2022-11-03 12:35:00 INFO i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/886/0/logs.log 2022-11-03 12:35:00 INFO i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.16 2022-11-03 12:35:00 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):50 - Using default value for environment variable LOG_CONNECTOR_MESSAGES: 'false' 2022-11-03 12:35:00 INFO i.a.c.EnvConfigs(getEnvOrDefault):1091 - Using default value for environment variable METRIC_CLIENT: '' 2022-11-03 12:35:00 WARN i.a.m.l.MetricClientFactory(initialize):60 - Metric client is already initialized to 2022-11-03 12:35:00 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):50 - Using default value for environment variable LOG_CONNECTOR_MESSAGES: 'false' 2022-11-03 12:35:00 INFO i.a.w.g.DefaultReplicationWorker(run):125 - start sync worker. job id: 886 attempt id: 0 2022-11-03 12:35:00 INFO i.a.w.g.DefaultReplicationWorker(run):141 - configured sync modes: {null.media_insights=full_refresh - overwrite, null.stories=full_refresh - overwrite, null.story_insights=full_refresh - overwrite, null.user_lifetime_insights=full_refresh - append, null.users=full_refresh - overwrite, null.media=full_refresh - overwrite, null.user_insights=incremental - append} 2022-11-03 12:35:00 INFO i.a.w.i.DefaultAirbyteDestination(start):65 - Running destination... 2022-11-03 12:35:00 INFO i.a.c.i.LineGobbler(voidCall):114 - 2022-11-03 12:35:00 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- START REPLICATION ----- 2022-11-03 12:35:00 INFO i.a.c.i.LineGobbler(voidCall):114 - 2022-11-03 12:35:00 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/destination-bigquery:1.2.5 exists... 2022-11-03 12:35:00 INFO i.a.c.i.LineGobbler(voidCall):114 - airbyte/destination-bigquery:1.2.5 was found locally. 2022-11-03 12:35:00 INFO i.a.w.p.DockerProcessFactory(create):119 - Creating docker container = destination-bigquery-write-886-0-ffbti with resources io.airbyte.config.ResourceRequirements@1f46cf83[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] 2022-11-03 12:35:00 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/886/0 --log-driver none --name destination-bigquery-write-886-0-ffbti --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-bigquery:1.2.5 -e AIRBYTE_VERSION=0.40.16 -e WORKER_JOB_ID=886 airbyte/destination-bigquery:1.2.5 write --config destination_config.json --catalog destination_catalog.json 2022-11-03 12:35:00 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/source-instagram:1.0.0 exists... 2022-11-03 12:35:00 INFO i.a.c.i.LineGobbler(voidCall):114 - airbyte/source-instagram:1.0.0 was found locally. 2022-11-03 12:35:00 INFO i.a.w.p.DockerProcessFactory(create):119 - Creating docker container = source-instagram-read-886-0-sxrhv with resources io.airbyte.config.ResourceRequirements@64a86ba5[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] 2022-11-03 12:35:00 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/886/0 --log-driver none --name source-instagram-read-886-0-sxrhv --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/source-instagram:1.0.0 -e AIRBYTE_VERSION=0.40.16 -e WORKER_JOB_ID=886 airbyte/source-instagram:1.0.0 read --config source_config.json --catalog source_catalog.json --state input_state.json 2022-11-03 12:35:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):454 - Destination output thread started. 2022-11-03 12:35:00 INFO i.a.w.g.DefaultReplicationWorker(run):185 - Waiting for source and destination threads to complete. 2022-11-03 12:35:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):339 - Replication thread started. 2022-11-03 12:35:03 source > Starting syncing SourceInstagram 2022-11-03 12:35:03 source > Syncing stream: media 2022-11-03 12:35:06 destination > integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json} 2022-11-03 12:35:06 destination > Running integration: io.airbyte.integrations.destination.bigquery.BigQueryDestination 2022-11-03 12:35:06 destination > Command: WRITE 2022-11-03 12:35:06 destination > Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'} 2022-11-03 12:35:06 destination > Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-11-03 12:35:06 destination > Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-11-03 12:35:06 destination > Selected loading method is set to: STANDARD 2022-11-03 12:35:06 destination > The "standard" upload mode is not performant, and is not recommended for production. Please use the GCS upload mode if you are syncing a large amount of data. 2022-11-03 12:35:07 source > /usr/local/lib/python3.9/site-packages/facebook_business/utils/api_utils.py:30: UserWarning: media does not allow field children 2022-11-03 12:35:07 source > warnings.warn(message) 2022-11-03 12:35:07 destination > Selected loading method is set to: STANDARD 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:09 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:09 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:09 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 12:35:10 destination > Partitioned table created successfully: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=misc, tableId=_airbyte_tmp_aik_instagram_media}} 2022-11-03 12:35:10 destination > Selected loading method is set to: STANDARD 2022-11-03 12:35:11 destination > Selected loading method is set to: STANDARD 2022-11-03 12:35:11 destination > Partitioned table created successfully: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=misc, tableId=_airbyte_tmp_yse_instagram_media_insights}} 2022-11-03 12:35:11 destination > Selected loading method is set to: STANDARD 2022-11-03 12:35:11 destination > Selected loading method is set to: STANDARD 2022-11-03 12:35:12 destination > Partitioned table created successfully: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=misc, tableId=_airbyte_tmp_zaf_instagram_stories}} 2022-11-03 12:35:12 destination > Selected loading method is set to: STANDARD 2022-11-03 12:35:12 destination > Selected loading method is set to: STANDARD 2022-11-03 12:35:12 destination > Partitioned table created successfully: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=misc, tableId=_airbyte_tmp_nvf_instagram_story_insights}} 2022-11-03 12:35:12 destination > Selected loading method is set to: STANDARD 2022-11-03 12:35:13 destination > Selected loading method is set to: STANDARD 2022-11-03 12:35:13 destination > Partitioned table created successfully: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=misc, tableId=_airbyte_tmp_eek_instagram_user_insights}} 2022-11-03 12:35:13 destination > Selected loading method is set to: STANDARD 2022-11-03 12:35:14 destination > Selected loading method is set to: STANDARD 2022-11-03 12:35:14 destination > Partitioned table created successfully: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=misc, tableId=_airbyte_tmp_nuu_instagram_user_lifetime_insights}} 2022-11-03 12:35:14 destination > Selected loading method is set to: STANDARD 2022-11-03 12:35:14 destination > Selected loading method is set to: STANDARD 2022-11-03 12:35:15 destination > Partitioned table created successfully: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=misc, tableId=_airbyte_tmp_szr_instagram_users}} 2022-11-03 12:35:15 destination > Selected loading method is set to: STANDARD 2022-11-03 12:35:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):369 - Records read: 1000 (925 KB) 2022-11-03 12:36:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):369 - Records read: 2000 (2 MB) 2022-11-03 12:39:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):369 - Records read: 3000 (3 MB) 2022-11-03 12:39:06 source > Read 3487 records from media stream 2022-11-03 12:39:06 source > Finished syncing media 2022-11-03 12:39:06 source > SourceInstagram runtimes: Syncing stream media 0:04:03.819768 2022-11-03 12:39:06 source > Syncing stream: media_insights 2022-11-03 12:40:21 source > /usr/local/lib/python3.9/site-packages/facebook_business/utils/api_utils.py:30: UserWarning: value of metric might not be compatible. Expect list; got 2022-11-03 12:40:21 source > warnings.warn(message) 2022-11-03 12:41:41 source > Backing off call(...) for 5.0s (facebook_business.exceptions.FacebookRequestError: Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17866676527332611/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "A8KFwfIx-LaO0t1HgLF00Ad" } }) 2022-11-03 12:41:46 source > Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17866676527332611/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "A8KFwfIx-LaO0t1HgLF00Ad" } } 2022-11-03 12:41:46 source > Caught retryable error after 1 tries. Waiting 5 more seconds then retrying... 2022-11-03 12:41:46 source > Backing off call(...) for 10.0s (facebook_business.exceptions.FacebookRequestError: Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17866676527332611/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "AQdhrpbMoTXGwwA8TG9AxsZ" } }) 2022-11-03 12:41:56 source > Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17866676527332611/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "AQdhrpbMoTXGwwA8TG9AxsZ" } } 2022-11-03 12:41:56 source > Caught retryable error after 2 tries. Waiting 10 more seconds then retrying... 2022-11-03 12:41:56 source > Backing off call(...) for 20.0s (facebook_business.exceptions.FacebookRequestError: Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17866676527332611/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "AmDcQpzVG1SrlVoSDD_tp3a" } }) 2022-11-03 12:42:16 source > Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17866676527332611/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "AmDcQpzVG1SrlVoSDD_tp3a" } } 2022-11-03 12:42:16 source > Caught retryable error after 3 tries. Waiting 20 more seconds then retrying... 2022-11-03 12:42:16 source > Backing off call(...) for 40.0s (facebook_business.exceptions.FacebookRequestError: Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17866676527332611/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "A4BoHULNTdFJdPqI4XRW-uu" } }) 2022-11-03 12:42:56 source > Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17866676527332611/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "A4BoHULNTdFJdPqI4XRW-uu" } } 2022-11-03 12:42:56 source > Caught retryable error after 4 tries. Waiting 40 more seconds then retrying... 2022-11-03 12:42:56 source > Backing off call(...) for 80.0s (facebook_business.exceptions.FacebookRequestError: Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17866676527332611/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "A08xMS-dZPZxHpA87CGvZMA" } }) 2022-11-03 12:44:17 source > Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17866676527332611/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "A08xMS-dZPZxHpA87CGvZMA" } } 2022-11-03 12:44:17 source > Caught retryable error after 5 tries. Waiting 80 more seconds then retrying... 2022-11-03 12:44:17 source > Backing off call(...) for 160.0s (facebook_business.exceptions.FacebookRequestError: Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17866676527332611/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "AsugW8hA6K4Ytz_w2wycxw2" } }) 2022-11-03 12:46:57 source > Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17866676527332611/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "AsugW8hA6K4Ytz_w2wycxw2" } } 2022-11-03 12:46:57 source > Caught retryable error after 6 tries. Waiting 160 more seconds then retrying... 2022-11-03 12:46:57 source > Giving up call(...) after 7 tries (facebook_business.exceptions.FacebookRequestError: Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17866676527332611/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "AmpttLvz-MMCsYoF3eA5hpP" } }) 2022-11-03 12:46:57 source > Insights error for business_account_id 17841400844997659: Media posted before business account conversion 2022-11-03 12:48:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):369 - Records read: 4000 (3 MB) 2022-11-03 12:51:34 source > Backing off call(...) for 5.0s (facebook_business.exceptions.FacebookRequestError: Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17844517699238475/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "A7im09Ug_lwM9OerVnmhjsM" } }) 2022-11-03 12:51:39 source > Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17844517699238475/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "A7im09Ug_lwM9OerVnmhjsM" } } 2022-11-03 12:51:39 source > Caught retryable error after 1 tries. Waiting 5 more seconds then retrying... 2022-11-03 12:51:39 source > Backing off call(...) for 10.0s (facebook_business.exceptions.FacebookRequestError: Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17844517699238475/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "AWSEoGm_nRCda5UI7DiYqar" } }) 2022-11-03 12:51:49 source > Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17844517699238475/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "AWSEoGm_nRCda5UI7DiYqar" } } 2022-11-03 12:51:49 source > Caught retryable error after 2 tries. Waiting 10 more seconds then retrying... 2022-11-03 12:51:49 source > Backing off call(...) for 20.0s (facebook_business.exceptions.FacebookRequestError: Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17844517699238475/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "ArtFZhhM2IEDQQUtsS650Qq" } }) 2022-11-03 12:52:10 source > Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17844517699238475/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "ArtFZhhM2IEDQQUtsS650Qq" } } 2022-11-03 12:52:10 source > Caught retryable error after 3 tries. Waiting 20 more seconds then retrying... 2022-11-03 12:52:10 source > Backing off call(...) for 40.0s (facebook_business.exceptions.FacebookRequestError: Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17844517699238475/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "AW04aiScz1oNqSxTYEMOYxl" } }) 2022-11-03 12:52:50 source > Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17844517699238475/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "AW04aiScz1oNqSxTYEMOYxl" } } 2022-11-03 12:52:50 source > Caught retryable error after 4 tries. Waiting 40 more seconds then retrying... 2022-11-03 12:52:50 source > Backing off call(...) for 80.0s (facebook_business.exceptions.FacebookRequestError: Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17844517699238475/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "AJkcrPntFI0-2IU0L33MUAq" } }) 2022-11-03 12:54:10 source > Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17844517699238475/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "AJkcrPntFI0-2IU0L33MUAq" } } 2022-11-03 12:54:10 source > Caught retryable error after 5 tries. Waiting 80 more seconds then retrying... 2022-11-03 12:54:10 source > Backing off call(...) for 160.0s (facebook_business.exceptions.FacebookRequestError: Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17844517699238475/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "Agjey1DyOtjnuNr4zZtJtTC" } }) 2022-11-03 12:56:50 source > Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17844517699238475/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "Agjey1DyOtjnuNr4zZtJtTC" } } 2022-11-03 12:56:50 source > Caught retryable error after 6 tries. Waiting 160 more seconds then retrying... 2022-11-03 12:56:50 source > Giving up call(...) after 7 tries (facebook_business.exceptions.FacebookRequestError: Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17844517699238475/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "AnKhU-Vf49hH7KEZCZ7javQ" } }) 2022-11-03 12:56:50 source > Insights error for business_account_id 17841406448385387: Media posted before business account conversion 2022-11-03 12:58:49 source > Backing off call(...) for 5.0s (facebook_business.exceptions.FacebookRequestError: Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17862901051076051/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "AEU_Rm2vGXB1f4gB35phXsL" } }) 2022-11-03 12:58:54 source > Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17862901051076051/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "AEU_Rm2vGXB1f4gB35phXsL" } } 2022-11-03 12:58:54 source > Caught retryable error after 1 tries. Waiting 5 more seconds then retrying... 2022-11-03 12:58:54 source > Backing off call(...) for 10.0s (facebook_business.exceptions.FacebookRequestError: Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17862901051076051/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "At0E8STXm52nk2zRsDAmw5d" } }) 2022-11-03 12:59:04 source > Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17862901051076051/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "At0E8STXm52nk2zRsDAmw5d" } } 2022-11-03 12:59:04 source > Caught retryable error after 2 tries. Waiting 10 more seconds then retrying... 2022-11-03 12:59:04 source > Backing off call(...) for 20.0s (facebook_business.exceptions.FacebookRequestError: Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17862901051076051/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "A3RTkefMArh8ierTMPHB2ps" } }) 2022-11-03 12:59:25 source > Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17862901051076051/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "A3RTkefMArh8ierTMPHB2ps" } } 2022-11-03 12:59:25 source > Caught retryable error after 3 tries. Waiting 20 more seconds then retrying... 2022-11-03 12:59:25 source > Backing off call(...) for 40.0s (facebook_business.exceptions.FacebookRequestError: Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17862901051076051/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "An78RI0dcuSOZiPmLt4juy9" } }) 2022-11-03 13:00:05 source > Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17862901051076051/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "An78RI0dcuSOZiPmLt4juy9" } } 2022-11-03 13:00:05 source > Caught retryable error after 4 tries. Waiting 40 more seconds then retrying... 2022-11-03 13:00:05 source > Backing off call(...) for 80.0s (facebook_business.exceptions.FacebookRequestError: Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17862901051076051/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "ASGScWzeQOYA2uZSfQfeZbh" } }) 2022-11-03 13:01:25 source > Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17862901051076051/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "ASGScWzeQOYA2uZSfQfeZbh" } } 2022-11-03 13:01:25 source > Caught retryable error after 5 tries. Waiting 80 more seconds then retrying... 2022-11-03 13:01:25 source > Backing off call(...) for 160.0s (facebook_business.exceptions.FacebookRequestError: Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17862901051076051/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "AmghFJlCN8Wxm_l7XCgtlyB" } }) 2022-11-03 13:04:05 source > Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17862901051076051/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "AmghFJlCN8Wxm_l7XCgtlyB" } } 2022-11-03 13:04:05 source > Caught retryable error after 6 tries. Waiting 160 more seconds then retrying... 2022-11-03 13:04:05 source > Giving up call(...) after 7 tries (facebook_business.exceptions.FacebookRequestError: Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17862901051076051/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "A0Bp0--mscoKs95q5E3uqga" } }) 2022-11-03 13:04:05 source > Insights error for business_account_id 17841400657993479: Media posted before business account conversion 2022-11-03 13:05:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):369 - Records read: 5000 (3 MB) 2022-11-03 13:08:37 source > Backing off call(...) for 5.0s (facebook_business.exceptions.FacebookRequestError: Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17864151274064454/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "AK9pRVqbsop28rJe1rqFwiE" } }) 2022-11-03 13:08:42 source > Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17864151274064454/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "AK9pRVqbsop28rJe1rqFwiE" } } 2022-11-03 13:08:42 source > Caught retryable error after 1 tries. Waiting 5 more seconds then retrying... 2022-11-03 13:08:42 source > Backing off call(...) for 10.0s (facebook_business.exceptions.FacebookRequestError: Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17864151274064454/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "A3Kq3u5ftISOK93Dafp3Wtd" } }) 2022-11-03 13:08:52 source > Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17864151274064454/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "A3Kq3u5ftISOK93Dafp3Wtd" } } 2022-11-03 13:08:52 source > Caught retryable error after 2 tries. Waiting 10 more seconds then retrying... 2022-11-03 13:08:52 source > Backing off call(...) for 20.0s (facebook_business.exceptions.FacebookRequestError: Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17864151274064454/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "AGqvfI1pwZGHKbGzwP23O4y" } }) 2022-11-03 13:09:12 source > Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17864151274064454/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "AGqvfI1pwZGHKbGzwP23O4y" } } 2022-11-03 13:09:12 source > Caught retryable error after 3 tries. Waiting 20 more seconds then retrying... 2022-11-03 13:09:12 source > Backing off call(...) for 40.0s (facebook_business.exceptions.FacebookRequestError: Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17864151274064454/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "AzTqOJbwVgRxV9XVjO8Z1rN" } }) 2022-11-03 13:09:52 source > Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17864151274064454/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "AzTqOJbwVgRxV9XVjO8Z1rN" } } 2022-11-03 13:09:52 source > Caught retryable error after 4 tries. Waiting 40 more seconds then retrying... 2022-11-03 13:09:52 source > Backing off call(...) for 80.0s (facebook_business.exceptions.FacebookRequestError: Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17864151274064454/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "ANNUCLDDjgTh5OUqc06nqKX" } }) 2022-11-03 13:11:13 source > Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17864151274064454/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "ANNUCLDDjgTh5OUqc06nqKX" } } 2022-11-03 13:11:13 source > Caught retryable error after 5 tries. Waiting 80 more seconds then retrying... 2022-11-03 13:11:13 source > Backing off call(...) for 160.0s (facebook_business.exceptions.FacebookRequestError: Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17864151274064454/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "ALf3TjKxMExdK-1EjIw4ngb" } }) 2022-11-03 13:13:53 source > Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17864151274064454/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "ALf3TjKxMExdK-1EjIw4ngb" } } 2022-11-03 13:13:53 source > Caught retryable error after 6 tries. Waiting 160 more seconds then retrying... 2022-11-03 13:13:53 source > Giving up call(...) after 7 tries (facebook_business.exceptions.FacebookRequestError: Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17864151274064454/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "ATQvWkisubLeWpcPNgYZZak" } }) 2022-11-03 13:13:53 source > Insights error for business_account_id 17841403860219174: Media posted before business account conversion 2022-11-03 13:16:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):369 - Records read: 6000 (4 MB) 2022-11-03 13:19:35 source > Backing off call(...) for 5.0s (facebook_business.exceptions.FacebookRequestError: Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17897537821166464/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "ABmSzv69jmjypavmO7GuTmC" } }) 2022-11-03 13:19:40 source > Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17897537821166464/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "ABmSzv69jmjypavmO7GuTmC" } } 2022-11-03 13:19:40 source > Caught retryable error after 1 tries. Waiting 5 more seconds then retrying... 2022-11-03 13:19:40 source > Backing off call(...) for 10.0s (facebook_business.exceptions.FacebookRequestError: Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17897537821166464/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "AE_DPLEqfPlPkaBNDpWvX4s" } }) 2022-11-03 13:19:50 source > Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17897537821166464/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "AE_DPLEqfPlPkaBNDpWvX4s" } } 2022-11-03 13:19:50 source > Caught retryable error after 2 tries. Waiting 10 more seconds then retrying... 2022-11-03 13:19:50 source > Backing off call(...) for 20.0s (facebook_business.exceptions.FacebookRequestError: Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17897537821166464/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "AUpnFeRCLFlHXbkjqeJIjNF" } }) 2022-11-03 13:20:11 source > Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17897537821166464/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "AUpnFeRCLFlHXbkjqeJIjNF" } } 2022-11-03 13:20:11 source > Caught retryable error after 3 tries. Waiting 20 more seconds then retrying... 2022-11-03 13:20:11 source > Backing off call(...) for 40.0s (facebook_business.exceptions.FacebookRequestError: Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17897537821166464/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "A64w9j08CTXqhLcr-RQHDVX" } }) 2022-11-03 13:20:52 source > Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17897537821166464/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "A64w9j08CTXqhLcr-RQHDVX" } } 2022-11-03 13:20:52 source > Caught retryable error after 4 tries. Waiting 40 more seconds then retrying... 2022-11-03 13:20:52 source > Backing off call(...) for 80.0s (facebook_business.exceptions.FacebookRequestError: Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17897537821166464/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "ASvCCa0v5UX7p5Y7Q3YM9Q-" } }) 2022-11-03 13:22:12 source > Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17897537821166464/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "ASvCCa0v5UX7p5Y7Q3YM9Q-" } } 2022-11-03 13:22:12 source > Caught retryable error after 5 tries. Waiting 80 more seconds then retrying... 2022-11-03 13:22:12 source > Backing off call(...) for 160.0s (facebook_business.exceptions.FacebookRequestError: Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17897537821166464/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "A7zXXBBY2jp66GmXSy62hvS" } }) 2022-11-03 13:24:52 source > Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17897537821166464/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "A7zXXBBY2jp66GmXSy62hvS" } } 2022-11-03 13:24:52 source > Caught retryable error after 6 tries. Waiting 160 more seconds then retrying... 2022-11-03 13:24:52 source > Giving up call(...) after 7 tries (facebook_business.exceptions.FacebookRequestError: Message: Call was not successful Method: GET Path: https://graph.facebook.com/v11.0/17897537821166464/insights Params: {'metric': '["engagement","impressions","reach","saved"]'} Status: 400 Response: { "error": { "message": "Invalid parameter", "type": "OAuthException", "code": 100, "error_data": { "blame_field_specs": [ [ "" ] ] }, "error_subcode": 2108006, "is_transient": false, "error_user_title": "Media posted before business account conversion", "error_user_msg": "The media was posted before the most recent time that the user's account was converted to a business account from a personal account.", "fbtrace_id": "AsEEDdZNMvyTQD1UOkJXovN" } }) 2022-11-03 13:24:52 source > Insights error for business_account_id 17841401993121167: Media posted before business account conversion 2022-11-03 13:24:52 source > Read 3003 records from media_insights stream 2022-11-03 13:24:52 source > Finished syncing media_insights 2022-11-03 13:24:52 source > SourceInstagram runtimes: Syncing stream media 0:04:03.819768 Syncing stream media_insights 0:45:45.543529 2022-11-03 13:24:52 source > Syncing stream: stories 2022-11-03 13:24:56 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:24:56 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:24:56 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:24:56 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:24:56 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:24:56 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:24:56 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:24:56 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:24:56 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:24:56 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:24:56 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:24:56 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:24:56 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:24:56 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:24:56 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:24:56 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:24:56 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:24:56 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:24:56 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:24:56 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:24:56 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:24:56 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:24:56 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:24:56 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:24:56 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:24:56 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:24:56 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:24:56 source > Read 9 records from stories stream 2022-11-03 13:24:56 source > Finished syncing stories 2022-11-03 13:24:56 source > SourceInstagram runtimes: Syncing stream media 0:04:03.819768 Syncing stream media_insights 0:45:45.543529 Syncing stream stories 0:00:04.330480 2022-11-03 13:24:56 source > Syncing stream: story_insights 2022-11-03 13:25:03 source > Read 9 records from story_insights stream 2022-11-03 13:25:03 source > Finished syncing story_insights 2022-11-03 13:25:03 source > SourceInstagram runtimes: Syncing stream media 0:04:03.819768 Syncing stream media_insights 0:45:45.543529 Syncing stream stories 0:00:04.330480 Syncing stream story_insights 0:00:06.725024 2022-11-03 13:25:03 source > Syncing stream: user_insights 2022-11-03 13:25:03 source > Reading insights between 2022-11-03 and 2022-11-04 2022-11-03 13:25:05 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:25:05 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:25:05 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:25:05 source > Reading insights between 2022-11-03 and 2022-11-04 2022-11-03 13:25:06 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:25:06 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:25:06 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:25:06 source > Reading insights between 2022-11-03 and 2022-11-04 2022-11-03 13:25:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:25:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:25:08 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:25:08 source > Reading insights between 2022-11-03 and 2022-11-04 2022-11-03 13:25:12 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:25:12 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:25:12 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:25:12 source > Reading insights between 2022-11-03 and 2022-11-04 2022-11-03 13:25:14 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:25:14 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:25:14 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:25:14 source > Reading insights between 2022-11-03 and 2022-11-04 2022-11-03 13:25:15 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:25:15 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:25:15 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:25:15 source > Reading insights between 2022-11-03 and 2022-11-04 2022-11-03 13:25:17 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:25:17 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:25:17 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:25:17 source > Reading insights between 2022-11-03 and 2022-11-04 2022-11-03 13:25:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):464 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@5a79d342[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@54be367d[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@5081b832[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@15833c46[name=user_insights,namespace=,additionalProperties={}],streamState={"17841403860219174":{"date":"2022-11-03T07:00:00+00:00"},"17841401993121167":{"date":"2022-11-03T07:00:00+00:00"},"17841400657993479":{"date":"2022-11-03T07:00:00+00:00"},"17841400844997659":{"date":"2022-11-03T07:00:00+00:00"},"17841440493306537":{"date":"2022-11-03T07:00:00+00:00"},"17841406448385387":{"date":"2022-11-03T07:00:00+00:00"},"17841417388884180":{"date":"2022-11-03T07:00:00+00:00"},"17841452674376878":{"date":"2022-11-03T07:00:00+00:00"},"17841452328191037":{"date":"2022-11-03T07:00:00+00:00"},"17841421145487667":{"date":"2022-11-03T07:00:00+00:00"}},additionalProperties={}],global=,data={"user_insights":{"17841403860219174":{"date":"2022-11-03T07:00:00+00:00"},"17841401993121167":{"date":"2022-11-03T07:00:00+00:00"},"17841400657993479":{"date":"2022-11-03T07:00:00+00:00"},"17841400844997659":{"date":"2022-11-03T07:00:00+00:00"},"17841440493306537":{"date":"2022-11-03T07:00:00+00:00"},"17841406448385387":{"date":"2022-11-03T07:00:00+00:00"},"17841417388884180":{"date":"2022-11-03T07:00:00+00:00"},"17841452674376878":{"date":"2022-11-03T07:00:00+00:00"},"17841452328191037":{"date":"2022-11-03T07:00:00+00:00"},"17841421145487667":{"date":"2022-11-03T07:00:00+00:00"}}},additionalProperties={}],trace=,additionalProperties={}] 2022-11-03 13:25:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):464 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@1741e77[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@24dccdfa[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@79c1b17b[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@75acc309[name=user_insights,namespace=,additionalProperties={}],streamState={"17841403860219174":{"date":"2022-11-03T07:00:00+00:00"},"17841401993121167":{"date":"2022-11-03T07:00:00+00:00"},"17841400657993479":{"date":"2022-11-03T07:00:00+00:00"},"17841400844997659":{"date":"2022-11-03T07:00:00+00:00"},"17841440493306537":{"date":"2022-11-03T07:00:00+00:00"},"17841406448385387":{"date":"2022-11-03T07:00:00+00:00"},"17841417388884180":{"date":"2022-11-03T07:00:00+00:00"},"17841452674376878":{"date":"2022-11-03T07:00:00+00:00"},"17841452328191037":{"date":"2022-11-03T07:00:00+00:00"},"17841421145487667":{"date":"2022-11-03T07:00:00+00:00"}},additionalProperties={}],global=,data={"user_insights":{"17841403860219174":{"date":"2022-11-03T07:00:00+00:00"},"17841401993121167":{"date":"2022-11-03T07:00:00+00:00"},"17841400657993479":{"date":"2022-11-03T07:00:00+00:00"},"17841400844997659":{"date":"2022-11-03T07:00:00+00:00"},"17841440493306537":{"date":"2022-11-03T07:00:00+00:00"},"17841406448385387":{"date":"2022-11-03T07:00:00+00:00"},"17841417388884180":{"date":"2022-11-03T07:00:00+00:00"},"17841452674376878":{"date":"2022-11-03T07:00:00+00:00"},"17841452328191037":{"date":"2022-11-03T07:00:00+00:00"},"17841421145487667":{"date":"2022-11-03T07:00:00+00:00"}}},additionalProperties={}],trace=,additionalProperties={}] 2022-11-03 13:25:17 WARN i.a.w.i.AirbyteMessageTracker(handleDestinationEmittedState):196 - The message tracker encountered an issue that prevents committed record counts from being reliably computed. 2022-11-03 13:25:17 WARN i.a.w.i.AirbyteMessageTracker(handleDestinationEmittedState):197 - This only impacts metadata and does not indicate a problem with actual sync data. 2022-11-03 13:25:17 WARN i.a.w.i.AirbyteMessageTracker(handleDestinationEmittedState):198 - State hash 448728110 was already committed, likely indicating a state hash collision io.airbyte.workers.internal.StateDeltaTracker$StateDeltaTrackerException: State hash 448728110 was already committed, likely indicating a state hash collision at io.airbyte.workers.internal.StateDeltaTracker.commitStateHash(StateDeltaTracker.java:114) ~[io.airbyte-airbyte-commons-worker-0.40.16.jar:?] at io.airbyte.workers.internal.AirbyteMessageTracker.handleDestinationEmittedState(AirbyteMessageTracker.java:193) ~[io.airbyte-airbyte-commons-worker-0.40.16.jar:?] at io.airbyte.workers.internal.AirbyteMessageTracker.acceptFromDestination(AirbyteMessageTracker.java:119) ~[io.airbyte-airbyte-commons-worker-0.40.16.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.lambda$getDestinationOutputRunnable$7(DefaultReplicationWorker.java:465) ~[io.airbyte-airbyte-commons-worker-0.40.16.jar:?] at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ~[?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?] at java.lang.Thread.run(Thread.java:1589) ~[?:?] 2022-11-03 13:25:21 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:25:21 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:25:21 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:25:21 source > Reading insights between 2022-11-03 and 2022-11-04 2022-11-03 13:25:23 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:25:23 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:25:23 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:25:23 source > Reading insights between 2022-11-03 and 2022-11-04 2022-11-03 13:25:24 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:25:24 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:25:24 source > /usr/local/lib/python3.9/site-packages/facebook_business/utils/api_utils.py:30: UserWarning: value of period might not be compatible. Expect list; got 2022-11-03 13:25:24 source > warnings.warn(message) 2022-11-03 13:25:24 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:25:24 source > Read 10 records from user_insights stream 2022-11-03 13:25:24 source > Finished syncing user_insights 2022-11-03 13:25:24 source > SourceInstagram runtimes: Syncing stream media 0:04:03.819768 Syncing stream media_insights 0:45:45.543529 Syncing stream stories 0:00:04.330480 Syncing stream story_insights 0:00:06.725024 Syncing stream user_insights 0:00:21.069817 2022-11-03 13:25:24 source > Syncing stream: user_lifetime_insights 2022-11-03 13:25:24 source > Encountered an exception while reading stream user_lifetime_insights Traceback (most recent call last): File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 113, in read yield from self._read_stream( File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 182, in _read_stream for record in record_iterator: File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 285, in _read_full_refresh for record in records: File "/airbyte/integration_code/source_instagram/streams.py", line 124, in read_records "date": insight["values"][0]["end_time"], KeyError: 'end_time' 2022-11-03 13:25:24 source > Finished syncing user_lifetime_insights 2022-11-03 13:25:24 source > SourceInstagram runtimes: Syncing stream media 0:04:03.819768 Syncing stream media_insights 0:45:45.543529 Syncing stream stories 0:00:04.330480 Syncing stream story_insights 0:00:06.725024 Syncing stream user_insights 0:00:21.069817 Syncing stream user_lifetime_insights 0:00:00.222682 2022-11-03 13:25:24 source > 'end_time' Traceback (most recent call last): File "/airbyte/integration_code/main.py", line 13, in launch(source, sys.argv[1:]) File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/entrypoint.py", line 123, in launch for message in source_entrypoint.run(parsed_args): File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/entrypoint.py", line 114, in run for message in generator: File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 127, in read raise e File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 113, in read yield from self._read_stream( File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 182, in _read_stream for record in record_iterator: File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 285, in _read_full_refresh for record in records: File "/airbyte/integration_code/source_instagram/streams.py", line 124, in read_records "date": insight["values"][0]["end_time"], KeyError: 'end_time' 2022-11-03 13:25:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):381 - Total records read: 6529 (4 MB) 2022-11-03 13:25:25 WARN i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$5):384 - Schema validation errors found for stream stories. Error messages: [$.timestamp is of an incorrect type. Expected it to be date-time] 2022-11-03 13:25:25 WARN i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$5):384 - Schema validation errors found for stream media. Error messages: [$.timestamp is of an incorrect type. Expected it to be date-time, $.children[1].timestamp is of an incorrect type. Expected it to be date-time, $.children[2].timestamp is of an incorrect type. Expected it to be date-time, $.children[0].timestamp is of an incorrect type. Expected it to be date-time] 2022-11-03 13:25:25 WARN i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$5):384 - Schema validation errors found for stream user_insights. Error messages: [$.date is of an incorrect type. Expected it to be date-time] 2022-11-03 13:25:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):464 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@548afc6d[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@167b581b[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@62c579c6[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@71e25a1c[name=user_insights,namespace=,additionalProperties={}],streamState={"17841403860219174":{"date":"2022-11-03T07:00:00+00:00"},"17841401993121167":{"date":"2022-11-03T07:00:00+00:00"},"17841400657993479":{"date":"2022-11-03T07:00:00+00:00"},"17841400844997659":{"date":"2022-11-03T07:00:00+00:00"},"17841440493306537":{"date":"2022-11-03T07:00:00+00:00"},"17841406448385387":{"date":"2022-11-03T07:00:00+00:00"},"17841417388884180":{"date":"2022-11-03T07:00:00+00:00"},"17841452674376878":{"date":"2022-11-03T07:00:00+00:00"},"17841452328191037":{"date":"2022-11-03T07:00:00+00:00"},"17841421145487667":{"date":"2022-11-03T07:00:00+00:00"}},additionalProperties={}],global=,data={"user_insights":{"17841403860219174":{"date":"2022-11-03T07:00:00+00:00"},"17841401993121167":{"date":"2022-11-03T07:00:00+00:00"},"17841400657993479":{"date":"2022-11-03T07:00:00+00:00"},"17841400844997659":{"date":"2022-11-03T07:00:00+00:00"},"17841440493306537":{"date":"2022-11-03T07:00:00+00:00"},"17841406448385387":{"date":"2022-11-03T07:00:00+00:00"},"17841417388884180":{"date":"2022-11-03T07:00:00+00:00"},"17841452674376878":{"date":"2022-11-03T07:00:00+00:00"},"17841452328191037":{"date":"2022-11-03T07:00:00+00:00"},"17841421145487667":{"date":"2022-11-03T07:00:00+00:00"}}},additionalProperties={}],trace=,additionalProperties={}] 2022-11-03 13:25:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):464 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@7288a9d9[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@3eff9c13[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@773dc943[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@146c4f02[name=user_insights,namespace=,additionalProperties={}],streamState={"17841403860219174":{"date":"2022-11-03T07:00:00+00:00"},"17841401993121167":{"date":"2022-11-03T07:00:00+00:00"},"17841400657993479":{"date":"2022-11-03T07:00:00+00:00"},"17841400844997659":{"date":"2022-11-03T07:00:00+00:00"},"17841440493306537":{"date":"2022-11-03T07:00:00+00:00"},"17841406448385387":{"date":"2022-11-03T07:00:00+00:00"},"17841417388884180":{"date":"2022-11-03T07:00:00+00:00"},"17841452674376878":{"date":"2022-11-03T07:00:00+00:00"},"17841452328191037":{"date":"2022-11-03T07:00:00+00:00"},"17841421145487667":{"date":"2022-11-03T07:00:00+00:00"}},additionalProperties={}],global=,data={"user_insights":{"17841403860219174":{"date":"2022-11-03T07:00:00+00:00"},"17841401993121167":{"date":"2022-11-03T07:00:00+00:00"},"17841400657993479":{"date":"2022-11-03T07:00:00+00:00"},"17841400844997659":{"date":"2022-11-03T07:00:00+00:00"},"17841440493306537":{"date":"2022-11-03T07:00:00+00:00"},"17841406448385387":{"date":"2022-11-03T07:00:00+00:00"},"17841417388884180":{"date":"2022-11-03T07:00:00+00:00"},"17841452674376878":{"date":"2022-11-03T07:00:00+00:00"},"17841452328191037":{"date":"2022-11-03T07:00:00+00:00"},"17841421145487667":{"date":"2022-11-03T07:00:00+00:00"}}},additionalProperties={}],trace=,additionalProperties={}] 2022-11-03 13:25:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):464 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@239dea37[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@61c0f553[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@782e5ff9[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@e4c0ba1[name=user_insights,namespace=,additionalProperties={}],streamState={"17841403860219174":{"date":"2022-11-03T07:00:00+00:00"},"17841401993121167":{"date":"2022-11-03T07:00:00+00:00"},"17841400657993479":{"date":"2022-11-03T07:00:00+00:00"},"17841400844997659":{"date":"2022-11-03T07:00:00+00:00"},"17841440493306537":{"date":"2022-11-03T07:00:00+00:00"},"17841406448385387":{"date":"2022-11-03T07:00:00+00:00"},"17841417388884180":{"date":"2022-11-03T07:00:00+00:00"},"17841452674376878":{"date":"2022-11-03T07:00:00+00:00"},"17841452328191037":{"date":"2022-11-03T07:00:00+00:00"},"17841421145487667":{"date":"2022-11-03T07:00:00+00:00"}},additionalProperties={}],global=,data={"user_insights":{"17841403860219174":{"date":"2022-11-03T07:00:00+00:00"},"17841401993121167":{"date":"2022-11-03T07:00:00+00:00"},"17841400657993479":{"date":"2022-11-03T07:00:00+00:00"},"17841400844997659":{"date":"2022-11-03T07:00:00+00:00"},"17841440493306537":{"date":"2022-11-03T07:00:00+00:00"},"17841406448385387":{"date":"2022-11-03T07:00:00+00:00"},"17841417388884180":{"date":"2022-11-03T07:00:00+00:00"},"17841452674376878":{"date":"2022-11-03T07:00:00+00:00"},"17841452328191037":{"date":"2022-11-03T07:00:00+00:00"},"17841421145487667":{"date":"2022-11-03T07:00:00+00:00"}}},additionalProperties={}],trace=,additionalProperties={}] 2022-11-03 13:25:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):464 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@424c840d[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@24408b7a[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@2e1bc99c[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@40e4cefd[name=user_insights,namespace=,additionalProperties={}],streamState={"17841403860219174":{"date":"2022-11-03T07:00:00+00:00"},"17841401993121167":{"date":"2022-11-03T07:00:00+00:00"},"17841400657993479":{"date":"2022-11-03T07:00:00+00:00"},"17841400844997659":{"date":"2022-11-03T07:00:00+00:00"},"17841440493306537":{"date":"2022-11-03T07:00:00+00:00"},"17841406448385387":{"date":"2022-11-03T07:00:00+00:00"},"17841417388884180":{"date":"2022-11-03T07:00:00+00:00"},"17841452674376878":{"date":"2022-11-03T07:00:00+00:00"},"17841452328191037":{"date":"2022-11-03T07:00:00+00:00"},"17841421145487667":{"date":"2022-11-03T07:00:00+00:00"}},additionalProperties={}],global=,data={"user_insights":{"17841403860219174":{"date":"2022-11-03T07:00:00+00:00"},"17841401993121167":{"date":"2022-11-03T07:00:00+00:00"},"17841400657993479":{"date":"2022-11-03T07:00:00+00:00"},"17841400844997659":{"date":"2022-11-03T07:00:00+00:00"},"17841440493306537":{"date":"2022-11-03T07:00:00+00:00"},"17841406448385387":{"date":"2022-11-03T07:00:00+00:00"},"17841417388884180":{"date":"2022-11-03T07:00:00+00:00"},"17841452674376878":{"date":"2022-11-03T07:00:00+00:00"},"17841452328191037":{"date":"2022-11-03T07:00:00+00:00"},"17841421145487667":{"date":"2022-11-03T07:00:00+00:00"}}},additionalProperties={}],trace=,additionalProperties={}] 2022-11-03 13:25:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):464 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@66ae4600[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@46950af4[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@36b27c93[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@5047cf9e[name=user_insights,namespace=,additionalProperties={}],streamState={"17841403860219174":{"date":"2022-11-03T07:00:00+00:00"},"17841401993121167":{"date":"2022-11-03T07:00:00+00:00"},"17841400657993479":{"date":"2022-11-03T07:00:00+00:00"},"17841400844997659":{"date":"2022-11-03T07:00:00+00:00"},"17841440493306537":{"date":"2022-11-03T07:00:00+00:00"},"17841406448385387":{"date":"2022-11-03T07:00:00+00:00"},"17841417388884180":{"date":"2022-11-03T07:00:00+00:00"},"17841452674376878":{"date":"2022-11-03T07:00:00+00:00"},"17841452328191037":{"date":"2022-11-03T07:00:00+00:00"},"17841421145487667":{"date":"2022-11-03T07:00:00+00:00"}},additionalProperties={}],global=,data={"user_insights":{"17841403860219174":{"date":"2022-11-03T07:00:00+00:00"},"17841401993121167":{"date":"2022-11-03T07:00:00+00:00"},"17841400657993479":{"date":"2022-11-03T07:00:00+00:00"},"17841400844997659":{"date":"2022-11-03T07:00:00+00:00"},"17841440493306537":{"date":"2022-11-03T07:00:00+00:00"},"17841406448385387":{"date":"2022-11-03T07:00:00+00:00"},"17841417388884180":{"date":"2022-11-03T07:00:00+00:00"},"17841452674376878":{"date":"2022-11-03T07:00:00+00:00"},"17841452328191037":{"date":"2022-11-03T07:00:00+00:00"},"17841421145487667":{"date":"2022-11-03T07:00:00+00:00"}}},additionalProperties={}],trace=,additionalProperties={}] 2022-11-03 13:25:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):464 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@44cd1dd0[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@2ae17d17[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@f12da3c[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@6147df7f[name=user_insights,namespace=,additionalProperties={}],streamState={"17841403860219174":{"date":"2022-11-03T07:00:00+00:00"},"17841401993121167":{"date":"2022-11-03T07:00:00+00:00"},"17841400657993479":{"date":"2022-11-03T07:00:00+00:00"},"17841400844997659":{"date":"2022-11-03T07:00:00+00:00"},"17841440493306537":{"date":"2022-11-03T07:00:00+00:00"},"17841406448385387":{"date":"2022-11-03T07:00:00+00:00"},"17841417388884180":{"date":"2022-11-03T07:00:00+00:00"},"17841452674376878":{"date":"2022-11-03T07:00:00+00:00"},"17841452328191037":{"date":"2022-11-03T07:00:00+00:00"},"17841421145487667":{"date":"2022-11-03T07:00:00+00:00"}},additionalProperties={}],global=,data={"user_insights":{"17841403860219174":{"date":"2022-11-03T07:00:00+00:00"},"17841401993121167":{"date":"2022-11-03T07:00:00+00:00"},"17841400657993479":{"date":"2022-11-03T07:00:00+00:00"},"17841400844997659":{"date":"2022-11-03T07:00:00+00:00"},"17841440493306537":{"date":"2022-11-03T07:00:00+00:00"},"17841406448385387":{"date":"2022-11-03T07:00:00+00:00"},"17841417388884180":{"date":"2022-11-03T07:00:00+00:00"},"17841452674376878":{"date":"2022-11-03T07:00:00+00:00"},"17841452328191037":{"date":"2022-11-03T07:00:00+00:00"},"17841421145487667":{"date":"2022-11-03T07:00:00+00:00"}}},additionalProperties={}],trace=,additionalProperties={}] 2022-11-03 13:25:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):464 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@4d486d1a[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@6ce0a861[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@75ba4cfb[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@2a59d914[name=user_insights,namespace=,additionalProperties={}],streamState={"17841403860219174":{"date":"2022-11-03T07:00:00+00:00"},"17841401993121167":{"date":"2022-11-03T07:00:00+00:00"},"17841400657993479":{"date":"2022-11-03T07:00:00+00:00"},"17841400844997659":{"date":"2022-11-03T07:00:00+00:00"},"17841440493306537":{"date":"2022-11-03T07:00:00+00:00"},"17841406448385387":{"date":"2022-11-03T07:00:00+00:00"},"17841417388884180":{"date":"2022-11-03T07:00:00+00:00"},"17841452674376878":{"date":"2022-11-03T07:00:00+00:00"},"17841452328191037":{"date":"2022-11-03T07:00:00+00:00"},"17841421145487667":{"date":"2022-11-03T07:00:00+00:00"}},additionalProperties={}],global=,data={"user_insights":{"17841403860219174":{"date":"2022-11-03T07:00:00+00:00"},"17841401993121167":{"date":"2022-11-03T07:00:00+00:00"},"17841400657993479":{"date":"2022-11-03T07:00:00+00:00"},"17841400844997659":{"date":"2022-11-03T07:00:00+00:00"},"17841440493306537":{"date":"2022-11-03T07:00:00+00:00"},"17841406448385387":{"date":"2022-11-03T07:00:00+00:00"},"17841417388884180":{"date":"2022-11-03T07:00:00+00:00"},"17841452674376878":{"date":"2022-11-03T07:00:00+00:00"},"17841452328191037":{"date":"2022-11-03T07:00:00+00:00"},"17841421145487667":{"date":"2022-11-03T07:00:00+00:00"}}},additionalProperties={}],trace=,additionalProperties={}] 2022-11-03 13:25:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):464 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@247741f8[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@4d3d46b7[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@6a47167f[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@e32f35a[name=user_insights,namespace=,additionalProperties={}],streamState={"17841403860219174":{"date":"2022-11-03T07:00:00+00:00"},"17841401993121167":{"date":"2022-11-03T07:00:00+00:00"},"17841400657993479":{"date":"2022-11-03T07:00:00+00:00"},"17841400844997659":{"date":"2022-11-03T07:00:00+00:00"},"17841440493306537":{"date":"2022-11-03T07:00:00+00:00"},"17841406448385387":{"date":"2022-11-03T07:00:00+00:00"},"17841417388884180":{"date":"2022-11-03T07:00:00+00:00"},"17841452674376878":{"date":"2022-11-03T07:00:00+00:00"},"17841452328191037":{"date":"2022-11-03T07:00:00+00:00"},"17841421145487667":{"date":"2022-11-03T07:00:00+00:00"}},additionalProperties={}],global=,data={"user_insights":{"17841403860219174":{"date":"2022-11-03T07:00:00+00:00"},"17841401993121167":{"date":"2022-11-03T07:00:00+00:00"},"17841400657993479":{"date":"2022-11-03T07:00:00+00:00"},"17841400844997659":{"date":"2022-11-03T07:00:00+00:00"},"17841440493306537":{"date":"2022-11-03T07:00:00+00:00"},"17841406448385387":{"date":"2022-11-03T07:00:00+00:00"},"17841417388884180":{"date":"2022-11-03T07:00:00+00:00"},"17841452674376878":{"date":"2022-11-03T07:00:00+00:00"},"17841452328191037":{"date":"2022-11-03T07:00:00+00:00"},"17841421145487667":{"date":"2022-11-03T07:00:00+00:00"}}},additionalProperties={}],trace=,additionalProperties={}] 2022-11-03 13:25:25 destination > Airbyte message consumer: succeeded. 2022-11-03 13:25:25 destination > Started closing all connections 2022-11-03 13:25:25 destination > Closing connector: AbstractBigQueryUploader{table=_airbyte_raw_instagram_story_insights, tmpTable=_airbyte_tmp_nvf_instagram_story_insights, syncMode=WRITE_TRUNCATE, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-11-03 13:25:25 destination > Waiting for job finish Job{job=JobId{project=spg-misc-data, job=5dbb0657-5285-438d-84db-d812d0f4dac2, location=europe-north1}, status=JobStatus{state=RUNNING, error=null, executionErrors=null}, statistics=LoadStatistics{creationTime=1667481925473, endTime=null, startTime=1667481925636, numChildJobs=null, parentJobId=null, scriptStatistics=null, reservationUsage=null, inputBytes=null, inputFiles=null, outputBytes=null, outputRows=null, badRecords=null}, userEmail=spg-misc-service@spg-misc-data.iam.gserviceaccount.com, etag=bwPOIihw2ALcJoiw21cQVw==, generatedId=spg-misc-data:europe-north1.5dbb0657-5285-438d-84db-d812d0f4dac2, selfLink=https://www.googleapis.com/bigquery/v2/projects/spg-misc-data/jobs/5dbb0657-5285-438d-84db-d812d0f4dac2?location=europe-north1, configuration=LoadJobConfiguration{type=LOAD, destinationTable=GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=misc, projectId=spg-misc-data, tableId=_airbyte_tmp_nvf_instagram_story_insights}}, decimalTargetTypes=null, destinationEncryptionConfiguration=null, createDisposition=CREATE_IF_NEEDED, writeDisposition=null, formatOptions=FormatOptions{format=NEWLINE_DELIMITED_JSON}, nullMarker=null, maxBadRecords=null, schema=Schema{fields=[Field{name=_airbyte_ab_id, type=STRING, mode=null, description=null, policyTags=null}, Field{name=_airbyte_emitted_at, type=TIMESTAMP, mode=null, description=null, policyTags=null}, Field{name=_airbyte_data, type=STRING, mode=null, description=null, policyTags=null}]}, ignoreUnknownValue=null, sourceUris=null, schemaUpdateOptions=null, autodetect=null, timePartitioning=null, clustering=null, useAvroLogicalTypes=null, labels=null, jobTimeoutMs=null, rangePartitioning=null, hivePartitioningOptions=null}}. Status: JobStatus{state=RUNNING, error=null, executionErrors=null} 2022-11-03 13:25:27 destination > Job finish Job{job=JobId{project=spg-misc-data, job=5dbb0657-5285-438d-84db-d812d0f4dac2, location=europe-north1}, status=JobStatus{state=RUNNING, error=null, executionErrors=null}, statistics=LoadStatistics{creationTime=1667481925473, endTime=null, startTime=1667481925636, numChildJobs=null, parentJobId=null, scriptStatistics=null, reservationUsage=null, inputBytes=null, inputFiles=null, outputBytes=null, outputRows=null, badRecords=null}, userEmail=spg-misc-service@spg-misc-data.iam.gserviceaccount.com, etag=bwPOIihw2ALcJoiw21cQVw==, generatedId=spg-misc-data:europe-north1.5dbb0657-5285-438d-84db-d812d0f4dac2, selfLink=https://www.googleapis.com/bigquery/v2/projects/spg-misc-data/jobs/5dbb0657-5285-438d-84db-d812d0f4dac2?location=europe-north1, configuration=LoadJobConfiguration{type=LOAD, destinationTable=GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=misc, projectId=spg-misc-data, tableId=_airbyte_tmp_nvf_instagram_story_insights}}, decimalTargetTypes=null, destinationEncryptionConfiguration=null, createDisposition=CREATE_IF_NEEDED, writeDisposition=null, formatOptions=FormatOptions{format=NEWLINE_DELIMITED_JSON}, nullMarker=null, maxBadRecords=null, schema=Schema{fields=[Field{name=_airbyte_ab_id, type=STRING, mode=null, description=null, policyTags=null}, Field{name=_airbyte_emitted_at, type=TIMESTAMP, mode=null, description=null, policyTags=null}, Field{name=_airbyte_data, type=STRING, mode=null, description=null, policyTags=null}]}, ignoreUnknownValue=null, sourceUris=null, schemaUpdateOptions=null, autodetect=null, timePartitioning=null, clustering=null, useAvroLogicalTypes=null, labels=null, jobTimeoutMs=null, rangePartitioning=null, hivePartitioningOptions=null}} with status JobStatus{state=RUNNING, error=null, executionErrors=null} 2022-11-03 13:25:27 destination > Uploading data from the tmp table _airbyte_tmp_nvf_instagram_story_insights to the source table _airbyte_raw_instagram_story_insights. 2022-11-03 13:25:27 destination > Replication finished with no explicit errors. Copying data from tmp tables to permanent 2022-11-03 13:25:29 destination > successfully copied table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=misc, tableId=_airbyte_tmp_nvf_instagram_story_insights}} to table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=misc, tableId=_airbyte_raw_instagram_story_insights}} 2022-11-03 13:25:29 destination > Data is successfully loaded to the source table _airbyte_raw_instagram_story_insights! 2022-11-03 13:25:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):464 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@10d41be5[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@37fbefb6[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@655df3d8[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@7cec740a[name=user_insights,namespace=,additionalProperties={}],streamState={"17841403860219174":{"date":"2022-11-03T07:00:00+00:00"},"17841401993121167":{"date":"2022-11-03T07:00:00+00:00"},"17841400657993479":{"date":"2022-11-03T07:00:00+00:00"},"17841400844997659":{"date":"2022-11-03T07:00:00+00:00"},"17841440493306537":{"date":"2022-11-03T07:00:00+00:00"},"17841406448385387":{"date":"2022-11-03T07:00:00+00:00"},"17841417388884180":{"date":"2022-11-03T07:00:00+00:00"},"17841452674376878":{"date":"2022-11-03T07:00:00+00:00"},"17841452328191037":{"date":"2022-11-03T07:00:00+00:00"},"17841421145487667":{"date":"2022-11-03T07:00:00+00:00"}},additionalProperties={}],global=,data={"user_insights":{"17841403860219174":{"date":"2022-11-03T07:00:00+00:00"},"17841401993121167":{"date":"2022-11-03T07:00:00+00:00"},"17841400657993479":{"date":"2022-11-03T07:00:00+00:00"},"17841400844997659":{"date":"2022-11-03T07:00:00+00:00"},"17841440493306537":{"date":"2022-11-03T07:00:00+00:00"},"17841406448385387":{"date":"2022-11-03T07:00:00+00:00"},"17841417388884180":{"date":"2022-11-03T07:00:00+00:00"},"17841452674376878":{"date":"2022-11-03T07:00:00+00:00"},"17841452328191037":{"date":"2022-11-03T07:00:00+00:00"},"17841421145487667":{"date":"2022-11-03T07:00:00+00:00"}}},additionalProperties={}],trace=,additionalProperties={}] 2022-11-03 13:25:29 WARN i.a.w.i.AirbyteMessageTracker(handleDestinationEmittedState):207 - The state message tracker was unable to match the destination state message to a corresponding source state message. 2022-11-03 13:25:29 WARN i.a.w.i.AirbyteMessageTracker(handleDestinationEmittedState):208 - This only impacts metrics and does not indicate a problem with actual sync data. 2022-11-03 13:25:29 WARN i.a.w.i.AirbyteMessageTracker(handleDestinationEmittedState):209 - Destination state message cannot be matched to corresponding Source state message. io.airbyte.workers.internal.StateMetricsTracker$StateMetricsTrackerNoStateMatchException: Destination state message cannot be matched to corresponding Source state message. at io.airbyte.workers.internal.StateMetricsTracker.findStartingTimeStampAndRemoveOlderEntries(StateMetricsTracker.java:147) ~[io.airbyte-airbyte-commons-worker-0.40.16.jar:?] at io.airbyte.workers.internal.StateMetricsTracker.updateStates(StateMetricsTracker.java:80) ~[io.airbyte-airbyte-commons-worker-0.40.16.jar:?] at io.airbyte.workers.internal.AirbyteMessageTracker.handleDestinationEmittedState(AirbyteMessageTracker.java:204) ~[io.airbyte-airbyte-commons-worker-0.40.16.jar:?] at io.airbyte.workers.internal.AirbyteMessageTracker.acceptFromDestination(AirbyteMessageTracker.java:119) ~[io.airbyte-airbyte-commons-worker-0.40.16.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.lambda$getDestinationOutputRunnable$7(DefaultReplicationWorker.java:465) ~[io.airbyte-airbyte-commons-worker-0.40.16.jar:?] at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ~[?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?] at java.lang.Thread.run(Thread.java:1589) ~[?:?] 2022-11-03 13:25:29 destination > Final state message is accepted. 2022-11-03 13:25:29 destination > Removing tmp tables... 2022-11-03 13:25:29 destination > Finishing destination process...completed 2022-11-03 13:25:29 destination > Closed connector: AbstractBigQueryUploader{table=_airbyte_raw_instagram_story_insights, tmpTable=_airbyte_tmp_nvf_instagram_story_insights, syncMode=WRITE_TRUNCATE, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-11-03 13:25:29 destination > Closing connector: AbstractBigQueryUploader{table=_airbyte_raw_instagram_users, tmpTable=_airbyte_tmp_szr_instagram_users, syncMode=WRITE_TRUNCATE, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-11-03 13:25:29 destination > Uploading data from the tmp table _airbyte_tmp_szr_instagram_users to the source table _airbyte_raw_instagram_users. 2022-11-03 13:25:29 destination > Replication finished with no explicit errors. Copying data from tmp tables to permanent 2022-11-03 13:25:31 destination > successfully copied table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=misc, tableId=_airbyte_tmp_szr_instagram_users}} to table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=misc, tableId=_airbyte_raw_instagram_users}} 2022-11-03 13:25:31 destination > Data is successfully loaded to the source table _airbyte_raw_instagram_users! 2022-11-03 13:25:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):464 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@4c574341[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@24398322[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@2e70774e[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@31230aae[name=user_insights,namespace=,additionalProperties={}],streamState={"17841403860219174":{"date":"2022-11-03T07:00:00+00:00"},"17841401993121167":{"date":"2022-11-03T07:00:00+00:00"},"17841400657993479":{"date":"2022-11-03T07:00:00+00:00"},"17841400844997659":{"date":"2022-11-03T07:00:00+00:00"},"17841440493306537":{"date":"2022-11-03T07:00:00+00:00"},"17841406448385387":{"date":"2022-11-03T07:00:00+00:00"},"17841417388884180":{"date":"2022-11-03T07:00:00+00:00"},"17841452674376878":{"date":"2022-11-03T07:00:00+00:00"},"17841452328191037":{"date":"2022-11-03T07:00:00+00:00"},"17841421145487667":{"date":"2022-11-03T07:00:00+00:00"}},additionalProperties={}],global=,data={"user_insights":{"17841403860219174":{"date":"2022-11-03T07:00:00+00:00"},"17841401993121167":{"date":"2022-11-03T07:00:00+00:00"},"17841400657993479":{"date":"2022-11-03T07:00:00+00:00"},"17841400844997659":{"date":"2022-11-03T07:00:00+00:00"},"17841440493306537":{"date":"2022-11-03T07:00:00+00:00"},"17841406448385387":{"date":"2022-11-03T07:00:00+00:00"},"17841417388884180":{"date":"2022-11-03T07:00:00+00:00"},"17841452674376878":{"date":"2022-11-03T07:00:00+00:00"},"17841452328191037":{"date":"2022-11-03T07:00:00+00:00"},"17841421145487667":{"date":"2022-11-03T07:00:00+00:00"}}},additionalProperties={}],trace=,additionalProperties={}] 2022-11-03 13:25:31 destination > Final state message is accepted. 2022-11-03 13:25:31 destination > Removing tmp tables... 2022-11-03 13:25:31 destination > Finishing destination process...completed 2022-11-03 13:25:31 destination > Closed connector: AbstractBigQueryUploader{table=_airbyte_raw_instagram_users, tmpTable=_airbyte_tmp_szr_instagram_users, syncMode=WRITE_TRUNCATE, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-11-03 13:25:31 destination > Closing connector: AbstractBigQueryUploader{table=_airbyte_raw_instagram_stories, tmpTable=_airbyte_tmp_zaf_instagram_stories, syncMode=WRITE_TRUNCATE, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-11-03 13:25:32 destination > Waiting for job finish Job{job=JobId{project=spg-misc-data, job=f32b945c-8187-4579-8ea9-99ff7204e13a, location=europe-north1}, status=JobStatus{state=RUNNING, error=null, executionErrors=null}, statistics=LoadStatistics{creationTime=1667481932272, endTime=null, startTime=1667481932457, numChildJobs=null, parentJobId=null, scriptStatistics=null, reservationUsage=null, inputBytes=null, inputFiles=null, outputBytes=null, outputRows=null, badRecords=null}, userEmail=spg-misc-service@spg-misc-data.iam.gserviceaccount.com, etag=qopUenpKO1cLOXs8fTY3/w==, generatedId=spg-misc-data:europe-north1.f32b945c-8187-4579-8ea9-99ff7204e13a, selfLink=https://www.googleapis.com/bigquery/v2/projects/spg-misc-data/jobs/f32b945c-8187-4579-8ea9-99ff7204e13a?location=europe-north1, configuration=LoadJobConfiguration{type=LOAD, destinationTable=GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=misc, projectId=spg-misc-data, tableId=_airbyte_tmp_zaf_instagram_stories}}, decimalTargetTypes=null, destinationEncryptionConfiguration=null, createDisposition=CREATE_IF_NEEDED, writeDisposition=null, formatOptions=FormatOptions{format=NEWLINE_DELIMITED_JSON}, nullMarker=null, maxBadRecords=null, schema=Schema{fields=[Field{name=_airbyte_ab_id, type=STRING, mode=null, description=null, policyTags=null}, Field{name=_airbyte_emitted_at, type=TIMESTAMP, mode=null, description=null, policyTags=null}, Field{name=_airbyte_data, type=STRING, mode=null, description=null, policyTags=null}]}, ignoreUnknownValue=null, sourceUris=null, schemaUpdateOptions=null, autodetect=null, timePartitioning=null, clustering=null, useAvroLogicalTypes=null, labels=null, jobTimeoutMs=null, rangePartitioning=null, hivePartitioningOptions=null}}. Status: JobStatus{state=RUNNING, error=null, executionErrors=null} 2022-11-03 13:25:35 destination > Job finish Job{job=JobId{project=spg-misc-data, job=f32b945c-8187-4579-8ea9-99ff7204e13a, location=europe-north1}, status=JobStatus{state=RUNNING, error=null, executionErrors=null}, statistics=LoadStatistics{creationTime=1667481932272, endTime=null, startTime=1667481932457, numChildJobs=null, parentJobId=null, scriptStatistics=null, reservationUsage=null, inputBytes=null, inputFiles=null, outputBytes=null, outputRows=null, badRecords=null}, userEmail=spg-misc-service@spg-misc-data.iam.gserviceaccount.com, etag=qopUenpKO1cLOXs8fTY3/w==, generatedId=spg-misc-data:europe-north1.f32b945c-8187-4579-8ea9-99ff7204e13a, selfLink=https://www.googleapis.com/bigquery/v2/projects/spg-misc-data/jobs/f32b945c-8187-4579-8ea9-99ff7204e13a?location=europe-north1, configuration=LoadJobConfiguration{type=LOAD, destinationTable=GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=misc, projectId=spg-misc-data, tableId=_airbyte_tmp_zaf_instagram_stories}}, decimalTargetTypes=null, destinationEncryptionConfiguration=null, createDisposition=CREATE_IF_NEEDED, writeDisposition=null, formatOptions=FormatOptions{format=NEWLINE_DELIMITED_JSON}, nullMarker=null, maxBadRecords=null, schema=Schema{fields=[Field{name=_airbyte_ab_id, type=STRING, mode=null, description=null, policyTags=null}, Field{name=_airbyte_emitted_at, type=TIMESTAMP, mode=null, description=null, policyTags=null}, Field{name=_airbyte_data, type=STRING, mode=null, description=null, policyTags=null}]}, ignoreUnknownValue=null, sourceUris=null, schemaUpdateOptions=null, autodetect=null, timePartitioning=null, clustering=null, useAvroLogicalTypes=null, labels=null, jobTimeoutMs=null, rangePartitioning=null, hivePartitioningOptions=null}} with status JobStatus{state=RUNNING, error=null, executionErrors=null} 2022-11-03 13:25:35 destination > Uploading data from the tmp table _airbyte_tmp_zaf_instagram_stories to the source table _airbyte_raw_instagram_stories. 2022-11-03 13:25:35 destination > Replication finished with no explicit errors. Copying data from tmp tables to permanent 2022-11-03 13:25:38 destination > successfully copied table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=misc, tableId=_airbyte_tmp_zaf_instagram_stories}} to table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=misc, tableId=_airbyte_raw_instagram_stories}} 2022-11-03 13:25:38 destination > Data is successfully loaded to the source table _airbyte_raw_instagram_stories! 2022-11-03 13:25:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):464 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@47181a80[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@2fd0b1d2[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@2377961[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@2be875f3[name=user_insights,namespace=,additionalProperties={}],streamState={"17841403860219174":{"date":"2022-11-03T07:00:00+00:00"},"17841401993121167":{"date":"2022-11-03T07:00:00+00:00"},"17841400657993479":{"date":"2022-11-03T07:00:00+00:00"},"17841400844997659":{"date":"2022-11-03T07:00:00+00:00"},"17841440493306537":{"date":"2022-11-03T07:00:00+00:00"},"17841406448385387":{"date":"2022-11-03T07:00:00+00:00"},"17841417388884180":{"date":"2022-11-03T07:00:00+00:00"},"17841452674376878":{"date":"2022-11-03T07:00:00+00:00"},"17841452328191037":{"date":"2022-11-03T07:00:00+00:00"},"17841421145487667":{"date":"2022-11-03T07:00:00+00:00"}},additionalProperties={}],global=,data={"user_insights":{"17841403860219174":{"date":"2022-11-03T07:00:00+00:00"},"17841401993121167":{"date":"2022-11-03T07:00:00+00:00"},"17841400657993479":{"date":"2022-11-03T07:00:00+00:00"},"17841400844997659":{"date":"2022-11-03T07:00:00+00:00"},"17841440493306537":{"date":"2022-11-03T07:00:00+00:00"},"17841406448385387":{"date":"2022-11-03T07:00:00+00:00"},"17841417388884180":{"date":"2022-11-03T07:00:00+00:00"},"17841452674376878":{"date":"2022-11-03T07:00:00+00:00"},"17841452328191037":{"date":"2022-11-03T07:00:00+00:00"},"17841421145487667":{"date":"2022-11-03T07:00:00+00:00"}}},additionalProperties={}],trace=,additionalProperties={}] 2022-11-03 13:25:38 destination > Final state message is accepted. 2022-11-03 13:25:38 destination > Removing tmp tables... 2022-11-03 13:25:38 destination > Finishing destination process...completed 2022-11-03 13:25:38 destination > Closed connector: AbstractBigQueryUploader{table=_airbyte_raw_instagram_stories, tmpTable=_airbyte_tmp_zaf_instagram_stories, syncMode=WRITE_TRUNCATE, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-11-03 13:25:38 destination > Closing connector: AbstractBigQueryUploader{table=_airbyte_raw_instagram_media, tmpTable=_airbyte_tmp_aik_instagram_media, syncMode=WRITE_TRUNCATE, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-11-03 13:25:39 destination > Waiting for job finish Job{job=JobId{project=spg-misc-data, job=47a78137-31f6-487e-a398-e6347254c8f1, location=europe-north1}, status=JobStatus{state=RUNNING, error=null, executionErrors=null}, statistics=LoadStatistics{creationTime=1667481939192, endTime=null, startTime=1667481939360, numChildJobs=null, parentJobId=null, scriptStatistics=null, reservationUsage=null, inputBytes=null, inputFiles=null, outputBytes=null, outputRows=null, badRecords=null}, userEmail=spg-misc-service@spg-misc-data.iam.gserviceaccount.com, etag=ZsjHr44NeN47Y8cq6qiyQA==, generatedId=spg-misc-data:europe-north1.47a78137-31f6-487e-a398-e6347254c8f1, selfLink=https://www.googleapis.com/bigquery/v2/projects/spg-misc-data/jobs/47a78137-31f6-487e-a398-e6347254c8f1?location=europe-north1, configuration=LoadJobConfiguration{type=LOAD, destinationTable=GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=misc, projectId=spg-misc-data, tableId=_airbyte_tmp_aik_instagram_media}}, decimalTargetTypes=null, destinationEncryptionConfiguration=null, createDisposition=CREATE_IF_NEEDED, writeDisposition=null, formatOptions=FormatOptions{format=NEWLINE_DELIMITED_JSON}, nullMarker=null, maxBadRecords=null, schema=Schema{fields=[Field{name=_airbyte_ab_id, type=STRING, mode=null, description=null, policyTags=null}, Field{name=_airbyte_emitted_at, type=TIMESTAMP, mode=null, description=null, policyTags=null}, Field{name=_airbyte_data, type=STRING, mode=null, description=null, policyTags=null}]}, ignoreUnknownValue=null, sourceUris=null, schemaUpdateOptions=null, autodetect=null, timePartitioning=null, clustering=null, useAvroLogicalTypes=null, labels=null, jobTimeoutMs=null, rangePartitioning=null, hivePartitioningOptions=null}}. Status: JobStatus{state=RUNNING, error=null, executionErrors=null} 2022-11-03 13:25:42 destination > Job finish Job{job=JobId{project=spg-misc-data, job=47a78137-31f6-487e-a398-e6347254c8f1, location=europe-north1}, status=JobStatus{state=RUNNING, error=null, executionErrors=null}, statistics=LoadStatistics{creationTime=1667481939192, endTime=null, startTime=1667481939360, numChildJobs=null, parentJobId=null, scriptStatistics=null, reservationUsage=null, inputBytes=null, inputFiles=null, outputBytes=null, outputRows=null, badRecords=null}, userEmail=spg-misc-service@spg-misc-data.iam.gserviceaccount.com, etag=ZsjHr44NeN47Y8cq6qiyQA==, generatedId=spg-misc-data:europe-north1.47a78137-31f6-487e-a398-e6347254c8f1, selfLink=https://www.googleapis.com/bigquery/v2/projects/spg-misc-data/jobs/47a78137-31f6-487e-a398-e6347254c8f1?location=europe-north1, configuration=LoadJobConfiguration{type=LOAD, destinationTable=GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=misc, projectId=spg-misc-data, tableId=_airbyte_tmp_aik_instagram_media}}, decimalTargetTypes=null, destinationEncryptionConfiguration=null, createDisposition=CREATE_IF_NEEDED, writeDisposition=null, formatOptions=FormatOptions{format=NEWLINE_DELIMITED_JSON}, nullMarker=null, maxBadRecords=null, schema=Schema{fields=[Field{name=_airbyte_ab_id, type=STRING, mode=null, description=null, policyTags=null}, Field{name=_airbyte_emitted_at, type=TIMESTAMP, mode=null, description=null, policyTags=null}, Field{name=_airbyte_data, type=STRING, mode=null, description=null, policyTags=null}]}, ignoreUnknownValue=null, sourceUris=null, schemaUpdateOptions=null, autodetect=null, timePartitioning=null, clustering=null, useAvroLogicalTypes=null, labels=null, jobTimeoutMs=null, rangePartitioning=null, hivePartitioningOptions=null}} with status JobStatus{state=RUNNING, error=null, executionErrors=null} 2022-11-03 13:25:42 destination > Uploading data from the tmp table _airbyte_tmp_aik_instagram_media to the source table _airbyte_raw_instagram_media. 2022-11-03 13:25:42 destination > Replication finished with no explicit errors. Copying data from tmp tables to permanent 2022-11-03 13:25:44 destination > successfully copied table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=misc, tableId=_airbyte_tmp_aik_instagram_media}} to table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=misc, tableId=_airbyte_raw_instagram_media}} 2022-11-03 13:25:44 destination > Data is successfully loaded to the source table _airbyte_raw_instagram_media! 2022-11-03 13:25:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):464 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@2c23b614[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@6d7dc63[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@3f9251a9[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@573dec45[name=user_insights,namespace=,additionalProperties={}],streamState={"17841403860219174":{"date":"2022-11-03T07:00:00+00:00"},"17841401993121167":{"date":"2022-11-03T07:00:00+00:00"},"17841400657993479":{"date":"2022-11-03T07:00:00+00:00"},"17841400844997659":{"date":"2022-11-03T07:00:00+00:00"},"17841440493306537":{"date":"2022-11-03T07:00:00+00:00"},"17841406448385387":{"date":"2022-11-03T07:00:00+00:00"},"17841417388884180":{"date":"2022-11-03T07:00:00+00:00"},"17841452674376878":{"date":"2022-11-03T07:00:00+00:00"},"17841452328191037":{"date":"2022-11-03T07:00:00+00:00"},"17841421145487667":{"date":"2022-11-03T07:00:00+00:00"}},additionalProperties={}],global=,data={"user_insights":{"17841403860219174":{"date":"2022-11-03T07:00:00+00:00"},"17841401993121167":{"date":"2022-11-03T07:00:00+00:00"},"17841400657993479":{"date":"2022-11-03T07:00:00+00:00"},"17841400844997659":{"date":"2022-11-03T07:00:00+00:00"},"17841440493306537":{"date":"2022-11-03T07:00:00+00:00"},"17841406448385387":{"date":"2022-11-03T07:00:00+00:00"},"17841417388884180":{"date":"2022-11-03T07:00:00+00:00"},"17841452674376878":{"date":"2022-11-03T07:00:00+00:00"},"17841452328191037":{"date":"2022-11-03T07:00:00+00:00"},"17841421145487667":{"date":"2022-11-03T07:00:00+00:00"}}},additionalProperties={}],trace=,additionalProperties={}] 2022-11-03 13:25:44 destination > Final state message is accepted. 2022-11-03 13:25:44 destination > Removing tmp tables... 2022-11-03 13:25:44 destination > Finishing destination process...completed 2022-11-03 13:25:44 destination > Closed connector: AbstractBigQueryUploader{table=_airbyte_raw_instagram_media, tmpTable=_airbyte_tmp_aik_instagram_media, syncMode=WRITE_TRUNCATE, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-11-03 13:25:44 destination > Closing connector: AbstractBigQueryUploader{table=_airbyte_raw_instagram_user_lifetime_insights, tmpTable=_airbyte_tmp_nuu_instagram_user_lifetime_insights, syncMode=WRITE_APPEND, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-11-03 13:25:44 destination > Uploading data from the tmp table _airbyte_tmp_nuu_instagram_user_lifetime_insights to the source table _airbyte_raw_instagram_user_lifetime_insights. 2022-11-03 13:25:44 destination > Replication finished with no explicit errors. Copying data from tmp tables to permanent 2022-11-03 13:25:49 destination > successfully copied table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=misc, tableId=_airbyte_tmp_nuu_instagram_user_lifetime_insights}} to table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=misc, tableId=_airbyte_raw_instagram_user_lifetime_insights}} 2022-11-03 13:25:49 destination > Data is successfully loaded to the source table _airbyte_raw_instagram_user_lifetime_insights! 2022-11-03 13:25:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):464 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@661f63a0[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@5e938fc4[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@73a182a6[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@4b461753[name=user_insights,namespace=,additionalProperties={}],streamState={"17841403860219174":{"date":"2022-11-03T07:00:00+00:00"},"17841401993121167":{"date":"2022-11-03T07:00:00+00:00"},"17841400657993479":{"date":"2022-11-03T07:00:00+00:00"},"17841400844997659":{"date":"2022-11-03T07:00:00+00:00"},"17841440493306537":{"date":"2022-11-03T07:00:00+00:00"},"17841406448385387":{"date":"2022-11-03T07:00:00+00:00"},"17841417388884180":{"date":"2022-11-03T07:00:00+00:00"},"17841452674376878":{"date":"2022-11-03T07:00:00+00:00"},"17841452328191037":{"date":"2022-11-03T07:00:00+00:00"},"17841421145487667":{"date":"2022-11-03T07:00:00+00:00"}},additionalProperties={}],global=,data={"user_insights":{"17841403860219174":{"date":"2022-11-03T07:00:00+00:00"},"17841401993121167":{"date":"2022-11-03T07:00:00+00:00"},"17841400657993479":{"date":"2022-11-03T07:00:00+00:00"},"17841400844997659":{"date":"2022-11-03T07:00:00+00:00"},"17841440493306537":{"date":"2022-11-03T07:00:00+00:00"},"17841406448385387":{"date":"2022-11-03T07:00:00+00:00"},"17841417388884180":{"date":"2022-11-03T07:00:00+00:00"},"17841452674376878":{"date":"2022-11-03T07:00:00+00:00"},"17841452328191037":{"date":"2022-11-03T07:00:00+00:00"},"17841421145487667":{"date":"2022-11-03T07:00:00+00:00"}}},additionalProperties={}],trace=,additionalProperties={}] 2022-11-03 13:25:49 destination > Final state message is accepted. 2022-11-03 13:25:49 destination > Removing tmp tables... 2022-11-03 13:25:49 destination > Finishing destination process...completed 2022-11-03 13:25:49 destination > Closed connector: AbstractBigQueryUploader{table=_airbyte_raw_instagram_user_lifetime_insights, tmpTable=_airbyte_tmp_nuu_instagram_user_lifetime_insights, syncMode=WRITE_APPEND, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-11-03 13:25:49 destination > Closing connector: AbstractBigQueryUploader{table=_airbyte_raw_instagram_media_insights, tmpTable=_airbyte_tmp_yse_instagram_media_insights, syncMode=WRITE_TRUNCATE, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-11-03 13:25:49 destination > Waiting for job finish Job{job=JobId{project=spg-misc-data, job=53631e43-5792-4624-be5a-e9e2e301bed8, location=europe-north1}, status=JobStatus{state=RUNNING, error=null, executionErrors=null}, statistics=LoadStatistics{creationTime=1667481949486, endTime=null, startTime=1667481949647, numChildJobs=null, parentJobId=null, scriptStatistics=null, reservationUsage=null, inputBytes=null, inputFiles=null, outputBytes=null, outputRows=null, badRecords=null}, userEmail=spg-misc-service@spg-misc-data.iam.gserviceaccount.com, etag=PPRI9bLAu4ulpFX+g86e/Q==, generatedId=spg-misc-data:europe-north1.53631e43-5792-4624-be5a-e9e2e301bed8, selfLink=https://www.googleapis.com/bigquery/v2/projects/spg-misc-data/jobs/53631e43-5792-4624-be5a-e9e2e301bed8?location=europe-north1, configuration=LoadJobConfiguration{type=LOAD, destinationTable=GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=misc, projectId=spg-misc-data, tableId=_airbyte_tmp_yse_instagram_media_insights}}, decimalTargetTypes=null, destinationEncryptionConfiguration=null, createDisposition=CREATE_IF_NEEDED, writeDisposition=null, formatOptions=FormatOptions{format=NEWLINE_DELIMITED_JSON}, nullMarker=null, maxBadRecords=null, schema=Schema{fields=[Field{name=_airbyte_ab_id, type=STRING, mode=null, description=null, policyTags=null}, Field{name=_airbyte_emitted_at, type=TIMESTAMP, mode=null, description=null, policyTags=null}, Field{name=_airbyte_data, type=STRING, mode=null, description=null, policyTags=null}]}, ignoreUnknownValue=null, sourceUris=null, schemaUpdateOptions=null, autodetect=null, timePartitioning=null, clustering=null, useAvroLogicalTypes=null, labels=null, jobTimeoutMs=null, rangePartitioning=null, hivePartitioningOptions=null}}. Status: JobStatus{state=RUNNING, error=null, executionErrors=null} 2022-11-03 13:25:53 destination > Job finish Job{job=JobId{project=spg-misc-data, job=53631e43-5792-4624-be5a-e9e2e301bed8, location=europe-north1}, status=JobStatus{state=RUNNING, error=null, executionErrors=null}, statistics=LoadStatistics{creationTime=1667481949486, endTime=null, startTime=1667481949647, numChildJobs=null, parentJobId=null, scriptStatistics=null, reservationUsage=null, inputBytes=null, inputFiles=null, outputBytes=null, outputRows=null, badRecords=null}, userEmail=spg-misc-service@spg-misc-data.iam.gserviceaccount.com, etag=PPRI9bLAu4ulpFX+g86e/Q==, generatedId=spg-misc-data:europe-north1.53631e43-5792-4624-be5a-e9e2e301bed8, selfLink=https://www.googleapis.com/bigquery/v2/projects/spg-misc-data/jobs/53631e43-5792-4624-be5a-e9e2e301bed8?location=europe-north1, configuration=LoadJobConfiguration{type=LOAD, destinationTable=GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=misc, projectId=spg-misc-data, tableId=_airbyte_tmp_yse_instagram_media_insights}}, decimalTargetTypes=null, destinationEncryptionConfiguration=null, createDisposition=CREATE_IF_NEEDED, writeDisposition=null, formatOptions=FormatOptions{format=NEWLINE_DELIMITED_JSON}, nullMarker=null, maxBadRecords=null, schema=Schema{fields=[Field{name=_airbyte_ab_id, type=STRING, mode=null, description=null, policyTags=null}, Field{name=_airbyte_emitted_at, type=TIMESTAMP, mode=null, description=null, policyTags=null}, Field{name=_airbyte_data, type=STRING, mode=null, description=null, policyTags=null}]}, ignoreUnknownValue=null, sourceUris=null, schemaUpdateOptions=null, autodetect=null, timePartitioning=null, clustering=null, useAvroLogicalTypes=null, labels=null, jobTimeoutMs=null, rangePartitioning=null, hivePartitioningOptions=null}} with status JobStatus{state=RUNNING, error=null, executionErrors=null} 2022-11-03 13:25:53 destination > Uploading data from the tmp table _airbyte_tmp_yse_instagram_media_insights to the source table _airbyte_raw_instagram_media_insights. 2022-11-03 13:25:53 destination > Replication finished with no explicit errors. Copying data from tmp tables to permanent 2022-11-03 13:25:56 destination > successfully copied table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=misc, tableId=_airbyte_tmp_yse_instagram_media_insights}} to table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=misc, tableId=_airbyte_raw_instagram_media_insights}} 2022-11-03 13:25:56 destination > Data is successfully loaded to the source table _airbyte_raw_instagram_media_insights! 2022-11-03 13:25:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):464 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@56596ff8[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@14763758[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@6bbd33c2[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@10ba4d69[name=user_insights,namespace=,additionalProperties={}],streamState={"17841403860219174":{"date":"2022-11-03T07:00:00+00:00"},"17841401993121167":{"date":"2022-11-03T07:00:00+00:00"},"17841400657993479":{"date":"2022-11-03T07:00:00+00:00"},"17841400844997659":{"date":"2022-11-03T07:00:00+00:00"},"17841440493306537":{"date":"2022-11-03T07:00:00+00:00"},"17841406448385387":{"date":"2022-11-03T07:00:00+00:00"},"17841417388884180":{"date":"2022-11-03T07:00:00+00:00"},"17841452674376878":{"date":"2022-11-03T07:00:00+00:00"},"17841452328191037":{"date":"2022-11-03T07:00:00+00:00"},"17841421145487667":{"date":"2022-11-03T07:00:00+00:00"}},additionalProperties={}],global=,data={"user_insights":{"17841403860219174":{"date":"2022-11-03T07:00:00+00:00"},"17841401993121167":{"date":"2022-11-03T07:00:00+00:00"},"17841400657993479":{"date":"2022-11-03T07:00:00+00:00"},"17841400844997659":{"date":"2022-11-03T07:00:00+00:00"},"17841440493306537":{"date":"2022-11-03T07:00:00+00:00"},"17841406448385387":{"date":"2022-11-03T07:00:00+00:00"},"17841417388884180":{"date":"2022-11-03T07:00:00+00:00"},"17841452674376878":{"date":"2022-11-03T07:00:00+00:00"},"17841452328191037":{"date":"2022-11-03T07:00:00+00:00"},"17841421145487667":{"date":"2022-11-03T07:00:00+00:00"}}},additionalProperties={}],trace=,additionalProperties={}] 2022-11-03 13:25:56 destination > Final state message is accepted. 2022-11-03 13:25:56 destination > Removing tmp tables... 2022-11-03 13:25:56 destination > Finishing destination process...completed 2022-11-03 13:25:56 destination > Closed connector: AbstractBigQueryUploader{table=_airbyte_raw_instagram_media_insights, tmpTable=_airbyte_tmp_yse_instagram_media_insights, syncMode=WRITE_TRUNCATE, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-11-03 13:25:56 destination > Closing connector: AbstractBigQueryUploader{table=_airbyte_raw_instagram_user_insights, tmpTable=_airbyte_tmp_eek_instagram_user_insights, syncMode=WRITE_APPEND, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-11-03 13:25:56 destination > Waiting for job finish Job{job=JobId{project=spg-misc-data, job=d7e72efd-a512-4749-9365-04b7cd0bd4e9, location=europe-north1}, status=JobStatus{state=RUNNING, error=null, executionErrors=null}, statistics=LoadStatistics{creationTime=1667481956626, endTime=null, startTime=1667481956862, numChildJobs=null, parentJobId=null, scriptStatistics=null, reservationUsage=null, inputBytes=null, inputFiles=null, outputBytes=null, outputRows=null, badRecords=null}, userEmail=spg-misc-service@spg-misc-data.iam.gserviceaccount.com, etag=pvgmqq9wLNaxdVT01PY4DQ==, generatedId=spg-misc-data:europe-north1.d7e72efd-a512-4749-9365-04b7cd0bd4e9, selfLink=https://www.googleapis.com/bigquery/v2/projects/spg-misc-data/jobs/d7e72efd-a512-4749-9365-04b7cd0bd4e9?location=europe-north1, configuration=LoadJobConfiguration{type=LOAD, destinationTable=GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=misc, projectId=spg-misc-data, tableId=_airbyte_tmp_eek_instagram_user_insights}}, decimalTargetTypes=null, destinationEncryptionConfiguration=null, createDisposition=CREATE_IF_NEEDED, writeDisposition=null, formatOptions=FormatOptions{format=NEWLINE_DELIMITED_JSON}, nullMarker=null, maxBadRecords=null, schema=Schema{fields=[Field{name=_airbyte_ab_id, type=STRING, mode=null, description=null, policyTags=null}, Field{name=_airbyte_emitted_at, type=TIMESTAMP, mode=null, description=null, policyTags=null}, Field{name=_airbyte_data, type=STRING, mode=null, description=null, policyTags=null}]}, ignoreUnknownValue=null, sourceUris=null, schemaUpdateOptions=null, autodetect=null, timePartitioning=null, clustering=null, useAvroLogicalTypes=null, labels=null, jobTimeoutMs=null, rangePartitioning=null, hivePartitioningOptions=null}}. Status: JobStatus{state=RUNNING, error=null, executionErrors=null} 2022-11-03 13:25:59 destination > Job finish Job{job=JobId{project=spg-misc-data, job=d7e72efd-a512-4749-9365-04b7cd0bd4e9, location=europe-north1}, status=JobStatus{state=RUNNING, error=null, executionErrors=null}, statistics=LoadStatistics{creationTime=1667481956626, endTime=null, startTime=1667481956862, numChildJobs=null, parentJobId=null, scriptStatistics=null, reservationUsage=null, inputBytes=null, inputFiles=null, outputBytes=null, outputRows=null, badRecords=null}, userEmail=spg-misc-service@spg-misc-data.iam.gserviceaccount.com, etag=pvgmqq9wLNaxdVT01PY4DQ==, generatedId=spg-misc-data:europe-north1.d7e72efd-a512-4749-9365-04b7cd0bd4e9, selfLink=https://www.googleapis.com/bigquery/v2/projects/spg-misc-data/jobs/d7e72efd-a512-4749-9365-04b7cd0bd4e9?location=europe-north1, configuration=LoadJobConfiguration{type=LOAD, destinationTable=GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=misc, projectId=spg-misc-data, tableId=_airbyte_tmp_eek_instagram_user_insights}}, decimalTargetTypes=null, destinationEncryptionConfiguration=null, createDisposition=CREATE_IF_NEEDED, writeDisposition=null, formatOptions=FormatOptions{format=NEWLINE_DELIMITED_JSON}, nullMarker=null, maxBadRecords=null, schema=Schema{fields=[Field{name=_airbyte_ab_id, type=STRING, mode=null, description=null, policyTags=null}, Field{name=_airbyte_emitted_at, type=TIMESTAMP, mode=null, description=null, policyTags=null}, Field{name=_airbyte_data, type=STRING, mode=null, description=null, policyTags=null}]}, ignoreUnknownValue=null, sourceUris=null, schemaUpdateOptions=null, autodetect=null, timePartitioning=null, clustering=null, useAvroLogicalTypes=null, labels=null, jobTimeoutMs=null, rangePartitioning=null, hivePartitioningOptions=null}} with status JobStatus{state=RUNNING, error=null, executionErrors=null} 2022-11-03 13:25:59 destination > Uploading data from the tmp table _airbyte_tmp_eek_instagram_user_insights to the source table _airbyte_raw_instagram_user_insights. 2022-11-03 13:25:59 destination > Replication finished with no explicit errors. Copying data from tmp tables to permanent 2022-11-03 13:26:02 destination > successfully copied table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=misc, tableId=_airbyte_tmp_eek_instagram_user_insights}} to table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=misc, tableId=_airbyte_raw_instagram_user_insights}} 2022-11-03 13:26:02 destination > Data is successfully loaded to the source table _airbyte_raw_instagram_user_insights! 2022-11-03 13:26:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):464 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@d81d629[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@28e8fc36[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@2a49f9ca[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@68da38ef[name=user_insights,namespace=,additionalProperties={}],streamState={"17841403860219174":{"date":"2022-11-03T07:00:00+00:00"},"17841401993121167":{"date":"2022-11-03T07:00:00+00:00"},"17841400657993479":{"date":"2022-11-03T07:00:00+00:00"},"17841400844997659":{"date":"2022-11-03T07:00:00+00:00"},"17841440493306537":{"date":"2022-11-03T07:00:00+00:00"},"17841406448385387":{"date":"2022-11-03T07:00:00+00:00"},"17841417388884180":{"date":"2022-11-03T07:00:00+00:00"},"17841452674376878":{"date":"2022-11-03T07:00:00+00:00"},"17841452328191037":{"date":"2022-11-03T07:00:00+00:00"},"17841421145487667":{"date":"2022-11-03T07:00:00+00:00"}},additionalProperties={}],global=,data={"user_insights":{"17841403860219174":{"date":"2022-11-03T07:00:00+00:00"},"17841401993121167":{"date":"2022-11-03T07:00:00+00:00"},"17841400657993479":{"date":"2022-11-03T07:00:00+00:00"},"17841400844997659":{"date":"2022-11-03T07:00:00+00:00"},"17841440493306537":{"date":"2022-11-03T07:00:00+00:00"},"17841406448385387":{"date":"2022-11-03T07:00:00+00:00"},"17841417388884180":{"date":"2022-11-03T07:00:00+00:00"},"17841452674376878":{"date":"2022-11-03T07:00:00+00:00"},"17841452328191037":{"date":"2022-11-03T07:00:00+00:00"},"17841421145487667":{"date":"2022-11-03T07:00:00+00:00"}}},additionalProperties={}],trace=,additionalProperties={}] 2022-11-03 13:26:02 destination > Final state message is accepted. 2022-11-03 13:26:02 destination > Removing tmp tables... 2022-11-03 13:26:02 destination > Finishing destination process...completed 2022-11-03 13:26:02 destination > Closed connector: AbstractBigQueryUploader{table=_airbyte_raw_instagram_user_insights, tmpTable=_airbyte_tmp_eek_instagram_user_insights, syncMode=WRITE_APPEND, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-11-03 13:26:02 destination > Completed integration: io.airbyte.integrations.destination.bigquery.BigQueryDestination 2022-11-03 13:26:02 ERROR i.a.w.g.DefaultReplicationWorker(run):196 - Sync worker failed. java.util.concurrent.ExecutionException: io.airbyte.workers.general.DefaultReplicationWorker$SourceException: 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.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:189) ~[io.airbyte-airbyte-commons-worker-0.40.16.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:71) ~[io.airbyte-airbyte-commons-worker-0.40.16.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$4(TemporalAttemptExecution.java:190) ~[io.airbyte-airbyte-workers-0.40.16.jar:?] at java.lang.Thread.run(Thread.java:1589) ~[?:?] Suppressed: io.airbyte.workers.exception.WorkerException: Source process exit with code 1. This warning is normal if the job was cancelled. at io.airbyte.workers.internal.DefaultAirbyteSource.close(DefaultAirbyteSource.java:135) ~[io.airbyte-airbyte-commons-worker-0.40.16.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:151) ~[io.airbyte-airbyte-commons-worker-0.40.16.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:71) ~[io.airbyte-airbyte-commons-worker-0.40.16.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$4(TemporalAttemptExecution.java:190) ~[io.airbyte-airbyte-workers-0.40.16.jar:?] at java.lang.Thread.run(Thread.java:1589) ~[?:?] Caused by: io.airbyte.workers.general.DefaultReplicationWorker$SourceException: Source process exited with non-zero exit code 1 at io.airbyte.workers.general.DefaultReplicationWorker.lambda$getReplicationRunnable$6(DefaultReplicationWorker.java:395) ~[io.airbyte-airbyte-commons-worker-0.40.16.jar:?] at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ~[?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?] ... 1 more 2022-11-03 13:26:02 WARN i.a.w.g.DefaultReplicationWorker(run):236 - Could not reliably determine committed record counts, committed record stats will be set to null 2022-11-03 13:26:02 INFO i.a.w.g.DefaultReplicationWorker(run):295 - Source output at least one state message 2022-11-03 13:26:02 INFO i.a.w.g.DefaultReplicationWorker(run):301 - State capture: Updated state to: Optional[io.airbyte.config.State@2c2199fc[state=[{"type":"STREAM","stream":{"stream_descriptor":{"name":"user_insights"},"stream_state":{"17841403860219174":{"date":"2022-11-03T07:00:00+00:00"},"17841401993121167":{"date":"2022-11-03T07:00:00+00:00"},"17841400657993479":{"date":"2022-11-03T07:00:00+00:00"},"17841400844997659":{"date":"2022-11-03T07:00:00+00:00"},"17841440493306537":{"date":"2022-11-03T07:00:00+00:00"},"17841406448385387":{"date":"2022-11-03T07:00:00+00:00"},"17841417388884180":{"date":"2022-11-03T07:00:00+00:00"},"17841452674376878":{"date":"2022-11-03T07:00:00+00:00"},"17841452328191037":{"date":"2022-11-03T07:00:00+00:00"},"17841421145487667":{"date":"2022-11-03T07:00:00+00:00"}}}}]]] 2022-11-03 13:26:02 INFO i.a.w.g.DefaultReplicationWorker(run):316 - sync summary: { "status" : "failed", "recordsSynced" : 6518, "bytesSynced" : 4387145, "startTime" : 1667478900287, "endTime" : 1667481962816, "totalStats" : { "recordsEmitted" : 6518, "bytesEmitted" : 4387145, "sourceStateMessagesEmitted" : 10, "destinationStateMessagesEmitted" : 17, "meanSecondsBeforeSourceStateMessageEmitted" : 299, "maxSecondsBeforeSourceStateMessageEmitted" : 2996, "replicationStartTime" : 1667478900287, "replicationEndTime" : 1667481962815, "sourceReadStartTime" : 1667478900374, "sourceReadEndTime" : 1667481925086, "destinationWriteStartTime" : 1667478900493, "destinationWriteEndTime" : 1667481962815 }, "streamStats" : [ { "streamName" : "instagram_stories", "stats" : { "recordsEmitted" : 9, "bytesEmitted" : 7126 } }, { "streamName" : "instagram_user_insights", "stats" : { "recordsEmitted" : 10, "bytesEmitted" : 3935 } }, { "streamName" : "instagram_media_insights", "stats" : { "recordsEmitted" : 3003, "bytesEmitted" : 479139 } }, { "streamName" : "instagram_story_insights", "stats" : { "recordsEmitted" : 9, "bytesEmitted" : 1641 } }, { "streamName" : "instagram_media", "stats" : { "recordsEmitted" : 3487, "bytesEmitted" : 3895304 } } ] } 2022-11-03 13:26:02 INFO i.a.w.g.DefaultReplicationWorker(run):317 - failures: [ { "failureOrigin" : "source", "failureType" : "system_error", "internalMessage" : "'end_time'", "externalMessage" : "Something went wrong in the connector. See the logs for more details.", "metadata" : { "attemptNumber" : 0, "jobId" : 886, "from_trace_message" : true, "connector_command" : "read" }, "stacktrace" : "Traceback (most recent call last):\n File \"/airbyte/integration_code/main.py\", line 13, in \n launch(source, sys.argv[1:])\n File \"/usr/local/lib/python3.9/site-packages/airbyte_cdk/entrypoint.py\", line 123, in launch\n for message in source_entrypoint.run(parsed_args):\n File \"/usr/local/lib/python3.9/site-packages/airbyte_cdk/entrypoint.py\", line 114, in run\n for message in generator:\n File \"/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py\", line 127, in read\n raise e\n File \"/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py\", line 113, in read\n yield from self._read_stream(\n File \"/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py\", line 182, in _read_stream\n for record in record_iterator:\n File \"/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py\", line 285, in _read_full_refresh\n for record in records:\n File \"/airbyte/integration_code/source_instagram/streams.py\", line 124, in read_records\n \"date\": insight[\"values\"][0][\"end_time\"],\nKeyError: 'end_time'\n", "timestamp" : 1667481924867 }, { "failureOrigin" : "source", "internalMessage" : "io.airbyte.workers.general.DefaultReplicationWorker$SourceException: Source process exited with non-zero exit code 1", "externalMessage" : "Something went wrong within the source connector", "metadata" : { "attemptNumber" : 0, "jobId" : 886, "connector_command" : "read" }, "stacktrace" : "java.util.concurrent.CompletionException: io.airbyte.workers.general.DefaultReplicationWorker$SourceException: Source process exited with non-zero exit code 1\n\tat java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315)\n\tat java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:320)\n\tat java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1807)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)\n\tat java.base/java.lang.Thread.run(Thread.java:1589)\nCaused by: io.airbyte.workers.general.DefaultReplicationWorker$SourceException: Source process exited with non-zero exit code 1\n\tat io.airbyte.workers.general.DefaultReplicationWorker.lambda$getReplicationRunnable$6(DefaultReplicationWorker.java:395)\n\tat java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)\n\t... 3 more\n", "timestamp" : 1667481925087 } ] 2022-11-03 13:26:02 INFO i.a.w.t.TemporalAttemptExecution(get):162 - Stopping cancellation check scheduling... 2022-11-03 13:26:02 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):176 - sync summary: io.airbyte.config.StandardSyncOutput@28e2fb04[standardSyncSummary=io.airbyte.config.StandardSyncSummary@5b82ef26[status=failed,recordsSynced=6518,bytesSynced=4387145,startTime=1667478900287,endTime=1667481962816,totalStats=io.airbyte.config.SyncStats@34c53842[recordsEmitted=6518,bytesEmitted=4387145,sourceStateMessagesEmitted=10,destinationStateMessagesEmitted=17,recordsCommitted=,meanSecondsBeforeSourceStateMessageEmitted=299,maxSecondsBeforeSourceStateMessageEmitted=2996,maxSecondsBetweenStateMessageEmittedandCommitted=,meanSecondsBetweenStateMessageEmittedandCommitted=,replicationStartTime=1667478900287,replicationEndTime=1667481962815,sourceReadStartTime=1667478900374,sourceReadEndTime=1667481925086,destinationWriteStartTime=1667478900493,destinationWriteEndTime=1667481962815,additionalProperties={}],streamStats=[io.airbyte.config.StreamSyncStats@672ca202[streamName=instagram_stories,stats=io.airbyte.config.SyncStats@58294f38[recordsEmitted=9,bytesEmitted=7126,sourceStateMessagesEmitted=,destinationStateMessagesEmitted=,recordsCommitted=,meanSecondsBeforeSourceStateMessageEmitted=,maxSecondsBeforeSourceStateMessageEmitted=,maxSecondsBetweenStateMessageEmittedandCommitted=,meanSecondsBetweenStateMessageEmittedandCommitted=,replicationStartTime=,replicationEndTime=,sourceReadStartTime=,sourceReadEndTime=,destinationWriteStartTime=,destinationWriteEndTime=,additionalProperties={}]], io.airbyte.config.StreamSyncStats@141e60c4[streamName=instagram_user_insights,stats=io.airbyte.config.SyncStats@9045d2d[recordsEmitted=10,bytesEmitted=3935,sourceStateMessagesEmitted=,destinationStateMessagesEmitted=,recordsCommitted=,meanSecondsBeforeSourceStateMessageEmitted=,maxSecondsBeforeSourceStateMessageEmitted=,maxSecondsBetweenStateMessageEmittedandCommitted=,meanSecondsBetweenStateMessageEmittedandCommitted=,replicationStartTime=,replicationEndTime=,sourceReadStartTime=,sourceReadEndTime=,destinationWriteStartTime=,destinationWriteEndTime=,additionalProperties={}]], io.airbyte.config.StreamSyncStats@b3ac2bd[streamName=instagram_media_insights,stats=io.airbyte.config.SyncStats@19780c6d[recordsEmitted=3003,bytesEmitted=479139,sourceStateMessagesEmitted=,destinationStateMessagesEmitted=,recordsCommitted=,meanSecondsBeforeSourceStateMessageEmitted=,maxSecondsBeforeSourceStateMessageEmitted=,maxSecondsBetweenStateMessageEmittedandCommitted=,meanSecondsBetweenStateMessageEmittedandCommitted=,replicationStartTime=,replicationEndTime=,sourceReadStartTime=,sourceReadEndTime=,destinationWriteStartTime=,destinationWriteEndTime=,additionalProperties={}]], io.airbyte.config.StreamSyncStats@7e0747c6[streamName=instagram_story_insights,stats=io.airbyte.config.SyncStats@5541801e[recordsEmitted=9,bytesEmitted=1641,sourceStateMessagesEmitted=,destinationStateMessagesEmitted=,recordsCommitted=,meanSecondsBeforeSourceStateMessageEmitted=,maxSecondsBeforeSourceStateMessageEmitted=,maxSecondsBetweenStateMessageEmittedandCommitted=,meanSecondsBetweenStateMessageEmittedandCommitted=,replicationStartTime=,replicationEndTime=,sourceReadStartTime=,sourceReadEndTime=,destinationWriteStartTime=,destinationWriteEndTime=,additionalProperties={}]], io.airbyte.config.StreamSyncStats@8338f21[streamName=instagram_media,stats=io.airbyte.config.SyncStats@5171f12e[recordsEmitted=3487,bytesEmitted=3895304,sourceStateMessagesEmitted=,destinationStateMessagesEmitted=,recordsCommitted=,meanSecondsBeforeSourceStateMessageEmitted=,maxSecondsBeforeSourceStateMessageEmitted=,maxSecondsBetweenStateMessageEmittedandCommitted=,meanSecondsBetweenStateMessageEmittedandCommitted=,replicationStartTime=,replicationEndTime=,sourceReadStartTime=,sourceReadEndTime=,destinationWriteStartTime=,destinationWriteEndTime=,additionalProperties={}]]]],normalizationSummary=,webhookOperationSummary=,state=io.airbyte.config.State@2c2199fc[state=[{"type":"STREAM","stream":{"stream_descriptor":{"name":"user_insights"},"stream_state":{"17841403860219174":{"date":"2022-11-03T07:00:00+00:00"},"17841401993121167":{"date":"2022-11-03T07:00:00+00:00"},"17841400657993479":{"date":"2022-11-03T07:00:00+00:00"},"17841400844997659":{"date":"2022-11-03T07:00:00+00:00"},"17841440493306537":{"date":"2022-11-03T07:00:00+00:00"},"17841406448385387":{"date":"2022-11-03T07:00:00+00:00"},"17841417388884180":{"date":"2022-11-03T07:00:00+00:00"},"17841452674376878":{"date":"2022-11-03T07:00:00+00:00"},"17841452328191037":{"date":"2022-11-03T07:00:00+00:00"},"17841421145487667":{"date":"2022-11-03T07:00:00+00:00"}}}}]],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@158cb5b1[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@4c94966e[stream=io.airbyte.protocol.models.AirbyteStream@584a425a[name=instagram_media,jsonSchema={"type":"object","properties":{"id":{"type":["null","string"]},"ig_id":{"type":["null","string"]},"owner":{"type":["null","object"],"properties":{"id":{"type":["null","string"]}}},"caption":{"type":["null","string"]},"page_id":{"type":["null","string"]},"children":{"type":["null","array"],"items":{"type":"object","properties":{"id":{"type":["null","string"]},"ig_id":{"type":["null","string"]},"owner":{"type":["null","object"],"properties":{"id":{"type":["null","string"]}}},"username":{"type":["null","string"]},"media_url":{"type":["null","string"]},"permalink":{"type":["null","string"]},"shortcode":{"type":["null","string"]},"timestamp":{"type":["null","string"],"format":"date-time"},"media_type":{"type":["null","string"]},"thumbnail_url":{"type":["null","string"]}}}},"username":{"type":["null","string"]},"media_url":{"type":["null","string"]},"permalink":{"type":["null","string"]},"shortcode":{"type":["null","string"]},"timestamp":{"type":["null","string"],"format":"date-time"},"like_count":{"type":["null","integer"]},"media_type":{"type":["null","string"]},"thumbnail_url":{"type":["null","string"]},"comments_count":{"type":["null","integer"]},"is_comment_enabled":{"type":["null","boolean"]},"business_account_id":{"type":["null","string"]}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@66c30fc[stream=io.airbyte.protocol.models.AirbyteStream@76bd3cbd[name=instagram_media_insights,jsonSchema={"type":"object","properties":{"id":{"type":["null","string"]},"reach":{"type":["null","integer"]},"saved":{"type":["null","integer"]},"page_id":{"type":["null","string"]},"engagement":{"type":["null","integer"]},"impressions":{"type":["null","integer"]},"video_views":{"type":["null","integer"]},"business_account_id":{"type":["null","string"]},"carousel_album_reach":{"type":["null","integer"]},"carousel_album_saved":{"type":["null","integer"]},"carousel_album_engagement":{"type":["null","integer"]},"carousel_album_impressions":{"type":["null","integer"]}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@1ef2f3e2[stream=io.airbyte.protocol.models.AirbyteStream@14a03af4[name=instagram_stories,jsonSchema={"type":"object","properties":{"id":{"type":["null","string"]},"ig_id":{"type":["null","string"]},"owner":{"type":["null","object"],"properties":{"id":{"type":["null","string"]}}},"caption":{"type":["null","string"]},"page_id":{"type":["null","string"]},"username":{"type":["null","string"]},"media_url":{"type":["null","string"]},"permalink":{"type":["null","string"]},"shortcode":{"type":["null","string"]},"timestamp":{"type":["null","string"],"format":"date-time"},"like_count":{"type":["null","integer"]},"media_type":{"type":["null","string"]},"thumbnail_url":{"type":["null","string"]},"business_account_id":{"type":["null","string"]}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@73ac034c[stream=io.airbyte.protocol.models.AirbyteStream@6c6b9150[name=instagram_story_insights,jsonSchema={"type":"object","properties":{"id":{"type":["null","string"]},"exits":{"type":["null","integer"]},"reach":{"type":["null","integer"]},"page_id":{"type":["null","string"]},"replies":{"type":["null","integer"]},"taps_back":{"type":["null","integer"]},"impressions":{"type":["null","integer"]},"taps_forward":{"type":["null","integer"]},"business_account_id":{"type":["null","string"]}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@658f12dc[stream=io.airbyte.protocol.models.AirbyteStream@70ede303[name=instagram_user_insights,jsonSchema={"type":"object","properties":{"date":{"type":["null","string"],"format":"date-time"},"reach":{"type":["null","integer"]},"page_id":{"type":["null","string"]},"reach_week":{"type":["null","integer"]},"impressions":{"type":["null","integer"]},"profile_views":{"type":["null","integer"]},"reach_days_28":{"type":["null","integer"]},"follower_count":{"type":["null","integer"]},"website_clicks":{"type":["null","integer"]},"impressions_week":{"type":["null","integer"]},"online_followers":{"type":["null","object"]},"phone_call_clicks":{"type":["null","integer"]},"business_account_id":{"type":["null","string"]},"impressions_days_28":{"type":["null","integer"]},"text_message_clicks":{"type":["null","integer"]},"get_directions_clicks":{"type":["null","integer"]}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[date],sourceDefinedPrimaryKey=[],namespace=,additionalProperties={}],syncMode=incremental,cursorField=[date],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@63c82831[stream=io.airbyte.protocol.models.AirbyteStream@5319d409[name=instagram_user_lifetime_insights,jsonSchema={"type":"object","properties":{"date":{"type":["null","string"],"format":"date-time"},"value":{"type":["integer","object"]},"metric":{"type":["null","string"]},"page_id":{"type":["null","string"]},"business_account_id":{"type":["null","string"]}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@4e9d3544[stream=io.airbyte.protocol.models.AirbyteStream@51f7226f[name=instagram_users,jsonSchema={"type":"object","properties":{"id":{"type":["null","string"]},"name":{"type":["null","string"]},"ig_id":{"type":["null","integer"]},"page_id":{"type":["null","string"]},"website":{"type":["null","string"]},"username":{"type":["null","string"]},"biography":{"type":["null","string"]},"media_count":{"type":["null","integer"]},"follows_count":{"type":["null","integer"]},"followers_count":{"type":["null","integer"]},"profile_picture_url":{"type":["null","string"]}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[[id]],additionalProperties={}]],additionalProperties={}],failures=[io.airbyte.config.FailureReason@735c01c0[failureOrigin=source,failureType=system_error,internalMessage='end_time',externalMessage=Something went wrong in the connector. See the logs for more details.,metadata=io.airbyte.config.Metadata@6e782a3e[additionalProperties={attemptNumber=0, jobId=886, from_trace_message=true, connector_command=read}],stacktrace=Traceback (most recent call last): File "/airbyte/integration_code/main.py", line 13, in launch(source, sys.argv[1:]) File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/entrypoint.py", line 123, in launch for message in source_entrypoint.run(parsed_args): File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/entrypoint.py", line 114, in run for message in generator: File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 127, in read raise e File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 113, in read yield from self._read_stream( File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 182, in _read_stream for record in record_iterator: File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 285, in _read_full_refresh for record in records: File "/airbyte/integration_code/source_instagram/streams.py", line 124, in read_records "date": insight["values"][0]["end_time"], KeyError: 'end_time' ,retryable=,timestamp=1667481924867], io.airbyte.config.FailureReason@496815a0[failureOrigin=source,failureType=,internalMessage=io.airbyte.workers.general.DefaultReplicationWorker$SourceException: Source process exited with non-zero exit code 1,externalMessage=Something went wrong within the source connector,metadata=io.airbyte.config.Metadata@2164b2b8[additionalProperties={attemptNumber=0, jobId=886, connector_command=read}],stacktrace=java.util.concurrent.CompletionException: io.airbyte.workers.general.DefaultReplicationWorker$SourceException: 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:1144) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) at java.base/java.lang.Thread.run(Thread.java:1589) Caused by: io.airbyte.workers.general.DefaultReplicationWorker$SourceException: Source process exited with non-zero exit code 1 at io.airbyte.workers.general.DefaultReplicationWorker.lambda$getReplicationRunnable$6(DefaultReplicationWorker.java:395) at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ... 3 more ,retryable=,timestamp=1667481925087]]] 2022-11-03 13:26:02 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):181 - Sync summary length: 15348 2022-11-03 13:26:02 INFO i.a.c.t.TemporalUtils(withBackgroundHeartbeat):283 - Stopping temporal heartbeating... 2022-11-03 13:26:02 INFO i.a.c.i.LineGobbler(voidCall):114 - 2022-11-03 13:26:02 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- END REPLICATION ----- 2022-11-03 13:26:02 INFO i.a.c.i.LineGobbler(voidCall):114 - 2022-11-03 13:26:02 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):50 - Using default value for environment variable NEED_STATE_VALIDATION: 'true' 2022-11-03 13:26:03 INFO i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/886/0/logs.log 2022-11-03 13:26:03 INFO i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.16 2022-11-03 13:26:03 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):134 - Running with normalization version: airbyte/normalization:0.2.23 2022-11-03 13:26:03 INFO i.a.c.i.LineGobbler(voidCall):114 - 2022-11-03 13:26:03 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- START DEFAULT NORMALIZATION ----- 2022-11-03 13:26:03 INFO i.a.c.i.LineGobbler(voidCall):114 - 2022-11-03 13:26:03 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/normalization:0.2.23 exists... 2022-11-03 13:26:03 INFO i.a.c.i.LineGobbler(voidCall):114 - airbyte/normalization:0.2.23 was found locally. 2022-11-03 13:26:03 INFO i.a.w.p.DockerProcessFactory(create):119 - Creating docker container = normalization-normalize-886-0-byulf with resources io.airbyte.config.ResourceRequirements@45947a1[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] 2022-11-03 13:26:03 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/886/0/normalize --log-driver none --name normalization-normalize-886-0-byulf --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e AIRBYTE_VERSION=0.40.16 airbyte/normalization:0.2.23 run --integration-type bigquery --config destination_config.json --catalog destination_catalog.json 2022-11-03 13:26:03 normalization > Running: transform-config --config destination_config.json --integration-type bigquery --out /data/886/0/normalize 2022-11-03 13:26:04 normalization > Namespace(config='destination_config.json', integration_type=, out='/data/886/0/normalize') 2022-11-03 13:26:04 normalization > transform_bigquery 2022-11-03 13:26:04 normalization > Running: transform-catalog --integration-type bigquery --profile-config-dir /data/886/0/normalize --catalog destination_catalog.json --out /data/886/0/normalize/models/generated/ --json-column _airbyte_data 2022-11-03 13:26:05 normalization > Processing destination_catalog.json... 2022-11-03 13:26:05 normalization > Generating airbyte_ctes/misc/instagram_media_ab1.sql from instagram_media 2022-11-03 13:26:05 normalization > Generating airbyte_ctes/misc/instagram_media_ab2.sql from instagram_media 2022-11-03 13:26:05 normalization > Generating airbyte_ctes/misc/instagram_media_ab3.sql from instagram_media 2022-11-03 13:26:05 normalization > Generating airbyte_tables/misc/instagram_media.sql from instagram_media 2022-11-03 13:26:05 normalization > Generating airbyte_ctes/misc/instagram_media_insights_ab1.sql from instagram_media_insights 2022-11-03 13:26:05 normalization > Generating airbyte_ctes/misc/instagram_media_insights_ab2.sql from instagram_media_insights 2022-11-03 13:26:05 normalization > Generating airbyte_ctes/misc/instagram_media_insights_ab3.sql from instagram_media_insights 2022-11-03 13:26:05 normalization > Generating airbyte_tables/misc/instagram_media_insights.sql from instagram_media_insights 2022-11-03 13:26:05 normalization > Generating airbyte_ctes/misc/instagram_stories_ab1.sql from instagram_stories 2022-11-03 13:26:05 normalization > Generating airbyte_ctes/misc/instagram_stories_ab2.sql from instagram_stories 2022-11-03 13:26:05 normalization > Generating airbyte_ctes/misc/instagram_stories_ab3.sql from instagram_stories 2022-11-03 13:26:05 normalization > Generating airbyte_tables/misc/instagram_stories.sql from instagram_stories 2022-11-03 13:26:05 normalization > Generating airbyte_ctes/misc/instagram_story_insights_ab1.sql from instagram_story_insights 2022-11-03 13:26:05 normalization > Generating airbyte_ctes/misc/instagram_story_insights_ab2.sql from instagram_story_insights 2022-11-03 13:26:05 normalization > Generating airbyte_ctes/misc/instagram_story_insights_ab3.sql from instagram_story_insights 2022-11-03 13:26:05 normalization > Generating airbyte_tables/misc/instagram_story_insights.sql from instagram_story_insights 2022-11-03 13:26:05 normalization > Generating airbyte_ctes/misc/instagram_user_insights_ab1.sql from instagram_user_insights 2022-11-03 13:26:05 normalization > Generating airbyte_ctes/misc/instagram_user_insights_ab2.sql from instagram_user_insights 2022-11-03 13:26:05 normalization > Generating airbyte_ctes/misc/instagram_user_insights_ab3.sql from instagram_user_insights 2022-11-03 13:26:05 normalization > Generating airbyte_incremental/misc/instagram_user_insights.sql from instagram_user_insights 2022-11-03 13:26:05 normalization > Generating airbyte_ctes/misc/instagram_user_lifetime_insights_ab1.sql from instagram_user_lifetime_insights 2022-11-03 13:26:05 normalization > Generating airbyte_ctes/misc/instagram_user_lifetime_insights_ab2.sql from instagram_user_lifetime_insights 2022-11-03 13:26:05 normalization > Generating airbyte_ctes/misc/instagram_user_lifetime_insights_ab3.sql from instagram_user_lifetime_insights 2022-11-03 13:26:05 normalization > Generating airbyte_incremental/misc/instagram_user_lifetime_insights.sql from instagram_user_lifetime_insights 2022-11-03 13:26:05 normalization > Generating airbyte_ctes/misc/instagram_users_ab1.sql from instagram_users 2022-11-03 13:26:05 normalization > Generating airbyte_ctes/misc/instagram_users_ab2.sql from instagram_users 2022-11-03 13:26:05 normalization > Generating airbyte_ctes/misc/instagram_users_ab3.sql from instagram_users 2022-11-03 13:26:05 normalization > Generating airbyte_tables/misc/instagram_users.sql from instagram_users 2022-11-03 13:26:05 normalization > Generating airbyte_ctes/misc/instagram_media_owner_ab1.sql from instagram_media/owner 2022-11-03 13:26:05 normalization > Generating airbyte_ctes/misc/instagram_media_owner_ab2.sql from instagram_media/owner 2022-11-03 13:26:05 normalization > Generating airbyte_ctes/misc/instagram_media_owner_ab3.sql from instagram_media/owner 2022-11-03 13:26:05 normalization > Generating airbyte_tables/misc/instagram_media_owner.sql from instagram_media/owner 2022-11-03 13:26:05 normalization > Generating airbyte_ctes/misc/instagram_media_children_ab1.sql from instagram_media/children 2022-11-03 13:26:05 normalization > Generating airbyte_ctes/misc/instagram_media_children_ab2.sql from instagram_media/children 2022-11-03 13:26:05 normalization > Generating airbyte_ctes/misc/instagram_media_children_ab3.sql from instagram_media/children 2022-11-03 13:26:05 normalization > Generating airbyte_tables/misc/instagram_media_children.sql from instagram_media/children 2022-11-03 13:26:05 normalization > Generating airbyte_ctes/misc/instagram_stories_owner_ab1.sql from instagram_stories/owner 2022-11-03 13:26:05 normalization > Generating airbyte_ctes/misc/instagram_stories_owner_ab2.sql from instagram_stories/owner 2022-11-03 13:26:05 normalization > Generating airbyte_ctes/misc/instagram_stories_owner_ab3.sql from instagram_stories/owner 2022-11-03 13:26:05 normalization > Generating airbyte_tables/misc/instagram_stories_owner.sql from instagram_stories/owner 2022-11-03 13:26:05 normalization > Ignoring stream 'value' from instagram_user_lifetime_insights/value because properties list is empty 2022-11-03 13:26:05 normalization > Generating airbyte_ctes/misc/instagram_media_children_owner_ab1.sql from instagram_media/children/owner 2022-11-03 13:26:05 normalization > Generating airbyte_ctes/misc/instagram_media_children_owner_ab2.sql from instagram_media/children/owner 2022-11-03 13:26:05 normalization > Generating airbyte_ctes/misc/instagram_media_children_owner_ab3.sql from instagram_media/children/owner 2022-11-03 13:26:05 normalization > Generating airbyte_tables/misc/instagram_media_children_owner.sql from instagram_media/children/owner 2022-11-03 13:26:05 normalization > detected no config file for ssh, assuming ssh is off. 2022-11-03 13:26:11 normalization > [--event-buffer-size EVENT_BUFFER_SIZE] 2022-11-03 13:26:11 normalization > --event-buffer-size EVENT_BUFFER_SIZE 2022-11-03 13:26:11 INFO i.a.w.n.NormalizationAirbyteStreamFactory(filterOutAndHandleNonAirbyteMessageLines):104 - 2022-11-03 13:26:11 normalization > DBT >=1.0.0 detected; using 10K event buffer size 2022-11-03 13:26:11 INFO i.a.w.n.NormalizationAirbyteStreamFactory(filterOutAndHandleNonAirbyteMessageLines):104 - 2022-11-03 13:26:17 normalization > Running with dbt=1.0.0 2022-11-03 13:26:17 normalization > Partial parse save file not found. Starting full parse. 2022-11-03 13:26:22 normalization > [WARNING]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources. There are 1 unused configuration paths: - models.airbyte_utils.generated.airbyte_views 2022-11-03 13:26:22 normalization > Found 44 models, 0 tests, 0 snapshots, 0 analyses, 602 macros, 0 operations, 0 seed files, 7 sources, 0 exposures, 0 metrics 2022-11-03 13:26:27 normalization > Concurrency: 8 threads (target='prod') 2022-11-03 13:26:28 normalization > 1 of 11 START table model misc.instagram_media_insights................................................................. [RUN] 2022-11-03 13:26:28 normalization > 2 of 11 START table model misc.instagram_stories........................................................................ [RUN] 2022-11-03 13:26:28 normalization > 3 of 11 START table model misc.instagram_story_insights................................................................. [RUN] 2022-11-03 13:26:28 normalization > 4 of 11 START table model misc.instagram_users.......................................................................... [RUN] 2022-11-03 13:26:28 normalization > 5 of 11 START table model misc.instagram_media.......................................................................... [RUN] 2022-11-03 13:26:29 normalization > 6 of 11 START incremental model misc.instagram_user_lifetime_insights................................................... [RUN] 2022-11-03 13:26:30 normalization > 7 of 11 START incremental model misc.instagram_user_insights............................................................ [RUN] 2022-11-03 13:26:32 normalization > 2 of 11 OK created table model misc.instagram_stories................................................................... [CREATE TABLE (9.0 rows, 7.4 KB processed) in 3.63s] 2022-11-03 13:26:32 normalization > 4 of 11 OK created table model misc.instagram_users..................................................................... [CREATE TABLE (0.0 rows, 0 processed) in 3.63s] 2022-11-03 13:26:32 normalization > 8 of 11 START table model misc.instagram_stories_owner.................................................................. [RUN] 2022-11-03 13:26:32 normalization > 1 of 11 OK created table model misc.instagram_media_insights............................................................ [CREATE TABLE (3.0k rows, 608.7 KB processed) in 3.85s] 2022-11-03 13:26:32 normalization > 3 of 11 OK created table model misc.instagram_story_insights............................................................ [CREATE TABLE (9.0 rows, 2.0 KB processed) in 3.89s] 2022-11-03 13:26:32 normalization > 5 of 11 OK created table model misc.instagram_media..................................................................... [CREATE TABLE (3.5k rows, 3.9 MB processed) in 4.08s] 2022-11-03 13:26:33 normalization > 9 of 11 START table model misc.instagram_media_owner.................................................................... [RUN] 2022-11-03 13:26:33 normalization > 10 of 11 START table model misc.instagram_media_children................................................................ [RUN] 2022-11-03 13:26:34 normalization > 8 of 11 OK created table model misc.instagram_stories_owner............................................................. [CREATE TABLE (9.0 rows, 972.0 Bytes processed) in 2.37s] 2022-11-03 13:26:35 normalization > 9 of 11 OK created table model misc.instagram_media_owner............................................................... [CREATE TABLE (3.5k rows, 367.8 KB processed) in 2.49s] 2022-11-03 13:26:35 normalization > 10 of 11 OK created table model misc.instagram_media_children........................................................... [CREATE TABLE (1.2k rows, 947.6 KB processed) in 2.43s] 2022-11-03 13:26:35 normalization > 11 of 11 START table model misc.instagram_media_children_owner.......................................................... [RUN] 2022-11-03 13:26:36 normalization > 6 of 11 OK created incremental model misc.instagram_user_lifetime_insights.............................................. [MERGE (0.0 rows, 0 processed) in 6.82s] 2022-11-03 13:26:36 normalization > 7 of 11 OK created incremental model misc.instagram_user_insights....................................................... [MERGE (11.0 rows, 59.9 KB processed) in 6.73s] 2022-11-03 13:26:38 normalization > 11 of 11 OK created table model misc.instagram_media_children_owner..................................................... [CREATE TABLE (1.2k rows, 124.3 KB processed) in 2.64s] 2022-11-03 13:26:38 normalization > Finished running 9 table models, 2 incremental models in 16.29s. 2022-11-03 13:26:38 normalization > Completed successfully 2022-11-03 13:26:38 normalization > Done. PASS=11 WARN=0 ERROR=0 SKIP=0 TOTAL=11 2022-11-03 13:26:39 INFO i.a.w.g.DefaultNormalizationWorker(run):82 - Normalization executed in 36 seconds. 2022-11-03 13:26:39 INFO i.a.w.g.DefaultNormalizationWorker(run):95 - Normalization summary: io.airbyte.config.NormalizationSummary@40cf3f81[startTime=1667481963045,endTime=1667481999077,failures=[]] 2022-11-03 13:26:39 INFO i.a.w.t.TemporalAttemptExecution(get):162 - Stopping cancellation check scheduling... 2022-11-03 13:26:39 INFO i.a.c.i.LineGobbler(voidCall):114 - 2022-11-03 13:26:39 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- END DEFAULT NORMALIZATION ----- 2022-11-03 13:26:39 INFO i.a.c.t.TemporalUtils(withBackgroundHeartbeat):283 - Stopping temporal heartbeating... 2022-11-03 13:26:39 INFO i.a.c.i.LineGobbler(voidCall):114 - 2022-11-03 13:26:39 INFO i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/886/1/logs.log 2022-11-03 13:26:39 INFO i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.16 2022-11-03 13:26:39 INFO i.a.c.i.LineGobbler(voidCall):114 - 2022-11-03 13:26:39 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK ----- 2022-11-03 13:26:39 INFO i.a.c.i.LineGobbler(voidCall):114 - 2022-11-03 13:26:39 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/source-instagram:1.0.0 exists... 2022-11-03 13:26:40 INFO i.a.c.i.LineGobbler(voidCall):114 - airbyte/source-instagram:1.0.0 was found locally. 2022-11-03 13:26:40 INFO i.a.w.p.DockerProcessFactory(create):119 - Creating docker container = source-instagram-check-886-1-irlli with resources io.airbyte.config.ResourceRequirements@3dd35bf6[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] 2022-11-03 13:26:40 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/886/1 --log-driver none --name source-instagram-check-886-1-irlli --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_JOB_ATTEMPT=1 -e WORKER_CONNECTOR_IMAGE=airbyte/source-instagram:1.0.0 -e AIRBYTE_VERSION=0.40.16 -e WORKER_JOB_ID=886 airbyte/source-instagram:1.0.0 check --config source_config.json 2022-11-03 13:26:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):117 - Available accounts: [{'page_id': '102749291163959', 'instagram_business_account': { "id": "17841421145487667" }}, {'page_id': '103060399076772', 'instagram_business_account': { "id": "17841452674376878" }}, {'page_id': '104664184731323', 'instagram_business_account': { "id": "17841440493306537" }}, {'page_id': '105860508692773', 'instagram_business_account': { "id": "17841452328191037" }}, {'page_id': '112693045416373', 'instagram_business_account': { "id": "17841400844997659" }}, {'page_id': '125387384800730', 'instagram_business_account': { "id": "17841406448385387" }}, {'page_id': '170433679646459', 'instagram_business_account': { "id": "17841400657993479" }}, {'page_id': '186733888443088', 'instagram_business_account': { "id": "17841403860219174" }}, {'page_id': '759141440879871', 'instagram_business_account': { "id": "17841417388884180" }}, {'page_id': '785571031595001', 'instagram_business_account': { "id": "17841401993121167" }}] 2022-11-03 13:26:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):117 - Check succeeded 2022-11-03 13:26:46 INFO i.a.w.t.TemporalAttemptExecution(get):162 - Stopping cancellation check scheduling... 2022-11-03 13:26:46 INFO i.a.c.i.LineGobbler(voidCall):114 - 2022-11-03 13:26:46 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK ----- 2022-11-03 13:26:46 INFO i.a.c.i.LineGobbler(voidCall):114 - 2022-11-03 13:26:46 INFO i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/886/1/logs.log 2022-11-03 13:26:46 INFO i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.16 2022-11-03 13:26:46 INFO i.a.c.i.LineGobbler(voidCall):114 - 2022-11-03 13:26:46 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK ----- 2022-11-03 13:26:46 INFO i.a.c.i.LineGobbler(voidCall):114 - 2022-11-03 13:26:46 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/destination-bigquery:1.2.5 exists... 2022-11-03 13:26:46 INFO i.a.c.i.LineGobbler(voidCall):114 - airbyte/destination-bigquery:1.2.5 was found locally. 2022-11-03 13:26:46 INFO i.a.w.p.DockerProcessFactory(create):119 - Creating docker container = destination-bigquery-check-886-1-mjjnr with resources io.airbyte.config.ResourceRequirements@3dd35bf6[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] 2022-11-03 13:26:46 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/886/1 --log-driver none --name destination-bigquery-check-886-1-mjjnr --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_JOB_ATTEMPT=1 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-bigquery:1.2.5 -e AIRBYTE_VERSION=0.40.16 -e WORKER_JOB_ID=886 airbyte/destination-bigquery:1.2.5 check --config source_config.json 2022-11-03 13:26:51 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):117 - integration args: {check=null, config=source_config.json} 2022-11-03 13:26:51 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):117 - Running integration: io.airbyte.integrations.destination.bigquery.BigQueryDestination 2022-11-03 13:26:51 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):117 - Command: CHECK 2022-11-03 13:26:51 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):117 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'} 2022-11-03 13:26:51 WARN i.a.w.i.DefaultAirbyteStreamFactory(internalLog):114 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-11-03 13:26:51 WARN i.a.w.i.DefaultAirbyteStreamFactory(internalLog):114 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-11-03 13:26:52 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):117 - Selected loading method is set to: STANDARD 2022-11-03 13:26:55 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):117 - Completed integration: io.airbyte.integrations.destination.bigquery.BigQueryDestination 2022-11-03 13:26:55 INFO i.a.w.t.TemporalAttemptExecution(get):162 - Stopping cancellation check scheduling... 2022-11-03 13:26:55 INFO i.a.c.i.LineGobbler(voidCall):114 - 2022-11-03 13:26:55 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK ----- 2022-11-03 13:26:55 INFO i.a.c.i.LineGobbler(voidCall):114 - 2022-11-03 13:26:55 INFO i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/886/1/logs.log 2022-11-03 13:26:55 INFO i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.16 2022-11-03 13:26:55 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):50 - Using default value for environment variable LOG_CONNECTOR_MESSAGES: 'false' 2022-11-03 13:26:55 INFO i.a.c.EnvConfigs(getEnvOrDefault):1091 - Using default value for environment variable METRIC_CLIENT: '' 2022-11-03 13:26:55 WARN i.a.m.l.MetricClientFactory(initialize):60 - Metric client is already initialized to 2022-11-03 13:26:55 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):50 - Using default value for environment variable LOG_CONNECTOR_MESSAGES: 'false' 2022-11-03 13:26:55 INFO i.a.w.g.DefaultReplicationWorker(run):125 - start sync worker. job id: 886 attempt id: 1 2022-11-03 13:26:55 INFO i.a.w.g.DefaultReplicationWorker(run):141 - configured sync modes: {null.media_insights=full_refresh - overwrite, null.stories=full_refresh - overwrite, null.story_insights=full_refresh - overwrite, null.user_lifetime_insights=full_refresh - append, null.users=full_refresh - overwrite, null.media=full_refresh - overwrite, null.user_insights=incremental - append} 2022-11-03 13:26:55 INFO i.a.w.i.DefaultAirbyteDestination(start):65 - Running destination... 2022-11-03 13:26:55 INFO i.a.c.i.LineGobbler(voidCall):114 - 2022-11-03 13:26:55 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- START REPLICATION ----- 2022-11-03 13:26:55 INFO i.a.c.i.LineGobbler(voidCall):114 - 2022-11-03 13:26:55 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/destination-bigquery:1.2.5 exists... 2022-11-03 13:26:55 INFO i.a.c.i.LineGobbler(voidCall):114 - airbyte/destination-bigquery:1.2.5 was found locally. 2022-11-03 13:26:55 INFO i.a.w.p.DockerProcessFactory(create):119 - Creating docker container = destination-bigquery-write-886-1-zbgie with resources io.airbyte.config.ResourceRequirements@554843d2[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] 2022-11-03 13:26:55 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/886/1 --log-driver none --name destination-bigquery-write-886-1-zbgie --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_JOB_ATTEMPT=1 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-bigquery:1.2.5 -e AIRBYTE_VERSION=0.40.16 -e WORKER_JOB_ID=886 airbyte/destination-bigquery:1.2.5 write --config destination_config.json --catalog destination_catalog.json 2022-11-03 13:26:55 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/source-instagram:1.0.0 exists... 2022-11-03 13:26:56 INFO i.a.c.i.LineGobbler(voidCall):114 - airbyte/source-instagram:1.0.0 was found locally. 2022-11-03 13:26:56 INFO i.a.w.p.DockerProcessFactory(create):119 - Creating docker container = source-instagram-read-886-1-fixtt with resources io.airbyte.config.ResourceRequirements@3e4cf12f[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] 2022-11-03 13:26:56 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/886/1 --log-driver none --name source-instagram-read-886-1-fixtt --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_JOB_ATTEMPT=1 -e WORKER_CONNECTOR_IMAGE=airbyte/source-instagram:1.0.0 -e AIRBYTE_VERSION=0.40.16 -e WORKER_JOB_ID=886 airbyte/source-instagram:1.0.0 read --config source_config.json --catalog source_catalog.json --state input_state.json 2022-11-03 13:26:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):454 - Destination output thread started. 2022-11-03 13:26:56 INFO i.a.w.g.DefaultReplicationWorker(run):185 - Waiting for source and destination threads to complete. 2022-11-03 13:26:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):339 - Replication thread started. 2022-11-03 13:26:57 source > Starting syncing SourceInstagram 2022-11-03 13:26:57 source > Syncing stream: media 2022-11-03 13:26:59 source > /usr/local/lib/python3.9/site-packages/facebook_business/utils/api_utils.py:30: UserWarning: media does not allow field children 2022-11-03 13:26:59 source > warnings.warn(message) 2022-11-03 13:26:59 destination > integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json} 2022-11-03 13:26:59 destination > Running integration: io.airbyte.integrations.destination.bigquery.BigQueryDestination 2022-11-03 13:26:59 destination > Command: WRITE 2022-11-03 13:26:59 destination > Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'} 2022-11-03 13:27:00 destination > Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-11-03 13:27:00 destination > Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-11-03 13:27:00 destination > Selected loading method is set to: STANDARD 2022-11-03 13:27:00 destination > The "standard" upload mode is not performant, and is not recommended for production. Please use the GCS upload mode if you are syncing a large amount of data. 2022-11-03 13:27:00 destination > Selected loading method is set to: STANDARD 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:01 ERROR c.n.s.DateTimeValidator(tryParse):82 - Invalid date-time: Invalid timezone offset: +0000 2022-11-03 13:27:03 destination > Partitioned table created successfully: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=misc, tableId=_airbyte_tmp_kbq_instagram_media}} 2022-11-03 13:27:03 destination > Selected loading method is set to: STANDARD 2022-11-03 13:27:03 destination > Selected loading method is set to: STANDARD 2022-11-03 13:27:03 destination > Partitioned table created successfully: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=misc, tableId=_airbyte_tmp_jjl_instagram_media_insights}} 2022-11-03 13:27:03 destination > Selected loading method is set to: STANDARD 2022-11-03 13:27:04 destination > Selected loading method is set to: STANDARD 2022-11-03 13:27:04 destination > Partitioned table created successfully: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=misc, tableId=_airbyte_tmp_ztb_instagram_stories}} 2022-11-03 13:27:04 destination > Selected loading method is set to: STANDARD 2022-11-03 13:27:04 destination > Selected loading method is set to: STANDARD 2022-11-03 13:27:05 destination > Partitioned table created successfully: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=misc, tableId=_airbyte_tmp_svr_instagram_story_insights}} 2022-11-03 13:27:05 destination > Selected loading method is set to: STANDARD 2022-11-03 13:27:05 destination > Selected loading method is set to: STANDARD 2022-11-03 13:27:05 destination > Partitioned table created successfully: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=misc, tableId=_airbyte_tmp_xgc_instagram_user_insights}} 2022-11-03 13:27:05 destination > Selected loading method is set to: STANDARD 2022-11-03 13:27:06 destination > Selected loading method is set to: STANDARD 2022-11-03 13:27:06 destination > Partitioned table created successfully: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=misc, tableId=_airbyte_tmp_yyc_instagram_user_lifetime_insights}} 2022-11-03 13:27:06 destination > Selected loading method is set to: STANDARD 2022-11-03 13:27:07 destination > Selected loading method is set to: STANDARD 2022-11-03 13:27:07 destination > Partitioned table created successfully: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=misc, tableId=_airbyte_tmp_zcw_instagram_users}} 2022-11-03 13:27:07 destination > Selected loading method is set to: STANDARD 2022-11-03 13:27:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):369 - Records read: 1000 (925 KB) 2022-11-03 13:28:15 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$5):226 - Running sync worker cancellation... 2022-11-03 13:28:15 INFO i.a.w.g.DefaultReplicationWorker(cancel):493 - Cancelling replication worker... 2022-11-03 13:28:25 INFO i.a.w.g.DefaultReplicationWorker(cancel):501 - Cancelling destination... 2022-11-03 13:28:25 INFO i.a.w.i.DefaultAirbyteDestination(cancel):121 - Attempting to cancel destination process... 2022-11-03 13:28:25 INFO i.a.w.i.DefaultAirbyteDestination(cancel):126 - Destination process exists, cancelling... 2022-11-03 13:28:25 INFO i.a.w.g.DefaultReplicationWorker(run):190 - One of source or destination thread complete. Waiting on the other. 2022-11-03 13:28:25 WARN i.a.c.i.LineGobbler(voidCall):119 - airbyte-destination gobbler IOException: Stream closed. Typically happens when cancelling a job. 2022-11-03 13:28:25 INFO i.a.w.i.DefaultAirbyteDestination(cancel):128 - Cancelled destination process! 2022-11-03 13:28:25 INFO i.a.w.g.DefaultReplicationWorker(cancel):508 - Cancelling source... 2022-11-03 13:28:25 INFO i.a.w.i.DefaultAirbyteSource(cancel):141 - Attempting to cancel source process... 2022-11-03 13:28:25 INFO i.a.w.i.DefaultAirbyteSource(cancel):146 - Source process exists, cancelling... 2022-11-03 13:28:26 INFO i.a.w.g.DefaultReplicationWorker(run):192 - Source and destination threads complete. 2022-11-03 13:28:26 INFO i.a.w.i.DefaultAirbyteSource(cancel):148 - Cancelled source process! 2022-11-03 13:28:26 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$5):230 - Interrupting worker thread... 2022-11-03 13:28:26 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$5):233 - Cancelling completable future... 2022-11-03 13:28:26 ERROR i.a.w.g.DefaultReplicationWorker(run):196 - Sync worker failed. io.airbyte.workers.exception.WorkerException: Source process exit with code 143. This warning is normal if the job was cancelled. at io.airbyte.workers.internal.DefaultAirbyteSource.close(DefaultAirbyteSource.java:135) ~[io.airbyte-airbyte-commons-worker-0.40.16.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:194) ~[io.airbyte-airbyte-commons-worker-0.40.16.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:71) ~[io.airbyte-airbyte-commons-worker-0.40.16.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$4(TemporalAttemptExecution.java:190) ~[io.airbyte-airbyte-workers-0.40.16.jar:?] at java.lang.Thread.run(Thread.java:1589) ~[?:?] Suppressed: java.io.IOException: Stream closed at java.lang.ProcessBuilder$NullOutputStream.write(ProcessBuilder.java:445) ~[?:?] at java.io.OutputStream.write(OutputStream.java:164) ~[?:?] at java.io.BufferedOutputStream.flushBuffer(BufferedOutputStream.java:125) ~[?:?] at java.io.BufferedOutputStream.implFlush(BufferedOutputStream.java:251) ~[?:?] at java.io.BufferedOutputStream.flush(BufferedOutputStream.java:245) ~[?:?] at sun.nio.cs.StreamEncoder.implFlush(StreamEncoder.java:416) ~[?:?] at sun.nio.cs.StreamEncoder.lockedFlush(StreamEncoder.java:218) ~[?:?] at sun.nio.cs.StreamEncoder.flush(StreamEncoder.java:205) ~[?:?] at java.io.OutputStreamWriter.flush(OutputStreamWriter.java:263) ~[?:?] at java.io.BufferedWriter.implFlush(BufferedWriter.java:372) ~[?:?] at java.io.BufferedWriter.flush(BufferedWriter.java:359) ~[?:?] at io.airbyte.workers.internal.DefaultAirbyteDestination.notifyEndOfInput(DefaultAirbyteDestination.java:94) ~[io.airbyte-airbyte-commons-worker-0.40.16.jar:?] at io.airbyte.workers.internal.DefaultAirbyteDestination.close(DefaultAirbyteDestination.java:107) ~[io.airbyte-airbyte-commons-worker-0.40.16.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:151) ~[io.airbyte-airbyte-commons-worker-0.40.16.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:71) ~[io.airbyte-airbyte-commons-worker-0.40.16.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$4(TemporalAttemptExecution.java:190) ~[io.airbyte-airbyte-workers-0.40.16.jar:?] at java.lang.Thread.run(Thread.java:1589) ~[?:?] 2022-11-03 13:28:26 WARN i.a.c.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled. 2022-11-03 13:28:26 WARN i.a.c.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled. 2022-11-03 13:28:26 INFO i.a.w.g.DefaultReplicationWorker(run):297 - Source did not output any state messages 2022-11-03 13:28:26 INFO i.a.w.t.TemporalAttemptExecution(get):162 - Stopping cancellation check scheduling... 2022-11-03 13:28:26 INFO i.a.c.t.TemporalUtils(withBackgroundHeartbeat):283 - Stopping temporal heartbeating... 2022-11-03 13:28:26 WARN i.a.w.g.DefaultReplicationWorker(run):305 - State capture: No new state, falling back on input state: io.airbyte.config.State@4b252dd3[state=[{"type":"STREAM","stream":{"stream_state":{"17841400657993479":{"date":"2022-11-03T07:00:00+00:00"},"17841400844997659":{"date":"2022-11-03T07:00:00+00:00"},"17841401993121167":{"date":"2022-11-03T07:00:00+00:00"},"17841403860219174":{"date":"2022-11-03T07:00:00+00:00"},"17841406448385387":{"date":"2022-11-03T07:00:00+00:00"},"17841417388884180":{"date":"2022-11-03T07:00:00+00:00"},"17841421145487667":{"date":"2022-11-03T07:00:00+00:00"},"17841440493306537":{"date":"2022-11-03T07:00:00+00:00"},"17841452328191037":{"date":"2022-11-03T07:00:00+00:00"},"17841452674376878":{"date":"2022-11-03T07:00:00+00:00"}},"stream_descriptor":{"name":"user_insights"}}}]] 2022-11-03 13:28:26 WARN i.t.i.a.POJOActivityTaskHandler(activityFailureToResult):307 - Activity failure. ActivityId=e889c836-ad77-3d00-84bb-070d50d1f388, activityType=Replicate, attempt=1 java.lang.RuntimeException: java.util.concurrent.CancellationException at io.airbyte.commons.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:281) ~[io.airbyte-airbyte-commons-temporal-0.40.16.jar:?] at io.airbyte.workers.temporal.sync.ReplicationActivityImpl.replicate(ReplicationActivityImpl.java:128) ~[io.airbyte-airbyte-workers-0.40.16.jar:?] at jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:104) ~[?:?] at java.lang.reflect.Method.invoke(Method.java:578) ~[?:?] at io.temporal.internal.activity.POJOActivityTaskHandler$POJOActivityInboundCallsInterceptor.execute(POJOActivityTaskHandler.java:214) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.activity.POJOActivityTaskHandler$POJOActivityImplementation.execute(POJOActivityTaskHandler.java:180) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.activity.POJOActivityTaskHandler.handle(POJOActivityTaskHandler.java:120) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:204) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:164) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:93) ~[temporal-sdk-1.8.1.jar:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?] at java.lang.Thread.run(Thread.java:1589) ~[?:?] Caused by: java.util.concurrent.CancellationException at java.util.concurrent.CompletableFuture.cancel(CompletableFuture.java:2510) ~[?:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$5(TemporalAttemptExecution.java:236) ~[io.airbyte-airbyte-workers-0.40.16.jar:?] at io.airbyte.commons.temporal.CancellationHandler$TemporalCancellationHandler.checkAndHandleCancellation(CancellationHandler.java:52) ~[io.airbyte-airbyte-commons-temporal-0.40.16.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$6(TemporalAttemptExecution.java:239) ~[io.airbyte-airbyte-workers-0.40.16.jar:?] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:577) ~[?:?] at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:358) ~[?:?] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) ~[?:?] ... 3 more 2022-11-03 13:28:26 INFO i.a.w.g.DefaultReplicationWorker(run):316 - sync summary: { "status" : "cancelled", "recordsSynced" : 1867, "bytesSynced" : 1903355, "startTime" : 1667482015766, "endTime" : 1667482106086, "totalStats" : { "recordsEmitted" : 1867, "bytesEmitted" : 1903355, "sourceStateMessagesEmitted" : 0, "destinationStateMessagesEmitted" : 0, "recordsCommitted" : 0, "meanSecondsBeforeSourceStateMessageEmitted" : 0, "maxSecondsBeforeSourceStateMessageEmitted" : 0, "maxSecondsBetweenStateMessageEmittedandCommitted" : 0, "meanSecondsBetweenStateMessageEmittedandCommitted" : 0, "replicationStartTime" : 1667482015766, "replicationEndTime" : 1667482106085, "sourceReadStartTime" : 1667482015843, "sourceReadEndTime" : 0, "destinationWriteStartTime" : 1667482016038, "destinationWriteEndTime" : 0 }, "streamStats" : [ { "streamName" : "instagram_media", "stats" : { "recordsEmitted" : 1867, "bytesEmitted" : 1903355 } } ] } 2022-11-03 13:28:26 INFO i.a.w.g.DefaultReplicationWorker(run):317 - failures: [ ] 2022-11-03 13:28:26 INFO i.a.c.i.LineGobbler(voidCall):114 - 2022-11-03 13:28:26 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- END REPLICATION ----- 2022-11-03 13:28:26 INFO i.a.c.i.LineGobbler(voidCall):114 -