File tree Expand file tree Collapse file tree 1 file changed +8
-0
lines changed
airbyte_cdk/sources/declarative/parsers Expand file tree Collapse file tree 1 file changed +8
-0
lines changed Original file line number Diff line number Diff line change @@ -2818,6 +2818,10 @@ def create_record_selector(
2818
2818
else None
2819
2819
)
2820
2820
2821
+ if model .transform_before_filtering is None :
2822
+ # default to False if not set
2823
+ model .transform_before_filtering = False
2824
+
2821
2825
assert model .transform_before_filtering is not None # for mypy
2822
2826
2823
2827
transform_before_filtering = model .transform_before_filtering
@@ -2832,6 +2836,10 @@ def create_record_selector(
2832
2836
)
2833
2837
transform_before_filtering = True
2834
2838
2839
+ if model .schema_normalization is None :
2840
+ # default to no schema normalization if not set
2841
+ model .schema_normalization = SchemaNormalizationModel .None_
2842
+
2835
2843
schema_normalization = (
2836
2844
TypeTransformer (SCHEMA_TRANSFORMER_TYPE_MAPPING [model .schema_normalization ])
2837
2845
if isinstance (model .schema_normalization , SchemaNormalizationModel )
You can’t perform that action at this time.
0 commit comments