We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 4f0fcbc commit fab54c2Copy full SHA for fab54c2
1 file changed
airbyte_cdk/sources/declarative/concurrent_declarative_source.py
@@ -211,7 +211,8 @@ def _group_streams(
211
# so we need to treat them as synchronous
212
213
supports_file_transfer = (
214
- "file_uploader" in name_to_stream_mapping[declarative_stream.name]
+ isinstance(declarative_stream, DeclarativeStream)
215
+ and "file_uploader" in name_to_stream_mapping[declarative_stream.name]
216
)
217
218
if (
0 commit comments