Skip to content

Commit

Permalink
fix(airbyte): add return statement to yield within a while loop in tr…
Browse files Browse the repository at this point in the history
…iggers (apache#38390)
  • Loading branch information
Lee-W authored and utkarsharma2 committed Apr 22, 2024
1 parent 7856750 commit 959f5da
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions airflow/providers/airbyte/triggers/airbyte.py
Original file line number Diff line number Diff line change
Expand Up @@ -80,6 +80,7 @@ async def run(self) -> AsyncIterator[TriggerEvent]:
"job_id": self.job_id,
}
)
return
await asyncio.sleep(self.poll_interval)
job_run_status = await hook.get_job_status(self.job_id)
if job_run_status == hook.SUCCEEDED:
Expand Down

0 comments on commit 959f5da

Please sign in to comment.