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']