diff --git a/airbyte_cdk/sources/declarative/async_job/job_orchestrator.py b/airbyte_cdk/sources/declarative/async_job/job_orchestrator.py index 398cee9f..bb8fb85f 100644 --- a/airbyte_cdk/sources/declarative/async_job/job_orchestrator.py +++ b/airbyte_cdk/sources/declarative/async_job/job_orchestrator.py @@ -437,10 +437,10 @@ def create_and_get_completed_partitions(self) -> Iterable[AsyncPartition]: yield from self._process_running_partitions_and_yield_completed_ones() self._wait_on_status_update() except Exception as exception: + LOGGER.warning( + f"Caught exception that stops the processing of the jobs: {exception}. Traceback: {traceback.format_exc()}" + ) if self._is_breaking_exception(exception): - LOGGER.warning( - f"Caught exception that stops the processing of the jobs: {exception}" - ) self._abort_all_running_jobs() raise exception