diff --git a/python_modules/libraries/dagster-airbyte/dagster_airbyte/resources.py b/python_modules/libraries/dagster-airbyte/dagster_airbyte/resources.py index c0cf0b97dd55b..33c30737640ed 100644 --- a/python_modules/libraries/dagster-airbyte/dagster_airbyte/resources.py +++ b/python_modules/libraries/dagster-airbyte/dagster_airbyte/resources.py @@ -1065,6 +1065,7 @@ def sync_and_poll( ) time.sleep(poll_interval) + # We return these job details in the AirbyteOutput when the job succeeds poll_job_details = self.get_job_details(job.id) job = AirbyteJob.from_job_details(job_details=poll_job_details) if job.status in (