2023-01-02 10:01:21 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. errors: $.method: must be a constant value Standard 2023-01-02 10:01:21 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. errors: $.access_key_id: object found, string expected, $.secret_access_key: object found, string expected 2023-01-02 10:01:21 INFO i.a.a.LoggingTrackingClient(track):43 - track. version: null, userId: null, action: Connector Jobs, metadata: {job_type=sync, namespace_definition=source, frequency=manual, connector_source_definition_id=9e0556f4-69df-4522-a3fb-03264d36b348, config.destination.port=set, workspace_id=27960fb9-f0c0-414c-bda4-792667d7d031, config.destination.database=set, attempt_stage=STARTED, config.source.domain_url._secret=set, config.destination.password._secret=set, attempt_id=1, connector_destination=Redshift, connector_destination_docker_repository=airbyte/destination-redshift, config.source.client_secret._secret=set, table_prefix=true, workspace_name=27960fb9-f0c0-414c-bda4-792667d7d031, config.source.start_date=set, catalog.destination_sync_mode.overwrite=set, number_of_streams=1, connector_source=Marketo, config.destination.host=set, connector_source_docker_repository=airbyte/source-marketo, config.destination.schema=set, config.destination.username=set, catalog.sync_mode.full_refresh=set, connection_id=fcc869fc-17c3-407a-9bbc-e4f0783fe583, job_id=1334, connector_source_version=0.1.11, connector_destination_version=0.3.50, operation.normalization=1, operation_count=1, config.source.client_id._secret=set, connector_destination_definition_id=f7a7d195-377f-cf5b-70a5-be6b819019dc} 2023-01-02 10:01:21 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/1334/0/logs.log 2023-01-02 10:01:21 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.40.11 2023-01-02 10:01:21 INFO i.a.c.i.LineGobbler(voidCall):114 - 2023-01-02 10:01:21 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK ----- 2023-01-02 10:01:21 INFO i.a.c.i.LineGobbler(voidCall):114 - 2023-01-02 10:01:21 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/source-marketo:0.1.11 exists... 2023-01-02 10:01:21 INFO i.a.c.i.LineGobbler(voidCall):114 - airbyte/source-marketo:0.1.11 was found locally. 2023-01-02 10:01:21 INFO i.a.w.p.DockerProcessFactory(create):119 - Creating docker container = source-marketo-check-1334-0-pmncj with resources io.airbyte.config.ResourceRequirements@2f9237c3[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] 2023-01-02 10:01:21 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/1334/0 --log-driver none --name source-marketo-check-1334-0-pmncj --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_CONNECTOR_IMAGE=airbyte/source-marketo:0.1.11 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_VERSION=0.40.11 -e WORKER_JOB_ID=1334 airbyte/source-marketo:0.1.11 check --config source_config.json 2023-01-02 10:01:23 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - Check succeeded 2023-01-02 10:01:23 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling... 2023-01-02 10:01:23 INFO i.a.c.i.LineGobbler(voidCall):114 - 2023-01-02 10:01:23 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK ----- 2023-01-02 10:01:23 INFO i.a.c.i.LineGobbler(voidCall):114 - 2023-01-02 10:01:23 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/1334/0/logs.log 2023-01-02 10:01:23 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.40.11 2023-01-02 10:01:23 INFO i.a.c.i.LineGobbler(voidCall):114 - 2023-01-02 10:01:23 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK ----- 2023-01-02 10:01:23 INFO i.a.c.i.LineGobbler(voidCall):114 - 2023-01-02 10:01:23 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/destination-redshift:0.3.50 exists... 2023-01-02 10:01:23 INFO i.a.c.i.LineGobbler(voidCall):114 - airbyte/destination-redshift:0.3.50 was found locally. 2023-01-02 10:01:23 INFO i.a.w.p.DockerProcessFactory(create):119 - Creating docker container = destination-redshift-check-1334-0-dgxnb with resources io.airbyte.config.ResourceRequirements@2f9237c3[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] 2023-01-02 10:01:23 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/1334/0 --log-driver none --name destination-redshift-check-1334-0-dgxnb --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_CONNECTOR_IMAGE=airbyte/destination-redshift:0.3.50 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_VERSION=0.40.11 -e WORKER_JOB_ID=1334 airbyte/destination-redshift:0.3.50 check --config source_config.json 2023-01-02 10:01:25 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - starting destination: class io.airbyte.integrations.destination.redshift.RedshiftDestination 2023-01-02 10:01:25 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - integration args: {check=null, config=source_config.json} 2023-01-02 10:01:25 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - Running integration: io.airbyte.integrations.destination.redshift.RedshiftDestination 2023-01-02 10:01:25 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - Command: CHECK 2023-01-02 10:01:25 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'} 2023-01-02 10:01:25 WARN i.a.w.i.DefaultAirbyteStreamFactory(internalLog):106 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2023-01-02 10:01:25 WARN i.a.w.i.DefaultAirbyteStreamFactory(internalLog):106 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2023-01-02 10:01:25 WARN i.a.w.i.DefaultAirbyteStreamFactory(internalLog):106 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2023-01-02 10:01:25 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - Using destination type: COPY_S3 2023-01-02 10:01:25 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - Creating S3 client... 2023-01-02 10:01:26 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - Started testing if IAM user can call listObjects on the destination bucket 2023-01-02 10:01:26 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - Finished checking for listObjects permission 2023-01-02 10:01:26 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - HikariPool-1 - Starting... 2023-01-02 10:01:26 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - HikariPool-1 - Start completed. 2023-01-02 10:01:26 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - HikariPool-1 - Driver does not support get/set network timeout for connections. ([Amazon][JDBC](10220) Driver does not support this optional feature.) 2023-01-02 10:01:29 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - HikariPool-1 - Shutdown initiated... 2023-01-02 10:01:29 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - HikariPool-1 - Shutdown completed. 2023-01-02 10:01:29 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - Completed integration: io.airbyte.integrations.destination.redshift.RedshiftDestination 2023-01-02 10:01:29 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):109 - completed destination: class io.airbyte.integrations.destination.redshift.RedshiftDestination 2023-01-02 10:01:29 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling... 2023-01-02 10:01:29 INFO i.a.c.i.LineGobbler(voidCall):114 - 2023-01-02 10:01:29 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK ----- 2023-01-02 10:01:29 INFO i.a.c.i.LineGobbler(voidCall):114 - 2023-01-02 10:01:29 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/1334/0/logs.log 2023-01-02 10:01:29 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.40.11 2023-01-02 10:01:29 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):50 - Using default value for environment variable LOG_CONNECTOR_MESSAGES: 'false' 2023-01-02 10:01:29 INFO i.a.c.EnvConfigs(getEnvOrDefault):1085 - Using default value for environment variable METRIC_CLIENT: '' 2023-01-02 10:01:29 WARN i.a.m.l.MetricClientFactory(initialize):60 - Metric client is already initialized to 2023-01-02 10:01:29 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):50 - Using default value for environment variable LOG_CONNECTOR_MESSAGES: 'false' 2023-01-02 10:01:29 INFO i.a.w.g.DefaultReplicationWorker(run):122 - start sync worker. job id: 1334 attempt id: 0 2023-01-02 10:01:29 INFO i.a.w.g.DefaultReplicationWorker(run):135 - configured sync modes: {null.leads=full_refresh - overwrite} 2023-01-02 10:01:29 INFO i.a.w.i.DefaultAirbyteDestination(start):65 - Running destination... 2023-01-02 10:01:29 INFO i.a.c.i.LineGobbler(voidCall):114 - 2023-01-02 10:01:29 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- START REPLICATION ----- 2023-01-02 10:01:29 INFO i.a.c.i.LineGobbler(voidCall):114 - 2023-01-02 10:01:29 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/destination-redshift:0.3.50 exists... 2023-01-02 10:01:29 INFO i.a.w.p.DockerProcessFactory(create):119 - Creating docker container = destination-redshift-write-1334-0-eucoe with resources io.airbyte.config.ResourceRequirements@5274ca15[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] 2023-01-02 10:01:29 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/1334/0 --log-driver none --name destination-redshift-write-1334-0-eucoe --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_CONNECTOR_IMAGE=airbyte/destination-redshift:0.3.50 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_VERSION=0.40.11 -e WORKER_JOB_ID=1334 airbyte/destination-redshift:0.3.50 write --config destination_config.json --catalog destination_catalog.json 2023-01-02 10:01:29 INFO i.a.c.i.LineGobbler(voidCall):114 - airbyte/destination-redshift:0.3.50 was found locally. 2023-01-02 10:01:29 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/source-marketo:0.1.11 exists... 2023-01-02 10:01:29 INFO i.a.c.i.LineGobbler(voidCall):114 - airbyte/source-marketo:0.1.11 was found locally. 2023-01-02 10:01:29 INFO i.a.w.p.DockerProcessFactory(create):119 - Creating docker container = source-marketo-read-1334-0-kynuo with resources io.airbyte.config.ResourceRequirements@3c9e91c6[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] 2023-01-02 10:01:29 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/1334/0 --log-driver none --name source-marketo-read-1334-0-kynuo --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_CONNECTOR_IMAGE=airbyte/source-marketo:0.1.11 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_VERSION=0.40.11 -e WORKER_JOB_ID=1334 airbyte/source-marketo:0.1.11 read --config source_config.json --catalog source_catalog.json --state input_state.json 2023-01-02 10:01:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):435 - Destination output thread started. 2023-01-02 10:01:29 INFO i.a.w.g.DefaultReplicationWorker(run):177 - Waiting for source and destination threads to complete. 2023-01-02 10:01:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):322 - Replication thread started. 2023-01-02 10:01:31 source > Starting syncing SourceMarketo 2023-01-02 10:01:31 destination > starting destination: class io.airbyte.integrations.destination.redshift.RedshiftDestination 2023-01-02 10:01:31 destination > integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json} 2023-01-02 10:01:31 destination > Running integration: io.airbyte.integrations.destination.redshift.RedshiftDestination 2023-01-02 10:01:31 destination > Command: WRITE 2023-01-02 10:01:31 destination > Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'} 2023-01-02 10:01:31 destination > Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2023-01-02 10:01:31 destination > Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2023-01-02 10:01:31 destination > Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2023-01-02 10:01:31 destination > Using destination type: COPY_S3 2023-01-02 10:01:32 destination > HikariPool-1 - Starting... 2023-01-02 10:01:32 destination > HikariPool-1 - Start completed. 2023-01-02 10:01:32 destination > Creating S3 client... 2023-01-02 10:01:32 source > Syncing stream: leads 2023-01-02 10:01:32 destination > Write config: WriteConfig{streamName=marketo_leads, namespace=null, outputSchemaName=silver_third_party, tmpTableName=_airbyte_tmp_jva_marketo_leads, outputTableName=_airbyte_raw_marketo_leads, syncMode=overwrite} 2023-01-02 10:01:32 destination > class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started. 2023-01-02 10:01:32 destination > Preparing tmp tables in destination started for 1 streams 2023-01-02 10:01:32 destination > Preparing staging area in destination started for schema silver_third_party stream marketo_leads: tmp table: _airbyte_tmp_jva_marketo_leads, stage: airbyte_redshift/silver_third_party_marketo_leads/2023_01_02_10_4087c8eb-f8f4-43e9-b340-518bd6d798fb/ 2023-01-02 10:01:32 destination > HikariPool-1 - Driver does not support get/set network timeout for connections. ([Amazon][JDBC](10220) Driver does not support this optional feature.) 2023-01-02 10:01:33 source > Export leads from 2022-12-20T00:00:00Z to 2023-01-19T00:00:00Z status is Created 2023-01-02 10:01:34 destination > Storage Object disposable.sandbox.data.dashlane.com/airbyte_redshift/silver_third_party_marketo_leads does not exist in bucket; creating... 2023-01-02 10:01:34 destination > Storage Object disposable.sandbox.data.dashlane.com/airbyte_redshift/silver_third_party_marketo_leads has been created in bucket. 2023-01-02 10:01:34 destination > Preparing staging area in destination completed for schema silver_third_party stream marketo_leads 2023-01-02 10:01:34 destination > Preparing tmp tables in destination completed. 2023-01-02 10:02:34 source > Export leads from 2022-12-20T00:00:00Z to 2023-01-19T00:00:00Z status is Completed 2023-01-02 10:02:39 destination > Starting a new buffer for stream marketo_leads (current state: 0 bytes in 0 buffers) 2023-01-02 10:02:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 1000 (2 MB) 2023-01-02 10:02:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 2000 (4 MB) 2023-01-02 10:02:42 source > Encountered an exception while reading stream leads 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 "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/streams/http/http.py", line 428, in read_records yield from self.parse_response(response, stream_state=stream_state, stream_slice=stream_slice) File "/airbyte/integration_code/source_marketo/source.py", line 242, in parse_response value = format_value(value, prop) File "/airbyte/integration_code/source_marketo/utils.py", line 69, in format_value return int(value) ValueError: invalid literal for int() with base 10: 'Asia/Bangkok' 2023-01-02 10:02:42 source > Finished syncing leads 2023-01-02 10:02:42 source > SourceMarketo runtimes: Syncing stream leads 0:01:10.259221 2023-01-02 10:02:42 source > invalid literal for int() with base 10: 'Asia/Bangkok' 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 "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/streams/http/http.py", line 428, in read_records yield from self.parse_response(response, stream_state=stream_state, stream_slice=stream_slice) File "/airbyte/integration_code/source_marketo/source.py", line 242, in parse_response value = format_value(value, prop) File "/airbyte/integration_code/source_marketo/utils.py", line 69, in format_value return int(value) ValueError: invalid literal for int() with base 10: 'Asia/Bangkok' 2023-01-02 10:02:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):363 - Total records read: 2173 (5 MB) 2023-01-02 10:02:42 destination > Airbyte message consumer: succeeded. 2023-01-02 10:02:42 destination > executing on success close procedure. 2023-01-02 10:02:42 destination > Flushing all 1 current buffers (574 KB in total) 2023-01-02 10:02:42 destination > Flushing buffer of stream marketo_leads (574 KB) 2023-01-02 10:02:42 destination > Flushing buffer for stream marketo_leads (574 KB) to staging 2023-01-02 10:02:42 destination > Wrapping up compression and write GZIP trailer data. 2023-01-02 10:02:42 destination > Finished writing data to fd040390-d61c-445f-9d13-5f1fdcce72bf6572319805751330410.csv.gz (584 KB) 2023-01-02 10:02:42 destination > Initiated multipart upload to disposable.sandbox.data.dashlane.com/airbyte_redshift/silver_third_party_marketo_leads/2023_01_02_10_4087c8eb-f8f4-43e9-b340-518bd6d798fb/0.csv.gz with full ID VZE4SACsZr7dDY26wydC52GaAntun63xyLe9qV0oY9NbyLcJKc8vo1lrsPkTyIo3UqWX9YPOqijmKfSYaLzwWTosfQei4p3.94EQA3i5doi9iFUfZes2O_MJmdpwUUfT 2023-01-02 10:02:42 destination > Called close() on [MultipartOutputStream for parts 1 - 10000] 2023-01-02 10:02:42 destination > [Manager uploading to disposable.sandbox.data.dashlane.com/airbyte_redshift/silver_third_party_marketo_leads/2023_01_02_10_4087c8eb-f8f4-43e9-b340-518bd6d798fb/0.csv.gz with id VZE4SACsZ...JmdpwUUfT]: Uploading leftover stream [Part number 1 containing 0.57 MB] 2023-01-02 10:02:42 destination > [Manager uploading to disposable.sandbox.data.dashlane.com/airbyte_redshift/silver_third_party_marketo_leads/2023_01_02_10_4087c8eb-f8f4-43e9-b340-518bd6d798fb/0.csv.gz with id VZE4SACsZ...JmdpwUUfT]: Finished uploading [Part number 1 containing 0.57 MB] 2023-01-02 10:02:43 destination > [Manager uploading to disposable.sandbox.data.dashlane.com/airbyte_redshift/silver_third_party_marketo_leads/2023_01_02_10_4087c8eb-f8f4-43e9-b340-518bd6d798fb/0.csv.gz with id VZE4SACsZ...JmdpwUUfT]: Completed 2023-01-02 10:02:43 destination > Uploaded buffer file to storage: fd040390-d61c-445f-9d13-5f1fdcce72bf6572319805751330410.csv.gz -> airbyte_redshift/silver_third_party_marketo_leads/2023_01_02_10_4087c8eb-f8f4-43e9-b340-518bd6d798fb/0.csv.gz (filename: 0.csv.gz) 2023-01-02 10:02:43 destination > Deleting tempFile data fd040390-d61c-445f-9d13-5f1fdcce72bf6572319805751330410.csv.gz 2023-01-02 10:02:43 destination > Closing buffer for stream marketo_leads 2023-01-02 10:02:43 destination > Copying into tables in destination started for 1 streams 2023-01-02 10:02:43 destination > Copying stream marketo_leads of schema silver_third_party into tmp table _airbyte_tmp_jva_marketo_leads to final table _airbyte_raw_marketo_leads from stage path airbyte_redshift/silver_third_party_marketo_leads/2023_01_02_10_4087c8eb-f8f4-43e9-b340-518bd6d798fb/ with 1 file(s) [0.csv.gz] 2023-01-02 10:02:43 destination > Starting copy to tmp table from stage: _airbyte_tmp_jva_marketo_leads in destination from stage: airbyte_redshift/silver_third_party_marketo_leads/2023_01_02_10_4087c8eb-f8f4-43e9-b340-518bd6d798fb/, schema: silver_third_party, . 2023-01-02 10:02:45 destination > Copy to tmp table silver_third_party._airbyte_tmp_jva_marketo_leads in destination complete. 2023-01-02 10:02:46 destination > Executing operations for Redshift Destination DB engine... 2023-01-02 10:02:46 destination > Discovering NOT SUPER table types... 2023-01-02 10:02:46 destination > Executing operations for Redshift Destination DB engine completed. 2023-01-02 10:02:46 destination > Executing finalization of tables. 2023-01-02 10:02:47 destination > Finalizing tables in destination completed. 2023-01-02 10:02:47 destination > Cleaning up destination started for 1 streams 2023-01-02 10:02:47 destination > Cleaning tmp table in destination started for stream marketo_leads. schema silver_third_party, tmp table name: _airbyte_tmp_jva_marketo_leads 2023-01-02 10:02:48 destination > Cleaning stage in destination started for stream marketo_leads. schema silver_third_party, stage: silver_third_party_marketo_leads 2023-01-02 10:02:48 destination > Deleting objects airbyte_redshift/silver_third_party_marketo_leads/, airbyte_redshift/silver_third_party_marketo_leads/2023_01_02_10_4087c8eb-f8f4-43e9-b340-518bd6d798fb/0.csv.gz, airbyte_redshift/silver_third_party_marketo_leads/2023_01_02_10_4087c8eb-f8f4-43e9-b340-518bd6d798fb/2af05d8c-0231-4c52-b7cd-d443115bb81b.manifest 2023-01-02 10:02:48 destination > Storage bucket airbyte_redshift/silver_third_party_marketo_leads has been cleaned-up (3 objects were deleted)... 2023-01-02 10:02:48 destination > Cleaning up destination completed. 2023-01-02 10:02:48 destination > Completed integration: io.airbyte.integrations.destination.redshift.RedshiftDestination 2023-01-02 10:02:48 destination > completed destination: class io.airbyte.integrations.destination.redshift.RedshiftDestination 2023-01-02 10:02:48 ERROR i.a.w.g.DefaultReplicationWorker(run):188 - 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:181) ~[io.airbyte-airbyte-workers-0.40.11.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:68) ~[io.airbyte-airbyte-workers-0.40.11.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:161) ~[io.airbyte-airbyte-workers-0.40.11.jar:?] at java.lang.Thread.run(Thread.java:833) ~[?:?] 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-workers-0.40.11.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:145) ~[io.airbyte-airbyte-workers-0.40.11.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:68) ~[io.airbyte-airbyte-workers-0.40.11.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:161) ~[io.airbyte-airbyte-workers-0.40.11.jar:?] at java.lang.Thread.run(Thread.java:833) ~[?:?] 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:377) ~[io.airbyte-airbyte-workers-0.40.11.jar:?] at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ~[?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?] ... 1 more 2023-01-02 10:02:48 INFO i.a.w.g.DefaultReplicationWorker(run):281 - Source did not output any state messages 2023-01-02 10:02:48 WARN i.a.w.g.DefaultReplicationWorker(run):289 - State capture: No new state, falling back on input state: io.airbyte.config.State@3f73ad25[state={}] 2023-01-02 10:02:48 INFO i.a.w.g.DefaultReplicationWorker(run):300 - sync summary: { "status" : "failed", "recordsSynced" : 2172, "bytesSynced" : 5365702, "startTime" : 1672653689622, "endTime" : 1672653768775, "totalStats" : { "recordsEmitted" : 2172, "bytesEmitted" : 5365702, "sourceStateMessagesEmitted" : 0, "destinationStateMessagesEmitted" : 0, "recordsCommitted" : 0, "meanSecondsBeforeSourceStateMessageEmitted" : 0, "maxSecondsBeforeSourceStateMessageEmitted" : 0, "maxSecondsBetweenStateMessageEmittedandCommitted" : 0, "meanSecondsBetweenStateMessageEmittedandCommitted" : 0 }, "streamStats" : [ { "streamName" : "marketo_leads", "stats" : { "recordsEmitted" : 2172, "bytesEmitted" : 5365702 } } ] } 2023-01-02 10:02:48 INFO i.a.w.g.DefaultReplicationWorker(run):301 - failures: [ { "failureOrigin" : "source", "failureType" : "system_error", "internalMessage" : "invalid literal for int() with base 10: 'Asia/Bangkok'", "externalMessage" : "Something went wrong in the connector. See the logs for more details.", "metadata" : { "attemptNumber" : 0, "jobId" : 1334, "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 \"/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/streams/http/http.py\", line 428, in read_records\n yield from self.parse_response(response, stream_state=stream_state, stream_slice=stream_slice)\n File \"/airbyte/integration_code/source_marketo/source.py\", line 242, in parse_response\n value = format_value(value, prop)\n File \"/airbyte/integration_code/source_marketo/utils.py\", line 69, in format_value\n return int(value)\nValueError: invalid literal for int() with base 10: 'Asia/Bangkok'\n", "timestamp" : 1672653762388 }, { "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" : 1334, "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:1136)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)\n\tat java.base/java.lang.Thread.run(Thread.java:833)\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:377)\n\tat java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)\n\t... 3 more\n", "timestamp" : 1672653762629 } ] 2023-01-02 10:02:48 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling... 2023-01-02 10:02:48 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):157 - sync summary: io.airbyte.config.StandardSyncOutput@663769af[standardSyncSummary=io.airbyte.config.StandardSyncSummary@2335eb0d[status=failed,recordsSynced=2172,bytesSynced=5365702,startTime=1672653689622,endTime=1672653768775,totalStats=io.airbyte.config.SyncStats@3778cc4e[recordsEmitted=2172,bytesEmitted=5365702,sourceStateMessagesEmitted=0,destinationStateMessagesEmitted=0,recordsCommitted=0,meanSecondsBeforeSourceStateMessageEmitted=0,maxSecondsBeforeSourceStateMessageEmitted=0,maxSecondsBetweenStateMessageEmittedandCommitted=0,meanSecondsBetweenStateMessageEmittedandCommitted=0,additionalProperties={}],streamStats=[io.airbyte.config.StreamSyncStats@125c8ac6[streamName=marketo_leads,stats=io.airbyte.config.SyncStats@4ffbf333[recordsEmitted=2172,bytesEmitted=5365702,sourceStateMessagesEmitted=,destinationStateMessagesEmitted=,recordsCommitted=,meanSecondsBeforeSourceStateMessageEmitted=,maxSecondsBeforeSourceStateMessageEmitted=,maxSecondsBetweenStateMessageEmittedandCommitted=,meanSecondsBetweenStateMessageEmittedandCommitted=,additionalProperties={}]]]],normalizationSummary=,state=io.airbyte.config.State@3f73ad25[state={}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@431a1442[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@3271aad3[stream=io.airbyte.protocol.models.AirbyteStream@440d0ce1[name=marketo_leads,jsonSchema={"type":["object","null"],"properties":{"id":{"type":["integer","null"]},"fax":{"type":["string","null"]},"city":{"type":["string","null"]},"site":{"type":["string","null"]},"email":{"type":["string","null"]},"phone":{"type":["string","null"]},"state":{"type":["string","null"]},"title":{"type":["string","null"]},"isLead":{"type":["boolean","null"]},"rating":{"type":["string","null"]},"address":{"type":["string","null"]},"company":{"type":["string","null"]},"cookies":{"type":["string","null"]},"country":{"type":["string","null"]},"sicCode":{"type":["string","null"]},"urgency":{"type":["number","null"]},"website":{"type":["string","null"]},"industry":{"type":["string","null"]},"lastName":{"type":["string","null"]},"leadRole":{"type":["string","null"]},"mktoName":{"type":["string","null"]},"priority":{"type":["integer","null"]},"createdAt":{"type":["string","null"],"format":"date-time"},"doNotCall":{"type":["boolean","null"]},"firstName":{"type":["string","null"]},"leadScore":{"type":["integer","null"]},"mainPhone":{"type":["string","null"]},"updatedAt":{"type":["string","null"],"format":"date-time"},"department":{"type":["string","null"]},"leadPerson":{"type":["string","null"]},"leadSource":{"type":["string","null"]},"leadStatus":{"type":["string","null"]},"middleName":{"type":["string","null"]},"personType":{"type":["string","null"]},"postalCode":{"type":["string","null"]},"salutation":{"type":["string","null"]},"anonymousIP":{"type":["string","null"]},"billingCity":{"type":["string","null"]},"blackListed":{"type":["boolean","null"]},"dateOfBirth":{"type":["string","null"],"format":"date-time"},"isAnonymous":{"type":["boolean","null"]},"mobilePhone":{"type":["string","null"]},"billingState":{"type":["string","null"]},"emailInvalid":{"type":["boolean","null"]},"inferredCity":{"type":["string","null"]},"unsubscribed":{"type":["boolean","null"]},"annualRevenue":{"type":["number","null"]},"billingStreet":{"type":["string","null"]},"mktoIsPartner":{"type":["boolean","null"]},"relativeScore":{"type":["integer","null"]},"billingCountry":{"type":["string","null"]},"contactCompany":{"type":["string","null"]},"emailSuspended":{"type":["boolean","null"]},"mktoIsCustomer":{"type":["boolean","null"]},"personTimeZone":{"type":["string","null"]},"doNotCallReason":{"type":["string","null"]},"inferredCompany":{"type":["string","null"]},"inferredCountry":{"type":["string","null"]},"leadPartitionId":{"type":["string","null"]},"mktoPersonNotes":{"type":["string","null"]},"relativeUrgency":{"type":["integer","null"]},"blackListedCause":{"type":["string","null"]},"emailSuspendedAt":{"type":["string","null"],"format":"date-time"},"mktoCompanyNotes":{"type":["string","null"]},"originalReferrer":{"type":["string","null"]},"billingPostalCode":{"type":["string","null"]},"emailInvalidCause":{"type":["string","null"]},"externalCompanyId":{"type":["string","null"]},"numberOfEmployees":{"type":["integer","null"]},"inferredPostalCode":{"type":["string","null"]},"leadRevenueStageId":{"type":["string","null"]},"marketingSuspended":{"type":["boolean","null"]},"mktoDoNotCallCause":{"type":["string","null"]},"originalSourceInfo":{"type":["string","null"]},"originalSourceType":{"type":["string","null"]},"unsubscribedReason":{"type":["string","null"]},"emailSuspendedCause":{"type":["string","null"]},"inferredStateRegion":{"type":["string","null"]},"mktoAcquisitionDate":{"type":["string","null"],"format":"date-time"},"acquisitionProgramId":{"type":["string","null"]},"originalSearchEngine":{"type":["string","null"]},"originalSearchPhrase":{"type":["string","null"]},"externalSalesPersonId":{"type":["string","null"]},"inferredPhoneAreaCode":{"type":["string","null"]},"registrationSourceInfo":{"type":["string","null"]},"registrationSourceType":{"type":["string","null"]},"leadRevenueCycleModelId":{"type":["string","null"]},"marketingSuspendedCause":{"type":["string","null"]},"inferredMetropolitanArea":{"type":["string","null"]},"personPrimaryLeadInterest":{"type":["string","null"]}},"additionalProperties":true},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[updatedAt],sourceDefinedPrimaryKey=[[id]],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[updatedAt],destinationSyncMode=overwrite,primaryKey=[[id]],additionalProperties={}]],additionalProperties={}],failures=[io.airbyte.config.FailureReason@54ff1d38[failureOrigin=source,failureType=system_error,internalMessage=invalid literal for int() with base 10: 'Asia/Bangkok',externalMessage=Something went wrong in the connector. See the logs for more details.,metadata=io.airbyte.config.Metadata@4754abe1[additionalProperties={attemptNumber=0, jobId=1334, 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 "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/streams/http/http.py", line 428, in read_records yield from self.parse_response(response, stream_state=stream_state, stream_slice=stream_slice) File "/airbyte/integration_code/source_marketo/source.py", line 242, in parse_response value = format_value(value, prop) File "/airbyte/integration_code/source_marketo/utils.py", line 69, in format_value return int(value) ValueError: invalid literal for int() with base 10: 'Asia/Bangkok' ,retryable=,timestamp=1672653762388], io.airbyte.config.FailureReason@784cb6ea[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@548ad706[additionalProperties={attemptNumber=0, jobId=1334, 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:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at java.base/java.lang.Thread.run(Thread.java:833) Caused by: 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:377) at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ... 3 more ,retryable=,timestamp=1672653762629]]] 2023-01-02 10:02:48 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):162 - Sync summary length: 9205 2023-01-02 10:02:48 INFO i.a.c.t.TemporalUtils(withBackgroundHeartbeat):280 - Stopping temporal heartbeating... 2023-01-02 10:02:48 INFO i.a.c.i.LineGobbler(voidCall):114 - 2023-01-02 10:02:48 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- END REPLICATION ----- 2023-01-02 10:02:48 INFO i.a.c.i.LineGobbler(voidCall):114 - 2023-01-02 10:02:48 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):50 - Using default value for environment variable NEED_STATE_VALIDATION: 'true' 2023-01-02 10:02:48 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/1334/0/logs.log 2023-01-02 10:02:48 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.40.11 2023-01-02 10:02:48 INFO i.a.c.i.LineGobbler(voidCall):114 - 2023-01-02 10:02:48 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):134 - Running with normalization version: airbyte/normalization-redshift:0.2.22 2023-01-02 10:02:48 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- START DEFAULT NORMALIZATION ----- 2023-01-02 10:02:48 INFO i.a.c.i.LineGobbler(voidCall):114 - 2023-01-02 10:02:48 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/normalization-redshift:0.2.22 exists... 2023-01-02 10:02:49 INFO i.a.c.i.LineGobbler(voidCall):114 - airbyte/normalization-redshift:0.2.22 was found locally. 2023-01-02 10:02:49 INFO i.a.w.p.DockerProcessFactory(create):119 - Creating docker container = normalization-redshift-normalize-1334-0-qcvwr with resources io.airbyte.config.ResourceRequirements@5f978972[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] 2023-01-02 10:02:49 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/1334/0/normalize --log-driver none --name normalization-redshift-normalize-1334-0-qcvwr --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.40.11 airbyte/normalization-redshift:0.2.22 run --integration-type redshift --config destination_config.json --catalog destination_catalog.json 2023-01-02 10:02:49 normalization > Running: transform-config --config destination_config.json --integration-type redshift --out /data/1334/0/normalize 2023-01-02 10:02:49 normalization > Namespace(config='destination_config.json', integration_type=, out='/data/1334/0/normalize') 2023-01-02 10:02:49 normalization > transform_redshift 2023-01-02 10:02:49 normalization > Running: transform-catalog --integration-type redshift --profile-config-dir /data/1334/0/normalize --catalog destination_catalog.json --out /data/1334/0/normalize/models/generated/ --json-column _airbyte_data 2023-01-02 10:02:49 normalization > Processing destination_catalog.json... 2023-01-02 10:02:49 normalization > Generating airbyte_ctes/silver_third_party/marketo_leads_ab1.sql from marketo_leads 2023-01-02 10:02:49 normalization > Generating airbyte_ctes/silver_third_party/marketo_leads_ab2.sql from marketo_leads 2023-01-02 10:02:49 normalization > Generating airbyte_ctes/silver_third_party/marketo_leads_ab3.sql from marketo_leads 2023-01-02 10:02:49 normalization > Generating airbyte_tables/silver_third_party/marketo_leads.sql from marketo_leads 2023-01-02 10:02:49 normalization > detected no config file for ssh, assuming ssh is off. 2023-01-02 10:02:52 normalization > [--event-buffer-size EVENT_BUFFER_SIZE] 2023-01-02 10:02:52 normalization > --event-buffer-size EVENT_BUFFER_SIZE 2023-01-02 10:02:52 INFO i.a.w.n.NormalizationAirbyteStreamFactory(filterOutAndHandleNonAirbyteMessageLines):104 - 2023-01-02 10:02:52 normalization > DBT >=1.0.0 detected; using 10K event buffer size 2023-01-02 10:02:52 INFO i.a.w.n.NormalizationAirbyteStreamFactory(filterOutAndHandleNonAirbyteMessageLines):104 - 2023-01-02 10:02:54 normalization > Running with dbt=1.0.0 2023-01-02 10:02:54 normalization > Partial parse save file not found. Starting full parse. 2023-01-02 10:02:56 normalization > [WARNING]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources. There are 2 unused configuration paths: - models.airbyte_utils.generated.airbyte_incremental - models.airbyte_utils.generated.airbyte_views 2023-01-02 10:02:56 normalization > Found 4 models, 0 tests, 0 snapshots, 0 analyses, 605 macros, 0 operations, 0 seed files, 1 source, 0 exposures, 0 metrics 2023-01-02 10:02:56 normalization > Concurrency: 4 threads (target='prod') 2023-01-02 10:03:48 normalization > 1 of 1 START table model silver_third_party.marketo_leads............................................................... [RUN] 2023-01-02 10:03:56 normalization > 1 of 1 OK created table model silver_third_party.marketo_leads.......................................................... [SELECT in 7.47s] 2023-01-02 10:03:56 normalization > Finished running 1 table model in 59.62s. 2023-01-02 10:03:56 normalization > Completed successfully 2023-01-02 10:03:56 normalization > Done. PASS=1 WARN=0 ERROR=0 SKIP=0 TOTAL=1 2023-01-02 10:03:56 INFO i.a.w.g.DefaultNormalizationWorker(run):82 - Normalization executed in 1 minute 7 seconds. 2023-01-02 10:03:56 INFO i.a.w.g.DefaultNormalizationWorker(run):95 - Normalization summary: io.airbyte.config.NormalizationSummary@6e823676[startTime=1672653768986,endTime=1672653836284,failures=[]] 2023-01-02 10:03:56 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling... 2023-01-02 10:03:56 INFO i.a.c.t.TemporalUtils(withBackgroundHeartbeat):280 - Stopping temporal heartbeating... 2023-01-02 10:03:56 INFO i.a.c.i.LineGobbler(voidCall):114 - 2023-01-02 10:03:56 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- END DEFAULT NORMALIZATION ----- 2023-01-02 10:03:56 INFO i.a.c.i.LineGobbler(voidCall):114 -