fix: use message=None instead of message="" in job_orchestrator (#935)

sophiecuiy · claude · web-flow · commit 61363369f998 · 2026-03-06T00:48:45.000Z
Co-authored-by: Claude Opus 4.6 &lt;noreply@anthropic.com&gt;
diff --git a/airbyte_cdk/sources/declarative/async_job/job_orchestrator.py b/airbyte_cdk/sources/declarative/async_job/job_orchestrator.py
@@ -481,7 +481,7 @@ def create_and_get_completed_partitions(self) -> Iterable[AsyncPartition]:
             # We emitted traced message but we didn't break on non_breaking_exception. We still need to raise an exception so that the
             # call of `create_and_get_completed_partitions` knows that there was an issue with some partitions and the sync is incomplete.
             raise AirbyteTracedException(
-                message="",
+                message=None,
                 internal_message="\n".join(
                     [
                         filter_secrets(exception.__repr__())

Original file line number	Diff line number	Diff line change
`@@ -481,7 +481,7 @@ def create_and_get_completed_partitions(self) -> Iterable[AsyncPartition]:`
`481`	`481`	`# We emitted traced message but we didn't break on non_breaking_exception. We still need to raise an exception so that the`
`482`	`482`	# call of `create_and_get_completed_partitions` knows that there was an issue with some partitions and the sync is incomplete.
`483`	`483`	`raise AirbyteTracedException(`
`484`		`- message="",`
	`484`	`+ message=None,`
`485`	`485`	`internal_message="\n".join(`
`486`	`486`	`[`
`487`	`487`	`filter_secrets(exception.__repr__())`