From 9c88382901eba3051a4399b1ed4b477e0d8cb035 Mon Sep 17 00:00:00 2001 From: Gary James Date: Tue, 3 Jan 2023 22:33:05 +0000 Subject: [PATCH] fix - Add default schema name to S3 archive metadata --- target_snowflake/__init__.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/target_snowflake/__init__.py b/target_snowflake/__init__.py index 1abbaebe..bba0b1c8 100644 --- a/target_snowflake/__init__.py +++ b/target_snowflake/__init__.py @@ -478,7 +478,7 @@ def flush_records(stream: str, if 'schema_name' not in stream_name_parts or 'table_name' not in stream_name_parts: raise Exception(f"Failed to extract schema and table names from stream '{stream}'") - archive_schema = stream_name_parts['schema_name'] + archive_schema = stream_name_parts['schema_name'] if stream_name_parts['schema_name'] is not None else db_sync.schema_name archive_table = stream_name_parts['table_name'] archive_tap = archive_load_files['tap']