```(meltano) lucaswiley@lucas-wiley pg-snowflake % meltano elt tap-postgres target-snowflake Running extract & load... No state was found, complete import. INFO Selected streams: ['userdata-public-_User'] INFO No currently_syncing found INFO Beginning sync of stream(userdata-public-_User) with sync method(full) INFO Stream userdata-public-_User is using full_table replication CRITICAL [Errno 32] Broken pipe Traceback (most recent call last): File "/Users/lucaswiley/Repos/onedrop-scripts/ingestion/pg-snowflake/.meltano/extractors/tap-postgres/venv/bin/tap-postgres", line 11, in <module> load_entry_point('tap-postgres==0.0.61', 'console_scripts', 'tap-postgres')() File "/Users/lucaswiley/Repos/onedrop-scripts/ingestion/pg-snowflake/.meltano/extractors/tap-postgres/venv/lib/python3.7/site-packages/tap_postgres/__init__.py", line 705, in main raise exc File "/Users/lucaswiley/Repos/onedrop-scripts/ingestion/pg-snowflake/.meltano/extractors/tap-postgres/venv/lib/python3.7/site-packages/tap_postgres/__init__.py", line 702, in main main_impl() File "/Users/lucaswiley/Repos/onedrop-scripts/ingestion/pg-snowflake/.meltano/extractors/tap-postgres/venv/lib/python3.7/site-packages/tap_postgres/__init__.py", line 696, in main_impl do_sync(conn_config, args.catalog.to_dict() if args.catalog else args.properties, args.config.get('default_replication_method'), state) File "/Users/lucaswiley/Repos/onedrop-scripts/ingestion/pg-snowflake/.meltano/extractors/tap-postgres/venv/lib/python3.7/site-packages/tap_postgres/__init__.py", line 666, in do_sync state = sync_traditional_stream(conn_config, stream, state, sync_method_lookup[stream['tap_stream_id']], end_lsn) File "/Users/lucaswiley/Repos/onedrop-scripts/ingestion/pg-snowflake/.meltano/extractors/tap-postgres/venv/lib/python3.7/site-packages/tap_postgres/__init__.py", line 552, in sync_traditional_stream state = do_sync_full_table(conn_config, stream, state, desired_columns, md_map) File "/Users/lucaswiley/Repos/onedrop-scripts/ingestion/pg-snowflake/.meltano/extractors/tap-postgres/venv/lib/python3.7/site-packages/tap_postgres/__init__.py", line 445, in do_sync_full_table sync_common.send_schema_message(stream, []) File "/Users/lucaswiley/Repos/onedrop-scripts/ingestion/pg-snowflake/.meltano/extractors/tap-postgres/venv/lib/python3.7/site-packages/tap_postgres/sync_strategies/common.py", line 30, in send_schema_message write_schema_message(schema_message) File "/Users/lucaswiley/Repos/onedrop-scripts/ingestion/pg-snowflake/.meltano/extractors/tap-postgres/venv/lib/python3.7/site-packages/tap_postgres/sync_strategies/common.py", line 15, in write_schema_message sys.stdout.flush() BrokenPipeError: [Errno 32] Broken pipe Exception ignored in: <_io.TextIOWrapper name='<stdout>' mode='w' encoding='UTF-8'> BrokenPipeError: [Errno 32] Broken pipe ELT could not complete, an error happened during the process: Subprocesses didn't exit cleanly: tap(120), target(-6) Traceback (most recent call last): File "/Users/lucaswiley/.pyenv/versions/3.7.7/lib/python3.7/site-packages/meltano/cli/elt.py", line 73, in elt run_extract_load(elt_context, session, dry_run=dry) File "/Users/lucaswiley/.pyenv/versions/3.7.7/lib/python3.7/site-packages/meltano/cli/elt.py", line 104, in run_extract_load singer_runner.run(session, **kwargs) File "/Users/lucaswiley/.pyenv/versions/3.7.7/lib/python3.7/site-packages/meltano/core/runner/singer.py", line 158, in run loop.run_until_complete(self.invoke(tap, target)) File "/Users/lucaswiley/.pyenv/versions/3.7.7/lib/python3.7/asyncio/base_events.py", line 587, in run_until_complete return future.result() File "/Users/lucaswiley/.pyenv/versions/3.7.7/lib/python3.7/site-packages/meltano/core/runner/singer.py", line 85, in invoke f"Subprocesses didn't exit cleanly: tap({tap_code}), target({target_code})" Exception: Subprocesses didn't exit cleanly: tap(120), target(-6) During ha…