Re: [I] RuntimeError in trigger creating hooks, Airflow 3.0.3 [airflow]

["victorrgez (via GitHub)" <gi...@apache.org>]

victorrgez commented on issue #53447:
URL: https://github.com/apache/airflow/issues/53447#issuecomment-3928296341

   Same issue in this part of the code:
   ```
   async def run(self) -> AsyncIterator[TriggerEvent]:
           """Make async connection to Dbt, polls for the pipeline run status."""
           hook = DbtCloudHook(self.conn_id, **self.hook_params)
           try:
               while await self.is_still_running(hook):
                   if self.end_time < time.time():
                       yield TriggerEvent(
                           {
                               "status": "error",
                               "message": f"Job run {self.run_id} has not reached a terminal status after "
                               f"{self.end_time} seconds.",
                               "run_id": self.run_id,
                           }
                       )
                       return
                   await asyncio.sleep(self.poll_interval)
               job_run_status = await hook.get_job_status(self.run_id, self.account_id)
   ```
   in this class `from airflow.providers.dbt.cloud.triggers.dbt import DbtCloudRunJobTrigger`


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@airflow.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org