BUGFIX: Prevent KeyError: 'type'

fixes transferwise#357
jaceksan · Mar 6, 2023 · f6b16c5 · f6b16c5
1 parent aa6ac2e
commit f6b16c5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/target_snowflake/stream_utils.py b/target_snowflake/stream_utils.py
@@ -66,7 +66,7 @@ def reset_new_value(record: Dict, key: str, _format: str):
                         reset_new_value(record, key, type_dict['format'])
                         break
             else:
-                if 'string' in schema['properties'][key]['type'] and \
+                if 'type' in schema['properties'][key] and 'string' in schema['properties'][key]['type'] and \
                         schema['properties'][key].get('format', None) in {'date-time', 'time', 'date'}:
                     reset_new_value(record, key, schema['properties'][key]['format'])