Skip to content

Commit 41bbd3b

Browse files
authored
fix(file): Support column named type (#417)
1 parent 2607bcf commit 41bbd3b

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

airbyte_cdk/sources/file_based/stream/default_file_based_stream.py

+4-1
Original file line numberDiff line numberDiff line change
@@ -356,7 +356,10 @@ def _fill_nulls(schema: Mapping[str, Any]) -> Mapping[str, Any]:
356356
if "null" not in v:
357357
schema[k] = ["null"] + v
358358
elif v != "null":
359-
schema[k] = ["null", v]
359+
if isinstance(v, (str, list)):
360+
schema[k] = ["null", v]
361+
else:
362+
DefaultFileBasedStream._fill_nulls(v)
360363
else:
361364
DefaultFileBasedStream._fill_nulls(v)
362365
elif isinstance(schema, list):

0 commit comments

Comments
 (0)