Improve logging

maxi297 · maxi297 · commit c3fac9c6e4ba · 2025-01-31T17:29:50.000-05:00
diff --git a/airbyte_cdk/sources/declarative/async_job/job_orchestrator.py b/airbyte_cdk/sources/declarative/async_job/job_orchestrator.py
@@ -438,7 +438,7 @@ def create_and_get_completed_partitions(self) -> Iterable[AsyncPartition]:
                 self._wait_on_status_update()
             except Exception as exception:
                 LOGGER.warning(
-                    f"Caught exception that stops the processing of the jobs: {exception}"
+                    f"Caught exception that stops the processing of the jobs: {exception}. Traceback: {traceback.format_exc()}"
                 )
                 if self._is_breaking_exception(exception):
                     self._abort_all_running_jobs()

Original file line number	Diff line number	Diff line change
`@@ -438,7 +438,7 @@ def create_and_get_completed_partitions(self) -> Iterable[AsyncPartition]:`
`438`	`438`	`self._wait_on_status_update()`
`439`	`439`	`except Exception as exception:`
`440`	`440`	`LOGGER.warning(`
`441`		`- f"Caught exception that stops the processing of the jobs: {exception}"`
	`441`	`+ f"Caught exception that stops the processing of the jobs: {exception}. Traceback: {traceback.format_exc()}"`
`442`	`442`	`)`
`443`	`443`	`if self._is_breaking_exception(exception):`
`444`	`444`	`self._abort_all_running_jobs()`