From b6129a346908df304a503ebc654278d975ce8c73 Mon Sep 17 00:00:00 2001 From: maxi297 Date: Tue, 11 Mar 2025 09:39:44 -0400 Subject: [PATCH] Support column named type --- .../sources/file_based/stream/default_file_based_stream.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/airbyte_cdk/sources/file_based/stream/default_file_based_stream.py b/airbyte_cdk/sources/file_based/stream/default_file_based_stream.py index 604322549..42d01577c 100644 --- a/airbyte_cdk/sources/file_based/stream/default_file_based_stream.py +++ b/airbyte_cdk/sources/file_based/stream/default_file_based_stream.py @@ -356,7 +356,10 @@ def _fill_nulls(schema: Mapping[str, Any]) -> Mapping[str, Any]: if "null" not in v: schema[k] = ["null"] + v elif v != "null": - schema[k] = ["null", v] + if isinstance(v, (str, list)): + schema[k] = ["null", v] + else: + DefaultFileBasedStream._fill_nulls(v) else: DefaultFileBasedStream._fill_nulls(v) elif isinstance(schema, list):