Skip to content

Commit fab54c2

Browse files
maxi297octavia-squidington-iii
andauthored
fix: only check for file upload if stream is declarative (#501)
Co-authored-by: octavia-squidington-iii <[email protected]>
1 parent 4f0fcbc commit fab54c2

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

airbyte_cdk/sources/declarative/concurrent_declarative_source.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -211,7 +211,8 @@ def _group_streams(
211211
# so we need to treat them as synchronous
212212

213213
supports_file_transfer = (
214-
"file_uploader" in name_to_stream_mapping[declarative_stream.name]
214+
isinstance(declarative_stream, DeclarativeStream)
215+
and "file_uploader" in name_to_stream_mapping[declarative_stream.name]
215216
)
216217

217218
if (

0 commit comments

Comments
 (0)