From bd7c64ae8d04bc7886a92eb4faf3548f9f0051dd Mon Sep 17 00:00:00 2001 From: maxi297 Date: Tue, 22 Apr 2025 15:56:08 -0400 Subject: [PATCH 1/2] only check for file upload if stream is declarative --- airbyte_cdk/sources/declarative/concurrent_declarative_source.py | 1 + 1 file changed, 1 insertion(+) diff --git a/airbyte_cdk/sources/declarative/concurrent_declarative_source.py b/airbyte_cdk/sources/declarative/concurrent_declarative_source.py index 8d5ac3ab2..d0d1f3517 100644 --- a/airbyte_cdk/sources/declarative/concurrent_declarative_source.py +++ b/airbyte_cdk/sources/declarative/concurrent_declarative_source.py @@ -211,6 +211,7 @@ def _group_streams( # so we need to treat them as synchronous supports_file_transfer = ( + isinstance(declarative_stream, DeclarativeStream) and "file_uploader" in name_to_stream_mapping[declarative_stream.name] ) From 051dba88063a2d29967d43006d9ad49e1f6e35bd Mon Sep 17 00:00:00 2001 From: octavia-squidington-iii Date: Tue, 22 Apr 2025 19:59:35 +0000 Subject: [PATCH 2/2] Auto-fix lint and format issues --- .../sources/declarative/concurrent_declarative_source.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/airbyte_cdk/sources/declarative/concurrent_declarative_source.py b/airbyte_cdk/sources/declarative/concurrent_declarative_source.py index d0d1f3517..ba76b0a39 100644 --- a/airbyte_cdk/sources/declarative/concurrent_declarative_source.py +++ b/airbyte_cdk/sources/declarative/concurrent_declarative_source.py @@ -211,8 +211,8 @@ def _group_streams( # so we need to treat them as synchronous supports_file_transfer = ( - isinstance(declarative_stream, DeclarativeStream) and - "file_uploader" in name_to_stream_mapping[declarative_stream.name] + isinstance(declarative_stream, DeclarativeStream) + and "file_uploader" in name_to_stream_mapping[declarative_stream.name] ) if (