diff --git a/target_snowflake/stream_utils.py b/target_snowflake/stream_utils.py
index be7f6297..b2ff0fd8 100644
--- 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'])