From 943b89ced668bdfb1dd10172557f0469cc159bc5 Mon Sep 17 00:00:00 2001 From: Sophie Cui Date: Thu, 5 Mar 2026 16:35:49 -0800 Subject: [PATCH] fix: use message=None instead of message="" in job_orchestrator With the `is not None` checks in `AirbyteTracedException.__str__` (PR #927), `message=""` returns an empty string instead of falling back to the detailed `internal_message`. Using `None` lets the fallback work correctly. Co-Authored-By: Claude Opus 4.6 --- airbyte_cdk/sources/declarative/async_job/job_orchestrator.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/airbyte_cdk/sources/declarative/async_job/job_orchestrator.py b/airbyte_cdk/sources/declarative/async_job/job_orchestrator.py index 399f42430..0e957011c 100644 --- 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__())