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(
28182818 else None
28192819 )
28202820
2821+ if model .transform_before_filtering is None :
2822+ # default to False if not set
2823+ model .transform_before_filtering = False
2824+
28212825 assert model .transform_before_filtering is not None # for mypy
28222826
28232827 transform_before_filtering = model .transform_before_filtering
@@ -2832,6 +2836,10 @@ def create_record_selector(
28322836 )
28332837 transform_before_filtering = True
28342838
2839+ if model .schema_normalization is None :
2840+ # default to no schema normalization if not set
2841+ model .schema_normalization = SchemaNormalizationModel .None_
2842+
28352843 schema_normalization = (
28362844 TypeTransformer (SCHEMA_TRANSFORMER_TYPE_MAPPING [model .schema_normalization ])
28372845 if isinstance (model .schema_normalization , SchemaNormalizationModel )
You can’t perform that action at this time.
0 commit comments