Fix edge case validation

airbytehq · Dec 3, 2024 · 807d23e · 807d23e
1 parent 520998a
commit 807d23e
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/airbyte_cdk/sources/declarative/schema/dynamic_schema_loader.py b/airbyte_cdk/sources/declarative/schema/dynamic_schema_loader.py
@@ -173,9 +173,10 @@ def _replace_type_if_not_valid(self, field_type: str) -> str:
         """
         Replaces a field type if it matches a type mapping in `types_map`.
         """
-        for types_pair in self.schema_type_identifier.types_map:
-            if field_type == types_pair.current_type:
-                return types_pair.target_type
+        if self.schema_type_identifier.types_map:
+            for types_pair in self.schema_type_identifier.types_map:
+                if field_type == types_pair.current_type:
+                    return types_pair.target_type
         return field_type
 
     @staticmethod
@@ -187,6 +188,7 @@ def _make_field_nullable(
         """
 
         if is_nullable:
+            field_type = deepcopy(field_type)
             field_type["type"] = ["null", field_type["type"]]
         return field_type