diff --git a/target_snowflake/__init__.py b/target_snowflake/__init__.py index e2a39beb..dc83da2b 100644 --- a/target_snowflake/__init__.py +++ b/target_snowflake/__init__.py @@ -43,7 +43,7 @@ def add_metadata_columns_to_schema(schema_message): extended_schema_message = schema_message extended_schema_message['schema']['properties']['_sdc_extracted_at'] = { 'type': ['null', 'string'], 'format': 'date-time' } extended_schema_message['schema']['properties']['_sdc_batched_at'] = { 'type': ['null', 'string'], 'format': 'date-time' } - extended_schema_message['schema']['properties']['_sdc_deleted_at'] = { 'type': ['null', 'string'], 'format': 'date-time' } + extended_schema_message['schema']['properties']['_sdc_deleted_at'] = { 'type': ['null', 'string'] } return extended_schema_message