2022-03-23 21:45:21 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.35.15-alpha 2022-03-23 21:45:21 INFO i.a.w.t.TemporalAttemptExecution(get):115 - Docker volume job log path: /tmp/workspace/64/2/logs.log 2022-03-23 21:45:21 INFO i.a.w.t.TemporalAttemptExecution(get):120 - Executing worker wrapper. Airbyte version: 0.35.15-alpha 2022-03-23 21:45:21 WARN i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):65 - Waiting for database to become available... 2022-03-23 21:45:21 INFO i.a.d.i.j.JobsDatabaseInstance(lambda$static$2):25 - Testing if jobs database is ready... 2022-03-23 21:45:21 INFO i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):90 - Database available! 2022-03-23 21:45:21 INFO i.a.d.Databases(createPostgresDatabaseWithRetry):48 - Database available! 2022-03-23 21:45:21 INFO i.a.w.DefaultReplicationWorker(run):103 - start sync worker. job id: 64 attempt id: 2 2022-03-23 21:45:21 INFO i.a.w.DefaultReplicationWorker(run):115 - configured sync modes: {null.pages=incremental - append, null.devices=incremental - append, null.daily_active_users=incremental - append, null.locations=incremental - append, null.monthly_active_users=incremental - append, null.weekly_active_users=incremental - append, null.two_weekly_active_users=incremental - append, null.four_weekly_active_users=incremental - append, null.traffic_sources=incremental - append, null.website_overview=incremental - append} 2022-03-23 21:45:21 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination... 2022-03-23 21:45:21 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-snowflake:0.4.20 exists... 2022-03-23 21:45:21 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-snowflake:0.4.20 was found locally. 2022-03-23 21:45:21 INFO i.a.w.p.DockerProcessFactory(create):157 - Preparing command: docker run --rm --init -i -w /data/64/2 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local airbyte/destination-snowflake:0.4.20 write --config destination_config.json --catalog destination_catalog.json 2022-03-23 21:45:21 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-google-analytics-v4:0.1.16 exists... 2022-03-23 21:45:21 INFO i.a.w.p.DockerProcessFactory(create):157 - Preparing command: docker run --rm --init -i -w /data/64/2 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local airbyte/source-google-analytics-v4:0.1.16 read --config source_config.json --catalog source_catalog.json --state input_state.json 2022-03-23 21:45:21 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-google-analytics-v4:0.1.16 was found locally. 2022-03-23 21:45:21 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):307 - Destination output thread started. 2022-03-23 21:45:21 INFO i.a.w.DefaultReplicationWorker(run):147 - Waiting for source and destination threads to complete. 2022-03-23 21:45:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):268 - Replication thread started. 2022-03-23 21:45:22 source > Starting syncing SourceGoogleAnalyticsV4 2022-03-23 21:45:22 destination > SLF4J: Class path contains multiple SLF4J bindings. 2022-03-23 21:45:22 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-03-23 21:45:22 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-03-23 21:45:22 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-03-23 21:45:22 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-03-23 21:45:23 destination > 2022-03-23 21:45:23 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json} 2022-03-23 21:45:23 destination > 2022-03-23 21:45:23 INFO i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2022-03-23 21:45:23 destination > 2022-03-23 21:45:23 INFO i.a.i.b.IntegrationRunner(runInternal):122 - Command: WRITE 2022-03-23 21:45:23 destination > 2022-03-23 21:45:23 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'} 2022-03-23 21:45:24 destination > 2022-03-23 21:45:24 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-03-23 21:45:24 destination > 2022-03-23 21:45:24 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-03-23 21:45:24 destination > 2022-03-23 21:45:24 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-03-23 21:45:24 destination > 2022-03-23 21:45:24 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword multiline - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-03-23 21:45:24 destination > 2022-03-23 21:45:24 INFO i.a.i.d.j.c.SwitchingDestination(getConsumer):65 - Using destination type: INTERNAL_STAGING 2022-03-23 21:45:24 source > Syncing stream: daily_active_users 2022-03-23 21:45:24 destination > 2022-03-23 21:45:24 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):92 - Write config: WriteConfig{streamName=GA-daily_active_users, namespace=null, outputSchemaName=AIRBYTE_SCHEMA, tmpTableName=_airbyte_tmp_cjd_GA_daily_active_users, outputTableName=_airbyte_raw_GA_daily_active_users, syncMode=append} 2022-03-23 21:45:24 destination > 2022-03-23 21:45:24 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):92 - Write config: WriteConfig{streamName=GA-devices, namespace=null, outputSchemaName=AIRBYTE_SCHEMA, tmpTableName=_airbyte_tmp_xau_GA_devices, outputTableName=_airbyte_raw_GA_devices, syncMode=append} 2022-03-23 21:45:24 destination > 2022-03-23 21:45:24 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):92 - Write config: WriteConfig{streamName=GA-four_weekly_active_users, namespace=null, outputSchemaName=AIRBYTE_SCHEMA, tmpTableName=_airbyte_tmp_pla_GA_four_weekly_active_users, outputTableName=_airbyte_raw_GA_four_weekly_active_users, syncMode=append} 2022-03-23 21:45:24 destination > 2022-03-23 21:45:24 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):92 - Write config: WriteConfig{streamName=GA-locations, namespace=null, outputSchemaName=AIRBYTE_SCHEMA, tmpTableName=_airbyte_tmp_mnz_GA_locations, outputTableName=_airbyte_raw_GA_locations, syncMode=append} 2022-03-23 21:45:24 destination > 2022-03-23 21:45:24 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):92 - Write config: WriteConfig{streamName=GA-monthly_active_users, namespace=null, outputSchemaName=AIRBYTE_SCHEMA, tmpTableName=_airbyte_tmp_dcn_GA_monthly_active_users, outputTableName=_airbyte_raw_GA_monthly_active_users, syncMode=append} 2022-03-23 21:45:24 destination > 2022-03-23 21:45:24 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):92 - Write config: WriteConfig{streamName=GA-pages, namespace=null, outputSchemaName=AIRBYTE_SCHEMA, tmpTableName=_airbyte_tmp_cpp_GA_pages, outputTableName=_airbyte_raw_GA_pages, syncMode=append} 2022-03-23 21:45:24 destination > 2022-03-23 21:45:24 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):92 - Write config: WriteConfig{streamName=GA-traffic_sources, namespace=null, outputSchemaName=AIRBYTE_SCHEMA, tmpTableName=_airbyte_tmp_pzg_GA_traffic_sources, outputTableName=_airbyte_raw_GA_traffic_sources, syncMode=append} 2022-03-23 21:45:24 destination > 2022-03-23 21:45:24 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):92 - Write config: WriteConfig{streamName=GA-two_weekly_active_users, namespace=null, outputSchemaName=AIRBYTE_SCHEMA, tmpTableName=_airbyte_tmp_xsb_GA_two_weekly_active_users, outputTableName=_airbyte_raw_GA_two_weekly_active_users, syncMode=append} 2022-03-23 21:45:24 destination > 2022-03-23 21:45:24 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):92 - Write config: WriteConfig{streamName=GA-website_overview, namespace=null, outputSchemaName=AIRBYTE_SCHEMA, tmpTableName=_airbyte_tmp_oox_GA_website_overview, outputTableName=_airbyte_raw_GA_website_overview, syncMode=append} 2022-03-23 21:45:24 destination > 2022-03-23 21:45:24 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):92 - Write config: WriteConfig{streamName=GA-weekly_active_users, namespace=null, outputSchemaName=AIRBYTE_SCHEMA, tmpTableName=_airbyte_tmp_col_GA_weekly_active_users, outputTableName=_airbyte_raw_GA_weekly_active_users, syncMode=append} 2022-03-23 21:45:24 destination > 2022-03-23 21:45:24 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):141 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started. 2022-03-23 21:45:24 destination > 2022-03-23 21:45:24 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):110 - Preparing tmp tables in destination started for 10 streams 2022-03-23 21:45:24 destination > 2022-03-23 21:45:24 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):118 - Preparing stage in destination started for schema AIRBYTE_SCHEMA stream GA-daily_active_users: tmp table: _airbyte_tmp_cjd_GA_daily_active_users, stage: AIRBYTE_SCHEMA__AIRBYTE_RAW_GA_DAILY_ACTIVE_USERS 2022-03-23 21:45:24 source > Backing off _send(...) for 5.0s (airbyte_cdk.sources.streams.http.exceptions.DefaultBackoffException) 2022-03-23 21:45:26 destination > 2022-03-23 21:45:26 INFO i.a.d.j.DefaultJdbcDatabase(lambda$query$1):106 - closing connection 2022-03-23 21:45:27 destination > 2022-03-23 21:45:27 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):129 - Preparing stage in destination completed for schema AIRBYTE_SCHEMA stream GA-daily_active_users 2022-03-23 21:45:27 destination > 2022-03-23 21:45:27 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):118 - Preparing stage in destination started for schema AIRBYTE_SCHEMA stream GA-devices: tmp table: _airbyte_tmp_xau_GA_devices, stage: AIRBYTE_SCHEMA__AIRBYTE_RAW_GA_DEVICES 2022-03-23 21:45:27 destination > 2022-03-23 21:45:27 INFO i.a.d.j.DefaultJdbcDatabase(lambda$query$1):106 - closing connection 2022-03-23 21:45:27 destination > 2022-03-23 21:45:27 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):129 - Preparing stage in destination completed for schema AIRBYTE_SCHEMA stream GA-devices 2022-03-23 21:45:27 destination > 2022-03-23 21:45:27 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):118 - Preparing stage in destination started for schema AIRBYTE_SCHEMA stream GA-four_weekly_active_users: tmp table: _airbyte_tmp_pla_GA_four_weekly_active_users, stage: AIRBYTE_SCHEMA__AIRBYTE_RAW_GA_FOUR_WEEKLY_ACTIVE_USERS 2022-03-23 21:45:27 destination > 2022-03-23 21:45:27 INFO i.a.d.j.DefaultJdbcDatabase(lambda$query$1):106 - closing connection 2022-03-23 21:45:28 destination > 2022-03-23 21:45:28 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):129 - Preparing stage in destination completed for schema AIRBYTE_SCHEMA stream GA-four_weekly_active_users 2022-03-23 21:45:28 destination > 2022-03-23 21:45:28 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):118 - Preparing stage in destination started for schema AIRBYTE_SCHEMA stream GA-locations: tmp table: _airbyte_tmp_mnz_GA_locations, stage: AIRBYTE_SCHEMA__AIRBYTE_RAW_GA_LOCATIONS 2022-03-23 21:45:28 destination > 2022-03-23 21:45:28 INFO i.a.d.j.DefaultJdbcDatabase(lambda$query$1):106 - closing connection 2022-03-23 21:45:28 destination > 2022-03-23 21:45:28 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):129 - Preparing stage in destination completed for schema AIRBYTE_SCHEMA stream GA-locations 2022-03-23 21:45:28 destination > 2022-03-23 21:45:28 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):118 - Preparing stage in destination started for schema AIRBYTE_SCHEMA stream GA-monthly_active_users: tmp table: _airbyte_tmp_dcn_GA_monthly_active_users, stage: AIRBYTE_SCHEMA__AIRBYTE_RAW_GA_MONTHLY_ACTIVE_USERS 2022-03-23 21:45:28 destination > 2022-03-23 21:45:28 INFO i.a.d.j.DefaultJdbcDatabase(lambda$query$1):106 - closing connection 2022-03-23 21:45:29 source > Caught retryable error '' after 1 tries. Waiting 5 seconds then retrying... 2022-03-23 21:45:29 source > Backing off _send(...) for 10.0s (airbyte_cdk.sources.streams.http.exceptions.DefaultBackoffException) 2022-03-23 21:45:29 destination > 2022-03-23 21:45:29 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):129 - Preparing stage in destination completed for schema AIRBYTE_SCHEMA stream GA-monthly_active_users 2022-03-23 21:45:29 destination > 2022-03-23 21:45:29 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):118 - Preparing stage in destination started for schema AIRBYTE_SCHEMA stream GA-pages: tmp table: _airbyte_tmp_cpp_GA_pages, stage: AIRBYTE_SCHEMA__AIRBYTE_RAW_GA_PAGES 2022-03-23 21:45:29 destination > 2022-03-23 21:45:29 INFO i.a.d.j.DefaultJdbcDatabase(lambda$query$1):106 - closing connection 2022-03-23 21:45:29 destination > 2022-03-23 21:45:29 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):129 - Preparing stage in destination completed for schema AIRBYTE_SCHEMA stream GA-pages 2022-03-23 21:45:29 destination > 2022-03-23 21:45:29 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):118 - Preparing stage in destination started for schema AIRBYTE_SCHEMA stream GA-traffic_sources: tmp table: _airbyte_tmp_pzg_GA_traffic_sources, stage: AIRBYTE_SCHEMA__AIRBYTE_RAW_GA_TRAFFIC_SOURCES 2022-03-23 21:45:30 destination > 2022-03-23 21:45:30 INFO i.a.d.j.DefaultJdbcDatabase(lambda$query$1):106 - closing connection 2022-03-23 21:45:30 destination > 2022-03-23 21:45:30 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):129 - Preparing stage in destination completed for schema AIRBYTE_SCHEMA stream GA-traffic_sources 2022-03-23 21:45:30 destination > 2022-03-23 21:45:30 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):118 - Preparing stage in destination started for schema AIRBYTE_SCHEMA stream GA-two_weekly_active_users: tmp table: _airbyte_tmp_xsb_GA_two_weekly_active_users, stage: AIRBYTE_SCHEMA__AIRBYTE_RAW_GA_TWO_WEEKLY_ACTIVE_USERS 2022-03-23 21:45:31 destination > 2022-03-23 21:45:31 INFO i.a.d.j.DefaultJdbcDatabase(lambda$query$1):106 - closing connection 2022-03-23 21:45:31 destination > 2022-03-23 21:45:31 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):129 - Preparing stage in destination completed for schema AIRBYTE_SCHEMA stream GA-two_weekly_active_users 2022-03-23 21:45:31 destination > 2022-03-23 21:45:31 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):118 - Preparing stage in destination started for schema AIRBYTE_SCHEMA stream GA-website_overview: tmp table: _airbyte_tmp_oox_GA_website_overview, stage: AIRBYTE_SCHEMA__AIRBYTE_RAW_GA_WEBSITE_OVERVIEW 2022-03-23 21:45:31 destination > 2022-03-23 21:45:31 INFO i.a.d.j.DefaultJdbcDatabase(lambda$query$1):106 - closing connection 2022-03-23 21:45:31 destination > 2022-03-23 21:45:31 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):129 - Preparing stage in destination completed for schema AIRBYTE_SCHEMA stream GA-website_overview 2022-03-23 21:45:31 destination > 2022-03-23 21:45:31 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):118 - Preparing stage in destination started for schema AIRBYTE_SCHEMA stream GA-weekly_active_users: tmp table: _airbyte_tmp_col_GA_weekly_active_users, stage: AIRBYTE_SCHEMA__AIRBYTE_RAW_GA_WEEKLY_ACTIVE_USERS 2022-03-23 21:45:32 destination > 2022-03-23 21:45:32 INFO i.a.d.j.DefaultJdbcDatabase(lambda$query$1):106 - closing connection 2022-03-23 21:45:32 destination > 2022-03-23 21:45:32 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):129 - Preparing stage in destination completed for schema AIRBYTE_SCHEMA stream GA-weekly_active_users 2022-03-23 21:45:32 destination > 2022-03-23 21:45:32 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):132 - Preparing tables in destination completed. 2022-03-23 21:45:39 source > Caught retryable error '' after 2 tries. Waiting 10 seconds then retrying... 2022-03-23 21:45:39 source > Backing off _send(...) for 20.0s (airbyte_cdk.sources.streams.http.exceptions.DefaultBackoffException) 2022-03-23 21:45:59 source > Caught retryable error '' after 3 tries. Waiting 20 seconds then retrying... 2022-03-23 21:45:59 source > Backing off _send(...) for 40.0s (airbyte_cdk.sources.streams.http.exceptions.DefaultBackoffException) 2022-03-23 21:46:39 source > Caught retryable error '' after 4 tries. Waiting 40 seconds then retrying... 2022-03-23 21:46:39 source > Backing off _send(...) for 80.0s (airbyte_cdk.sources.streams.http.exceptions.DefaultBackoffException) 2022-03-23 21:47:59 source > Caught retryable error '' after 5 tries. Waiting 80 seconds then retrying... 2022-03-23 21:47:59 source > Giving up _send(...) after 6 tries (airbyte_cdk.sources.streams.http.exceptions.DefaultBackoffException) 2022-03-23 21:47:59 source > Encountered an exception while reading stream SourceGoogleAnalyticsV4 Traceback (most recent call last): File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 108, in read internal_config=internal_config, File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 141, in _read_stream for record in record_iterator: File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 185, in _read_incremental for record_counter, record_data in enumerate(records, start=1): File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/streams/http/http.py", line 369, in read_records response = self._send_request(request, request_kwargs) File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/streams/http/http.py", line 333, in _send_request return backoff_handler(user_backoff_handler)(request, request_kwargs) File "/usr/local/lib/python3.7/site-packages/backoff/_sync.py", line 94, in retry ret = target(*args, **kwargs) File "/usr/local/lib/python3.7/site-packages/backoff/_sync.py", line 94, in retry ret = target(*args, **kwargs) File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/streams/http/http.py", line 294, in _send raise DefaultBackoffException(request=request, response=response) airbyte_cdk.sources.streams.http.exceptions.DefaultBackoffException 2022-03-23 21:47:59 source > Finished syncing SourceGoogleAnalyticsV4 2022-03-23 21:47:59 source > SourceGoogleAnalyticsV4 runtimes: 2022-03-23 21:47:59 source > Traceback (most recent call last): File "/airbyte/integration_code/main.py", line 13, in launch(source, sys.argv[1:]) File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/entrypoint.py", line 127, in launch for message in source_entrypoint.run(parsed_args): File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/entrypoint.py", line 118, in run for message in generator: File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 112, in read raise e File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 108, in read internal_config=internal_config, File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 141, in _read_stream for record in record_iterator: File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 185, in _read_incremental for record_counter, record_data in enumerate(records, start=1): File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/streams/http/http.py", line 369, in read_records response = self._send_request(request, request_kwargs) File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/streams/http/http.py", line 333, in _send_request return backoff_handler(user_backoff_handler)(request, request_kwargs) File "/usr/local/lib/python3.7/site-packages/backoff/_sync.py", line 94, in retry ret = target(*args, **kwargs) File "/usr/local/lib/python3.7/site-packages/backoff/_sync.py", line 94, in retry ret = target(*args, **kwargs) File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/streams/http/http.py", line 294, in _send raise DefaultBackoffException(request=request, response=response) airbyte_cdk.sources.streams.http.exceptions.DefaultBackoffException 2022-03-23 21:47:59 destination > 2022-03-23 21:47:59 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded. 2022-03-23 21:47:59 destination > 2022-03-23 21:47:59 INFO i.a.i.d.b.BufferedStreamConsumer(close):217 - executing on success close procedure. 2022-03-23 21:47:59 destination > 2022-03-23 21:47:59 INFO i.a.i.d.b.BufferedStreamConsumer(flushQueueToDestination):181 - Flushing buffer: 0 bytes 2022-03-23 21:47:59 destination > 2022-03-23 21:47:59 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):169 - Finalizing tables in destination started for 10 streams 2022-03-23 21:47:59 destination > 2022-03-23 21:47:59 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):177 - Finalizing stream GA-daily_active_users. schema AIRBYTE_SCHEMA, tmp table _airbyte_tmp_cjd_GA_daily_active_users, final table _airbyte_raw_GA_daily_active_users, stage path AIRBYTE_SCHEMA__AIRBYTE_RAW_GA_DAILY_ACTIVE_USERS/2022/03/23/21/5F6F96DA-6425-44B2-BA8E-A3B0E3ED2097/ 2022-03-23 21:48:00 destination > 2022-03-23 21:48:00 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):177 - Finalizing stream GA-devices. schema AIRBYTE_SCHEMA, tmp table _airbyte_tmp_xau_GA_devices, final table _airbyte_raw_GA_devices, stage path AIRBYTE_SCHEMA__AIRBYTE_RAW_GA_DEVICES/2022/03/23/21/5F6F96DA-6425-44B2-BA8E-A3B0E3ED2097/ 2022-03-23 21:48:01 destination > 2022-03-23 21:48:01 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):177 - Finalizing stream GA-four_weekly_active_users. schema AIRBYTE_SCHEMA, tmp table _airbyte_tmp_pla_GA_four_weekly_active_users, final table _airbyte_raw_GA_four_weekly_active_users, stage path AIRBYTE_SCHEMA__AIRBYTE_RAW_GA_FOUR_WEEKLY_ACTIVE_USERS/2022/03/23/21/5F6F96DA-6425-44B2-BA8E-A3B0E3ED2097/ 2022-03-23 21:48:02 destination > 2022-03-23 21:48:02 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):177 - Finalizing stream GA-locations. schema AIRBYTE_SCHEMA, tmp table _airbyte_tmp_mnz_GA_locations, final table _airbyte_raw_GA_locations, stage path AIRBYTE_SCHEMA__AIRBYTE_RAW_GA_LOCATIONS/2022/03/23/21/5F6F96DA-6425-44B2-BA8E-A3B0E3ED2097/ 2022-03-23 21:48:02 destination > 2022-03-23 21:48:02 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):177 - Finalizing stream GA-monthly_active_users. schema AIRBYTE_SCHEMA, tmp table _airbyte_tmp_dcn_GA_monthly_active_users, final table _airbyte_raw_GA_monthly_active_users, stage path AIRBYTE_SCHEMA__AIRBYTE_RAW_GA_MONTHLY_ACTIVE_USERS/2022/03/23/21/5F6F96DA-6425-44B2-BA8E-A3B0E3ED2097/ 2022-03-23 21:48:03 destination > 2022-03-23 21:48:03 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):177 - Finalizing stream GA-pages. schema AIRBYTE_SCHEMA, tmp table _airbyte_tmp_cpp_GA_pages, final table _airbyte_raw_GA_pages, stage path AIRBYTE_SCHEMA__AIRBYTE_RAW_GA_PAGES/2022/03/23/21/5F6F96DA-6425-44B2-BA8E-A3B0E3ED2097/ 2022-03-23 21:48:04 destination > 2022-03-23 21:48:04 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):177 - Finalizing stream GA-traffic_sources. schema AIRBYTE_SCHEMA, tmp table _airbyte_tmp_pzg_GA_traffic_sources, final table _airbyte_raw_GA_traffic_sources, stage path AIRBYTE_SCHEMA__AIRBYTE_RAW_GA_TRAFFIC_SOURCES/2022/03/23/21/5F6F96DA-6425-44B2-BA8E-A3B0E3ED2097/ 2022-03-23 21:48:05 destination > 2022-03-23 21:48:05 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):177 - Finalizing stream GA-two_weekly_active_users. schema AIRBYTE_SCHEMA, tmp table _airbyte_tmp_xsb_GA_two_weekly_active_users, final table _airbyte_raw_GA_two_weekly_active_users, stage path AIRBYTE_SCHEMA__AIRBYTE_RAW_GA_TWO_WEEKLY_ACTIVE_USERS/2022/03/23/21/5F6F96DA-6425-44B2-BA8E-A3B0E3ED2097/ 2022-03-23 21:48:06 destination > 2022-03-23 21:48:06 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):177 - Finalizing stream GA-website_overview. schema AIRBYTE_SCHEMA, tmp table _airbyte_tmp_oox_GA_website_overview, final table _airbyte_raw_GA_website_overview, stage path AIRBYTE_SCHEMA__AIRBYTE_RAW_GA_WEBSITE_OVERVIEW/2022/03/23/21/5F6F96DA-6425-44B2-BA8E-A3B0E3ED2097/ 2022-03-23 21:48:06 destination > 2022-03-23 21:48:06 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):177 - Finalizing stream GA-weekly_active_users. schema AIRBYTE_SCHEMA, tmp table _airbyte_tmp_col_GA_weekly_active_users, final table _airbyte_raw_GA_weekly_active_users, stage path AIRBYTE_SCHEMA__AIRBYTE_RAW_GA_WEEKLY_ACTIVE_USERS/2022/03/23/21/5F6F96DA-6425-44B2-BA8E-A3B0E3ED2097/ 2022-03-23 21:48:07 destination > 2022-03-23 21:48:07 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):197 - Executing finalization of tables. 2022-03-23 21:48:10 destination > 2022-03-23 21:48:10 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):199 - Finalizing tables in destination completed. 2022-03-23 21:48:10 destination > 2022-03-23 21:48:10 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):201 - Cleaning tmp tables in destination started for 10 streams 2022-03-23 21:48:10 destination > 2022-03-23 21:48:10 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):205 - Cleaning tmp table in destination started for stream GA-daily_active_users. schema AIRBYTE_SCHEMA, tmp table name: _airbyte_tmp_cjd_GA_daily_active_users 2022-03-23 21:48:10 destination > 2022-03-23 21:48:10 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):211 - Cleaning stage in destination started for stream GA-daily_active_users. schema AIRBYTE_SCHEMA, stage: AIRBYTE_SCHEMA__AIRBYTE_RAW_GA_DAILY_ACTIVE_USERS 2022-03-23 21:48:10 destination > 2022-03-23 21:48:10 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):205 - Cleaning tmp table in destination started for stream GA-devices. schema AIRBYTE_SCHEMA, tmp table name: _airbyte_tmp_xau_GA_devices 2022-03-23 21:48:10 destination > 2022-03-23 21:48:10 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):211 - Cleaning stage in destination started for stream GA-devices. schema AIRBYTE_SCHEMA, stage: AIRBYTE_SCHEMA__AIRBYTE_RAW_GA_DEVICES 2022-03-23 21:48:10 destination > 2022-03-23 21:48:10 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):205 - Cleaning tmp table in destination started for stream GA-four_weekly_active_users. schema AIRBYTE_SCHEMA, tmp table name: _airbyte_tmp_pla_GA_four_weekly_active_users 2022-03-23 21:48:10 destination > 2022-03-23 21:48:10 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):211 - Cleaning stage in destination started for stream GA-four_weekly_active_users. schema AIRBYTE_SCHEMA, stage: AIRBYTE_SCHEMA__AIRBYTE_RAW_GA_FOUR_WEEKLY_ACTIVE_USERS 2022-03-23 21:48:10 destination > 2022-03-23 21:48:10 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):205 - Cleaning tmp table in destination started for stream GA-locations. schema AIRBYTE_SCHEMA, tmp table name: _airbyte_tmp_mnz_GA_locations 2022-03-23 21:48:11 destination > 2022-03-23 21:48:11 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):211 - Cleaning stage in destination started for stream GA-locations. schema AIRBYTE_SCHEMA, stage: AIRBYTE_SCHEMA__AIRBYTE_RAW_GA_LOCATIONS 2022-03-23 21:48:11 destination > 2022-03-23 21:48:11 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):205 - Cleaning tmp table in destination started for stream GA-monthly_active_users. schema AIRBYTE_SCHEMA, tmp table name: _airbyte_tmp_dcn_GA_monthly_active_users 2022-03-23 21:48:11 destination > 2022-03-23 21:48:11 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):211 - Cleaning stage in destination started for stream GA-monthly_active_users. schema AIRBYTE_SCHEMA, stage: AIRBYTE_SCHEMA__AIRBYTE_RAW_GA_MONTHLY_ACTIVE_USERS 2022-03-23 21:48:11 destination > 2022-03-23 21:48:11 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):205 - Cleaning tmp table in destination started for stream GA-pages. schema AIRBYTE_SCHEMA, tmp table name: _airbyte_tmp_cpp_GA_pages 2022-03-23 21:48:11 destination > 2022-03-23 21:48:11 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):211 - Cleaning stage in destination started for stream GA-pages. schema AIRBYTE_SCHEMA, stage: AIRBYTE_SCHEMA__AIRBYTE_RAW_GA_PAGES 2022-03-23 21:48:11 destination > 2022-03-23 21:48:11 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):205 - Cleaning tmp table in destination started for stream GA-traffic_sources. schema AIRBYTE_SCHEMA, tmp table name: _airbyte_tmp_pzg_GA_traffic_sources 2022-03-23 21:48:12 destination > 2022-03-23 21:48:12 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):211 - Cleaning stage in destination started for stream GA-traffic_sources. schema AIRBYTE_SCHEMA, stage: AIRBYTE_SCHEMA__AIRBYTE_RAW_GA_TRAFFIC_SOURCES 2022-03-23 21:48:12 destination > 2022-03-23 21:48:12 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):205 - Cleaning tmp table in destination started for stream GA-two_weekly_active_users. schema AIRBYTE_SCHEMA, tmp table name: _airbyte_tmp_xsb_GA_two_weekly_active_users 2022-03-23 21:48:12 destination > 2022-03-23 21:48:12 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):211 - Cleaning stage in destination started for stream GA-two_weekly_active_users. schema AIRBYTE_SCHEMA, stage: AIRBYTE_SCHEMA__AIRBYTE_RAW_GA_TWO_WEEKLY_ACTIVE_USERS 2022-03-23 21:48:12 destination > 2022-03-23 21:48:12 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):205 - Cleaning tmp table in destination started for stream GA-website_overview. schema AIRBYTE_SCHEMA, tmp table name: _airbyte_tmp_oox_GA_website_overview 2022-03-23 21:48:12 destination > 2022-03-23 21:48:12 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):211 - Cleaning stage in destination started for stream GA-website_overview. schema AIRBYTE_SCHEMA, stage: AIRBYTE_SCHEMA__AIRBYTE_RAW_GA_WEBSITE_OVERVIEW 2022-03-23 21:48:12 destination > 2022-03-23 21:48:12 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):205 - Cleaning tmp table in destination started for stream GA-weekly_active_users. schema AIRBYTE_SCHEMA, tmp table name: _airbyte_tmp_col_GA_weekly_active_users 2022-03-23 21:48:12 destination > 2022-03-23 21:48:12 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):211 - Cleaning stage in destination started for stream GA-weekly_active_users. schema AIRBYTE_SCHEMA, stage: AIRBYTE_SCHEMA__AIRBYTE_RAW_GA_WEEKLY_ACTIVE_USERS 2022-03-23 21:48:13 destination > 2022-03-23 21:48:13 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):215 - Cleaning tmp tables and stages in destination completed. 2022-03-23 21:48:13 destination > 2022-03-23 21:48:13 INFO i.a.i.b.IntegrationRunner(runInternal):169 - Completed integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2022-03-23 21:48:14 ERROR i.a.w.DefaultReplicationWorker(run):158 - Sync worker failed. java.util.concurrent.ExecutionException: java.lang.RuntimeException: java.lang.RuntimeException: Source process exited with non-zero exit code 1 at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) ~[?:?] at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) ~[?:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:151) ~[io.airbyte-airbyte-workers-0.35.15-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:56) ~[io.airbyte-airbyte-workers-0.35.15-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:171) ~[io.airbyte-airbyte-workers-0.35.15-alpha.jar:?] at java.lang.Thread.run(Thread.java:833) [?:?] Suppressed: io.airbyte.workers.WorkerException: Source process exit with code 1. This warning is normal if the job was cancelled. at io.airbyte.workers.protocols.airbyte.DefaultAirbyteSource.close(DefaultAirbyteSource.java:136) ~[io.airbyte-airbyte-workers-0.35.15-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:125) ~[io.airbyte-airbyte-workers-0.35.15-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:56) ~[io.airbyte-airbyte-workers-0.35.15-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:171) ~[io.airbyte-airbyte-workers-0.35.15-alpha.jar:?] at java.lang.Thread.run(Thread.java:833) [?:?] Caused by: java.lang.RuntimeException: java.lang.RuntimeException: Source process exited with non-zero exit code 1 at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:295) ~[io.airbyte-airbyte-workers-0.35.15-alpha.jar:?] at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ~[?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?] ... 1 more Caused by: java.lang.RuntimeException: Source process exited with non-zero exit code 1 at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:287) ~[io.airbyte-airbyte-workers-0.35.15-alpha.jar:?] at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ~[?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?] ... 1 more 2022-03-23 21:48:14 INFO i.a.w.DefaultReplicationWorker(run):217 - sync summary: io.airbyte.config.ReplicationAttemptSummary@2e2b4ec3[status=failed,recordsSynced=0,bytesSynced=0,startTime=1648071921547,endTime=1648072094251,totalStats=io.airbyte.config.SyncStats@67a89340[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]] 2022-03-23 21:48:14 INFO i.a.w.DefaultReplicationWorker(run):239 - Source did not output any state messages 2022-03-23 21:48:14 WARN i.a.w.DefaultReplicationWorker(run):247 - State capture: No new state, falling back on input state: io.airbyte.config.State@862728b[state={}] 2022-03-23 21:48:14 INFO i.a.w.t.TemporalAttemptExecution(get):141 - Stopping cancellation check scheduling... 2022-03-23 21:48:14 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$1):149 - sync summary: io.airbyte.config.StandardSyncOutput@6a4a24ef[standardSyncSummary=io.airbyte.config.StandardSyncSummary@ad7efb0[status=failed,recordsSynced=0,bytesSynced=0,startTime=1648071921547,endTime=1648072094251,totalStats=io.airbyte.config.SyncStats@67a89340[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]],state=io.airbyte.config.State@862728b[state={}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@3306b30e[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@37183679[stream=io.airbyte.protocol.models.AirbyteStream@cce0129[name=GA-daily_active_users,jsonSchema={"type":["null","object"],"$schema":"http://json-schema.org/draft-07/schema#","properties":{"ga_date":{"type":["string"],"format":"date"},"view_id":{"type":["string"]},"ga_1dayUsers":{"type":["null","integer"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[ga_date],sourceDefinedPrimaryKey=[],namespace=,additionalProperties={}],syncMode=incremental,cursorField=[ga_date],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@39d1d56f[stream=io.airbyte.protocol.models.AirbyteStream@3f498f98[name=GA-devices,jsonSchema={"type":["null","object"],"$schema":"http://json-schema.org/draft-07/schema#","properties":{"ga_date":{"type":["string"],"format":"date"},"view_id":{"type":["string"]},"ga_users":{"type":["null","integer"]},"ga_browser":{"type":["string"]},"ga_exitRate":{"type":["null","number"]},"ga_newUsers":{"type":["null","integer"]},"ga_sessions":{"type":["null","integer"]},"ga_pageviews":{"type":["null","integer"]},"ga_bounceRate":{"type":["null","number"]},"ga_avgTimeOnPage":{"type":["null","number"]},"ga_deviceCategory":{"type":["string"]},"ga_operatingSystem":{"type":["string"]},"ga_sessionsPerUser":{"type":["null","number"]},"ga_avgSessionDuration":{"type":["null","number"]},"ga_pageviewsPerSession":{"type":["null","number"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[ga_date],sourceDefinedPrimaryKey=[],namespace=,additionalProperties={}],syncMode=incremental,cursorField=[ga_date],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@4914ddf6[stream=io.airbyte.protocol.models.AirbyteStream@352f4ab4[name=GA-four_weekly_active_users,jsonSchema={"type":["null","object"],"$schema":"http://json-schema.org/draft-07/schema#","properties":{"ga_date":{"type":["string"],"format":"date"},"view_id":{"type":["string"]},"ga_28dayUsers":{"type":["null","integer"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[ga_date],sourceDefinedPrimaryKey=[],namespace=,additionalProperties={}],syncMode=incremental,cursorField=[ga_date],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@2e29bd3[stream=io.airbyte.protocol.models.AirbyteStream@71a4f158[name=GA-locations,jsonSchema={"type":["null","object"],"$schema":"http://json-schema.org/draft-07/schema#","properties":{"ga_city":{"type":["string"]},"ga_date":{"type":["string"],"format":"date"},"view_id":{"type":["string"]},"ga_metro":{"type":["string"]},"ga_users":{"type":["null","integer"]},"ga_region":{"type":["string"]},"ga_country":{"type":["string"]},"ga_exitRate":{"type":["null","number"]},"ga_newUsers":{"type":["null","integer"]},"ga_sessions":{"type":["null","integer"]},"ga_continent":{"type":["string"]},"ga_pageviews":{"type":["null","integer"]},"ga_bounceRate":{"type":["null","number"]},"ga_subContinent":{"type":["string"]},"ga_avgTimeOnPage":{"type":["null","number"]},"ga_sessionsPerUser":{"type":["null","number"]},"ga_avgSessionDuration":{"type":["null","number"]},"ga_pageviewsPerSession":{"type":["null","number"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[ga_date],sourceDefinedPrimaryKey=[],namespace=,additionalProperties={}],syncMode=incremental,cursorField=[ga_date],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@1e3079f7[stream=io.airbyte.protocol.models.AirbyteStream@5105fa6f[name=GA-monthly_active_users,jsonSchema={"type":["null","object"],"$schema":"http://json-schema.org/draft-07/schema#","properties":{"ga_date":{"type":["string"],"format":"date"},"view_id":{"type":["string"]},"ga_30dayUsers":{"type":["null","integer"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[ga_date],sourceDefinedPrimaryKey=[],namespace=,additionalProperties={}],syncMode=incremental,cursorField=[ga_date],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@47afdf9f[stream=io.airbyte.protocol.models.AirbyteStream@1157c803[name=GA-pages,jsonSchema={"type":["null","object"],"$schema":"http://json-schema.org/draft-07/schema#","properties":{"ga_date":{"type":["string"],"format":"date"},"view_id":{"type":["string"]},"ga_exits":{"type":["null","integer"]},"ga_exitRate":{"type":["null","number"]},"ga_hostname":{"type":["string"]},"ga_pagePath":{"type":["string"]},"ga_entrances":{"type":["null","integer"]},"ga_pageviews":{"type":["null","integer"]},"ga_bounceRate":{"type":["null","number"]},"ga_entranceRate":{"type":["null","number"]},"ga_avgTimeOnPage":{"type":["null","number"]},"ga_uniquePageviews":{"type":["null","integer"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[ga_date],sourceDefinedPrimaryKey=[],namespace=,additionalProperties={}],syncMode=incremental,cursorField=[ga_date],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@cb5e41f[stream=io.airbyte.protocol.models.AirbyteStream@729da164[name=GA-traffic_sources,jsonSchema={"type":["null","object"],"$schema":"http://json-schema.org/draft-07/schema#","properties":{"ga_date":{"type":["string"],"format":"date"},"view_id":{"type":["string"]},"ga_users":{"type":["null","integer"]},"ga_medium":{"type":["string"]},"ga_source":{"type":["string"]},"ga_exitRate":{"type":["null","number"]},"ga_newUsers":{"type":["null","integer"]},"ga_sessions":{"type":["null","integer"]},"ga_pageviews":{"type":["null","integer"]},"ga_bounceRate":{"type":["null","number"]},"ga_avgTimeOnPage":{"type":["null","number"]},"ga_socialNetwork":{"type":["string"]},"ga_sessionsPerUser":{"type":["null","number"]},"ga_avgSessionDuration":{"type":["null","number"]},"ga_pageviewsPerSession":{"type":["null","number"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[ga_date],sourceDefinedPrimaryKey=[],namespace=,additionalProperties={}],syncMode=incremental,cursorField=[ga_date],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@4bf7db8f[stream=io.airbyte.protocol.models.AirbyteStream@64cf1522[name=GA-two_weekly_active_users,jsonSchema={"type":["null","object"],"$schema":"http://json-schema.org/draft-07/schema#","properties":{"ga_date":{"type":["string"],"format":"date"},"view_id":{"type":["string"]},"ga_14dayUsers":{"type":["null","integer"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[ga_date],sourceDefinedPrimaryKey=[],namespace=,additionalProperties={}],syncMode=incremental,cursorField=[ga_date],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@477990b8[stream=io.airbyte.protocol.models.AirbyteStream@58708fb2[name=GA-website_overview,jsonSchema={"type":["null","object"],"$schema":"http://json-schema.org/draft-07/schema#","properties":{"ga_date":{"type":["string"],"format":"date"},"view_id":{"type":["string"]},"ga_users":{"type":["null","integer"]},"ga_exitRate":{"type":["null","number"]},"ga_newUsers":{"type":["null","integer"]},"ga_sessions":{"type":["null","integer"]},"ga_pageviews":{"type":["null","integer"]},"ga_bounceRate":{"type":["null","number"]},"ga_avgTimeOnPage":{"type":["null","number"]},"ga_sessionsPerUser":{"type":["null","number"]},"ga_avgSessionDuration":{"type":["null","number"]},"ga_pageviewsPerSession":{"type":["null","number"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[ga_date],sourceDefinedPrimaryKey=[],namespace=,additionalProperties={}],syncMode=incremental,cursorField=[ga_date],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@2dae1c90[stream=io.airbyte.protocol.models.AirbyteStream@31d47a02[name=GA-weekly_active_users,jsonSchema={"type":["null","object"],"$schema":"http://json-schema.org/draft-07/schema#","properties":{"ga_date":{"type":["string"],"format":"date"},"view_id":{"type":["string"]},"ga_7dayUsers":{"type":["null","integer"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[ga_date],sourceDefinedPrimaryKey=[],namespace=,additionalProperties={}],syncMode=incremental,cursorField=[ga_date],destinationSyncMode=append,primaryKey=[],additionalProperties={}]],additionalProperties={}],failures=[io.airbyte.config.FailureReason@3aa3d0d0[failureOrigin=source,failureType=,internalMessage=java.lang.RuntimeException: java.lang.RuntimeException: Source process exited with non-zero exit code 1,externalMessage=Something went wrong within the source connector,metadata=io.airbyte.config.Metadata@66f2d529[additionalProperties={attemptNumber=2, jobId=64}],stacktrace=java.util.concurrent.CompletionException: java.lang.RuntimeException: java.lang.RuntimeException: Source process exited with non-zero exit code 1 at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315) at java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:320) at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1807) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at java.base/java.lang.Thread.run(Thread.java:833) Caused by: java.lang.RuntimeException: java.lang.RuntimeException: Source process exited with non-zero exit code 1 at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:295) at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ... 3 more Caused by: java.lang.RuntimeException: Source process exited with non-zero exit code 1 at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:287) ... 4 more ,timestamp=1648072079862]]] 2022-03-23 21:48:14 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):212 - Stopping temporal heartbeating... 2022-03-23 21:48:14 INFO i.a.c.p.ConfigRepository(updateConnectionState):545 - Updating connection 33fe65cd-8f48-4461-be59-30697eaee514 state: io.airbyte.config.State@df21641[state={}] 2022-03-23 21:48:14 INFO i.a.w.t.TemporalAttemptExecution(get):115 - Docker volume job log path: /tmp/workspace/64/2/logs.log 2022-03-23 21:48:14 INFO i.a.w.t.TemporalAttemptExecution(get):120 - Executing worker wrapper. Airbyte version: 0.35.15-alpha 2022-03-23 21:48:14 WARN i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):65 - Waiting for database to become available... 2022-03-23 21:48:14 INFO i.a.d.i.j.JobsDatabaseInstance(lambda$static$2):25 - Testing if jobs database is ready... 2022-03-23 21:48:14 INFO i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):90 - Database available! 2022-03-23 21:48:14 INFO i.a.d.Databases(createPostgresDatabaseWithRetry):48 - Database available! 2022-03-23 21:48:14 INFO i.a.w.DefaultNormalizationWorker(run):46 - Running normalization. 2022-03-23 21:48:14 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):122 - Running with normalization version: airbyte/normalization-snowflake:0.1.65 2022-03-23 21:48:14 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/normalization-snowflake:0.1.65 exists... 2022-03-23 21:48:14 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/normalization-snowflake:0.1.65 was found locally. 2022-03-23 21:48:14 INFO i.a.w.p.DockerProcessFactory(create):157 - Preparing command: docker run --rm --init -i -w /data/64/2/normalize --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local airbyte/normalization-snowflake:0.1.65 run --integration-type snowflake --config destination_config.json --catalog destination_catalog.json 2022-03-23 21:48:14 normalization > Running: transform-config --config destination_config.json --integration-type snowflake --out /data/64/2/normalize 2022-03-23 21:48:14 normalization > Namespace(config='destination_config.json', integration_type=, out='/data/64/2/normalize') 2022-03-23 21:48:14 normalization > transform_snowflake 2022-03-23 21:48:14 normalization > Running: transform-catalog --integration-type snowflake --profile-config-dir /data/64/2/normalize --catalog destination_catalog.json --out /data/64/2/normalize/models/generated/ --json-column _airbyte_data 2022-03-23 21:48:15 normalization > Processing destination_catalog.json... 2022-03-23 21:48:15 normalization > Generating airbyte_ctes/AIRBYTE_SCHEMA/GA_DAILY_ACTIVE_USERS_AB1.sql from GA-daily_active_users 2022-03-23 21:48:15 normalization > Generating airbyte_ctes/AIRBYTE_SCHEMA/GA_DAILY_ACTIVE_USERS_AB2.sql from GA-daily_active_users 2022-03-23 21:48:15 normalization > Generating airbyte_ctes/AIRBYTE_SCHEMA/GA_DAILY_ACTIVE_USERS_AB3.sql from GA-daily_active_users 2022-03-23 21:48:15 normalization > Generating airbyte_incremental/AIRBYTE_SCHEMA/GA_DAILY_ACTIVE_USERS.sql from GA-daily_active_users 2022-03-23 21:48:15 normalization > Generating airbyte_ctes/AIRBYTE_SCHEMA/GA_DEVICES_AB1.sql from GA-devices 2022-03-23 21:48:15 normalization > Generating airbyte_ctes/AIRBYTE_SCHEMA/GA_DEVICES_AB2.sql from GA-devices 2022-03-23 21:48:15 normalization > Generating airbyte_ctes/AIRBYTE_SCHEMA/GA_DEVICES_AB3.sql from GA-devices 2022-03-23 21:48:15 normalization > Generating airbyte_incremental/AIRBYTE_SCHEMA/GA_DEVICES.sql from GA-devices 2022-03-23 21:48:15 normalization > Generating airbyte_ctes/AIRBYTE_SCHEMA/GA_FOUR_WEEKLY_ACTIVE_USERS_AB1.sql from GA-four_weekly_active_users 2022-03-23 21:48:15 normalization > Generating airbyte_ctes/AIRBYTE_SCHEMA/GA_FOUR_WEEKLY_ACTIVE_USERS_AB2.sql from GA-four_weekly_active_users 2022-03-23 21:48:15 normalization > Generating airbyte_ctes/AIRBYTE_SCHEMA/GA_FOUR_WEEKLY_ACTIVE_USERS_AB3.sql from GA-four_weekly_active_users 2022-03-23 21:48:15 normalization > Generating airbyte_incremental/AIRBYTE_SCHEMA/GA_FOUR_WEEKLY_ACTIVE_USERS.sql from GA-four_weekly_active_users 2022-03-23 21:48:15 normalization > Generating airbyte_ctes/AIRBYTE_SCHEMA/GA_LOCATIONS_AB1.sql from GA-locations 2022-03-23 21:48:15 normalization > Generating airbyte_ctes/AIRBYTE_SCHEMA/GA_LOCATIONS_AB2.sql from GA-locations 2022-03-23 21:48:15 normalization > Generating airbyte_ctes/AIRBYTE_SCHEMA/GA_LOCATIONS_AB3.sql from GA-locations 2022-03-23 21:48:15 normalization > Generating airbyte_incremental/AIRBYTE_SCHEMA/GA_LOCATIONS.sql from GA-locations 2022-03-23 21:48:15 normalization > Generating airbyte_ctes/AIRBYTE_SCHEMA/GA_MONTHLY_ACTIVE_USERS_AB1.sql from GA-monthly_active_users 2022-03-23 21:48:15 normalization > Generating airbyte_ctes/AIRBYTE_SCHEMA/GA_MONTHLY_ACTIVE_USERS_AB2.sql from GA-monthly_active_users 2022-03-23 21:48:15 normalization > Generating airbyte_ctes/AIRBYTE_SCHEMA/GA_MONTHLY_ACTIVE_USERS_AB3.sql from GA-monthly_active_users 2022-03-23 21:48:15 normalization > Generating airbyte_incremental/AIRBYTE_SCHEMA/GA_MONTHLY_ACTIVE_USERS.sql from GA-monthly_active_users 2022-03-23 21:48:15 normalization > Generating airbyte_ctes/AIRBYTE_SCHEMA/GA_PAGES_AB1.sql from GA-pages 2022-03-23 21:48:15 normalization > Generating airbyte_ctes/AIRBYTE_SCHEMA/GA_PAGES_AB2.sql from GA-pages 2022-03-23 21:48:15 normalization > Generating airbyte_ctes/AIRBYTE_SCHEMA/GA_PAGES_AB3.sql from GA-pages 2022-03-23 21:48:15 normalization > Generating airbyte_incremental/AIRBYTE_SCHEMA/GA_PAGES.sql from GA-pages 2022-03-23 21:48:15 normalization > Generating airbyte_ctes/AIRBYTE_SCHEMA/GA_TRAFFIC_SOURCES_AB1.sql from GA-traffic_sources 2022-03-23 21:48:15 normalization > Generating airbyte_ctes/AIRBYTE_SCHEMA/GA_TRAFFIC_SOURCES_AB2.sql from GA-traffic_sources 2022-03-23 21:48:15 normalization > Generating airbyte_ctes/AIRBYTE_SCHEMA/GA_TRAFFIC_SOURCES_AB3.sql from GA-traffic_sources 2022-03-23 21:48:15 normalization > Generating airbyte_incremental/AIRBYTE_SCHEMA/GA_TRAFFIC_SOURCES.sql from GA-traffic_sources 2022-03-23 21:48:15 normalization > Generating airbyte_ctes/AIRBYTE_SCHEMA/GA_TWO_WEEKLY_ACTIVE_USERS_AB1.sql from GA-two_weekly_active_users 2022-03-23 21:48:15 normalization > Generating airbyte_ctes/AIRBYTE_SCHEMA/GA_TWO_WEEKLY_ACTIVE_USERS_AB2.sql from GA-two_weekly_active_users 2022-03-23 21:48:15 normalization > Generating airbyte_ctes/AIRBYTE_SCHEMA/GA_TWO_WEEKLY_ACTIVE_USERS_AB3.sql from GA-two_weekly_active_users 2022-03-23 21:48:15 normalization > Generating airbyte_incremental/AIRBYTE_SCHEMA/GA_TWO_WEEKLY_ACTIVE_USERS.sql from GA-two_weekly_active_users 2022-03-23 21:48:15 normalization > Generating airbyte_ctes/AIRBYTE_SCHEMA/GA_WEBSITE_OVERVIEW_AB1.sql from GA-website_overview 2022-03-23 21:48:15 normalization > Generating airbyte_ctes/AIRBYTE_SCHEMA/GA_WEBSITE_OVERVIEW_AB2.sql from GA-website_overview 2022-03-23 21:48:15 normalization > Generating airbyte_ctes/AIRBYTE_SCHEMA/GA_WEBSITE_OVERVIEW_AB3.sql from GA-website_overview 2022-03-23 21:48:15 normalization > Generating airbyte_incremental/AIRBYTE_SCHEMA/GA_WEBSITE_OVERVIEW.sql from GA-website_overview 2022-03-23 21:48:15 normalization > Generating airbyte_ctes/AIRBYTE_SCHEMA/GA_WEEKLY_ACTIVE_USERS_AB1.sql from GA-weekly_active_users 2022-03-23 21:48:15 normalization > Generating airbyte_ctes/AIRBYTE_SCHEMA/GA_WEEKLY_ACTIVE_USERS_AB2.sql from GA-weekly_active_users 2022-03-23 21:48:15 normalization > Generating airbyte_ctes/AIRBYTE_SCHEMA/GA_WEEKLY_ACTIVE_USERS_AB3.sql from GA-weekly_active_users 2022-03-23 21:48:15 normalization > Generating airbyte_incremental/AIRBYTE_SCHEMA/GA_WEEKLY_ACTIVE_USERS.sql from GA-weekly_active_users 2022-03-23 21:48:15 normalization > detected no config file for ssh, assuming ssh is off. 2022-03-23 21:48:16 normalization > Running with dbt=0.21.1 2022-03-23 21:48:17 normalization > Unable to do partial parsing because ../build/partial_parse.msgpack not found 2022-03-23 21:48:18 normalization > [WARNING]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources. 2022-03-23 21:48:18 normalization > There are 2 unused configuration paths: 2022-03-23 21:48:18 normalization > - models.airbyte_utils.generated.airbyte_views 2022-03-23 21:48:18 normalization > - models.airbyte_utils.generated.airbyte_tables 2022-03-23 21:48:18 normalization > 2022-03-23 21:48:18 normalization > Found 40 models, 0 tests, 0 snapshots, 0 analyses, 504 macros, 0 operations, 0 seed files, 10 sources, 0 exposures 2022-03-23 21:48:18 normalization > 2022-03-23 21:48:20 normalization > 21:48:20 | Concurrency: 5 threads (target='prod') 2022-03-23 21:48:20 normalization > 21:48:20 | 2022-03-23 21:48:27 normalization > 21:48:27 | 1 of 10 START incremental model AIRBYTE_SCHEMA.GA_LOCATIONS.................................................. [RUN] 2022-03-23 21:48:27 normalization > 21:48:27 | 2 of 10 START incremental model AIRBYTE_SCHEMA.GA_FOUR_WEEKLY_ACTIVE_USERS................................... [RUN] 2022-03-23 21:48:27 normalization > 21:48:27 | 3 of 10 START incremental model AIRBYTE_SCHEMA.GA_DAILY_ACTIVE_USERS......................................... [RUN] 2022-03-23 21:48:28 normalization > 21:48:28 | 4 of 10 START incremental model AIRBYTE_SCHEMA.GA_MONTHLY_ACTIVE_USERS....................................... [RUN] 2022-03-23 21:48:28 normalization > 21:48:28 | 5 of 10 START incremental model AIRBYTE_SCHEMA.GA_DEVICES.................................................... [RUN] 2022-03-23 21:48:30 normalization > 21:48:30 | 1 of 10 OK created incremental model AIRBYTE_SCHEMA.GA_LOCATIONS............................................. [SUCCESS 1 in 3.72s] 2022-03-23 21:48:30 normalization > 21:48:30 | 6 of 10 START incremental model AIRBYTE_SCHEMA.GA_PAGES...................................................... [RUN] 2022-03-23 21:48:31 normalization > 21:48:31 | 2 of 10 OK created incremental model AIRBYTE_SCHEMA.GA_FOUR_WEEKLY_ACTIVE_USERS.............................. [SUCCESS 1 in 3.51s] 2022-03-23 21:48:31 normalization > 21:48:31 | 7 of 10 START incremental model AIRBYTE_SCHEMA.GA_WEEKLY_ACTIVE_USERS........................................ [RUN] 2022-03-23 21:48:31 normalization > 21:48:31 | 3 of 10 OK created incremental model AIRBYTE_SCHEMA.GA_DAILY_ACTIVE_USERS.................................... [SUCCESS 1 in 4.20s] 2022-03-23 21:48:31 normalization > 21:48:31 | 8 of 10 START incremental model AIRBYTE_SCHEMA.GA_TRAFFIC_SOURCES............................................ [RUN] 2022-03-23 21:48:32 normalization > 21:48:32 | 4 of 10 OK created incremental model AIRBYTE_SCHEMA.GA_MONTHLY_ACTIVE_USERS.................................. [SUCCESS 1 in 3.80s] 2022-03-23 21:48:32 normalization > 21:48:32 | 9 of 10 START incremental model AIRBYTE_SCHEMA.GA_WEBSITE_OVERVIEW........................................... [RUN] 2022-03-23 21:48:33 normalization > 21:48:33 | 5 of 10 OK created incremental model AIRBYTE_SCHEMA.GA_DEVICES............................................... [SUCCESS 1 in 4.64s] 2022-03-23 21:48:33 normalization > 21:48:33 | 10 of 10 START incremental model AIRBYTE_SCHEMA.GA_TWO_WEEKLY_ACTIVE_USERS................................... [RUN] 2022-03-23 21:48:33 normalization > 21:48:33 | 7 of 10 OK created incremental model AIRBYTE_SCHEMA.GA_WEEKLY_ACTIVE_USERS................................... [SUCCESS 1 in 2.58s] 2022-03-23 21:48:33 normalization > 21:48:33 | 6 of 10 OK created incremental model AIRBYTE_SCHEMA.GA_PAGES................................................. [SUCCESS 1 in 2.86s] 2022-03-23 21:48:34 normalization > 21:48:34 | 8 of 10 OK created incremental model AIRBYTE_SCHEMA.GA_TRAFFIC_SOURCES....................................... [SUCCESS 1 in 2.45s] 2022-03-23 21:48:34 normalization > 21:48:34 | 9 of 10 OK created incremental model AIRBYTE_SCHEMA.GA_WEBSITE_OVERVIEW...................................... [SUCCESS 1 in 2.44s] 2022-03-23 21:48:35 normalization > 21:48:35 | 10 of 10 OK created incremental model AIRBYTE_SCHEMA.GA_TWO_WEEKLY_ACTIVE_USERS.............................. [SUCCESS 1 in 2.22s] 2022-03-23 21:48:35 normalization > 21:48:35 | 2022-03-23 21:48:35 normalization > 21:48:35 | Finished running 10 incremental models in 16.81s. 2022-03-23 21:48:35 normalization > 2022-03-23 21:48:35 normalization > Completed successfully 2022-03-23 21:48:35 normalization > 2022-03-23 21:48:35 normalization > Done. PASS=10 WARN=0 ERROR=0 SKIP=0 TOTAL=10 2022-03-23 21:48:35 INFO i.a.w.DefaultNormalizationWorker(run):69 - Normalization executed in 21 seconds. 2022-03-23 21:48:35 INFO i.a.w.t.TemporalAttemptExecution(get):141 - Stopping cancellation check scheduling... 2022-03-23 21:48:35 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):212 - Stopping temporal heartbeating...