Having an issue with

tap-postgres

to

target-snowflake

(pipeline wise variant) where I cannot archive files - it looks like this line is evaluating to None, and causing it to not sync. Is there a way I can verify the

stream_name_parts['table_name']

exists?

Hey Sam, it's really not pretty, but you can hardcode db_sync.py in lines 416-417 (under the copy_to_archive method) to replace the 'tap' key's value. I did this and it works:

new_tap = {'tap': "dbo"}
        s3_archive_metadata.update(new_tap)