Skip to content

Commit b6129a3

Browse files
author
maxi297
committed
Support column named type
1 parent 969dec1 commit b6129a3

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

Lines changed: 4 additions & 1 deletion
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)