2022-05-09 01:11:17 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.35.65-alpha
2022-05-09 01:11:17 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/7789/0/logs.log
2022-05-09 01:11:17 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.65-alpha
2022-05-09 01:11:17 INFO i.a.w.DefaultReplicationWorker(run):104 - start sync worker. job id: 7789 attempt id: 0
2022-05-09 01:11:17 INFO i.a.w.DefaultReplicationWorker(run):116 - configured sync modes: {null.activity_types=full_refresh - overwrite, null.programs=incremental - append_dedup, null.activities_change_data_value=incremental - append_dedup, null.leads=incremental - append_dedup, null.campaigns=incremental - append_dedup}
2022-05-09 01:11:17 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination...
2022-05-09 01:11:17 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-snowflake:0.4.25 exists...
2022-05-09 01:11:17 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-snowflake:0.4.25 was found locally.
2022-05-09 01:11:17 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 7789
2022-05-09 01:11:17 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/7789/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_CONNECTOR_IMAGE=airbyte/destination-snowflake:0.4.25 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.35.65-alpha -e WORKER_JOB_ID=7789 airbyte/destination-snowflake:0.4.25 write --config destination_config.json --catalog destination_catalog.json
2022-05-09 01:11:17 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-marketo:0.1.3 exists...
2022-05-09 01:11:17 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-marketo:0.1.3 was found locally.
2022-05-09 01:11:17 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 7789
2022-05-09 01:11:17 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/7789/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_CONNECTOR_IMAGE=airbyte/source-marketo:0.1.3 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.35.65-alpha -e WORKER_JOB_ID=7789 airbyte/source-marketo:0.1.3 read --config source_config.json --catalog source_catalog.json --state input_state.json
2022-05-09 01:11:17 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):339 - Destination output thread started.
2022-05-09 01:11:17 INFO i.a.w.DefaultReplicationWorker(run):158 - Waiting for source and destination threads to complete.
2022-05-09 01:11:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):279 - Replication thread started.
2022-05-09 01:11:18 destination > SLF4J: Class path contains multiple SLF4J bindings.
2022-05-09 01:11:18 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-05-09 01:11:18 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-05-09 01:11:18 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-05-09 01:11:18 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-05-09 01:11:19 source > Starting syncing SourceMarketo
2022-05-09 01:11:19 destination > 2022-05-09 01:11:19 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-05-09 01:11:19 destination > 2022-05-09 01:11:19 INFO i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-05-09 01:11:19 destination > 2022-05-09 01:11:19 INFO i.a.i.b.IntegrationRunner(runInternal):122 - Command: WRITE
2022-05-09 01:11:19 destination > 2022-05-09 01:11:19 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-05-09 01:11:20 destination > 2022-05-09 01:11:20 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-05-09 01:11:20 destination > 2022-05-09 01:11:20 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-05-09 01:11:20 destination > 2022-05-09 01:11:20 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-05-09 01:11:20 destination > 2022-05-09 01:11:20 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword multiline - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-05-09 01:11:20 destination > 2022-05-09 01:11:20 INFO i.a.i.d.j.c.SwitchingDestination(getConsumer):65 - Using destination type: INTERNAL_STAGING
2022-05-09 01:11:20 destination > 2022-05-09 01:11:20 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):99 - Write config: WriteConfig{streamName=activities_change_data_value, namespace=MARKETO, outputSchemaName=MARKETO, tmpTableName=_airbyte_tmp_wkb_activities_change_data_value, outputTableName=_airbyte_raw_activities_change_data_value, syncMode=append_dedup}
2022-05-09 01:11:20 destination > 2022-05-09 01:11:20 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):99 - Write config: WriteConfig{streamName=activity_types, namespace=MARKETO, outputSchemaName=MARKETO, tmpTableName=_airbyte_tmp_irw_activity_types, outputTableName=_airbyte_raw_activity_types, syncMode=overwrite}
2022-05-09 01:11:20 destination > 2022-05-09 01:11:20 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):99 - Write config: WriteConfig{streamName=campaigns, namespace=MARKETO, outputSchemaName=MARKETO, tmpTableName=_airbyte_tmp_kcy_campaigns, outputTableName=_airbyte_raw_campaigns, syncMode=append_dedup}
2022-05-09 01:11:20 destination > 2022-05-09 01:11:20 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):99 - Write config: WriteConfig{streamName=leads, namespace=MARKETO, outputSchemaName=MARKETO, tmpTableName=_airbyte_tmp_syl_leads, outputTableName=_airbyte_raw_leads, syncMode=append_dedup}
2022-05-09 01:11:20 destination > 2022-05-09 01:11:20 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):99 - Write config: WriteConfig{streamName=programs, namespace=MARKETO, outputSchemaName=MARKETO, tmpTableName=_airbyte_tmp_yjy_programs, outputTableName=_airbyte_raw_programs, syncMode=append_dedup}
2022-05-09 01:11:20 source > Syncing stream: activities_change_data_value 
2022-05-09 01:11:20 source > Setting state of activities_change_data_value stream to {'activityDate': '2022-05-08T02:52:31Z'}
2022-05-09 01:11:20 destination > 2022-05-09 01:11:20 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-05-09 01:11:20 destination > 2022-05-09 01:11:20 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):117 - Preparing tmp tables in destination started for 5 streams
2022-05-09 01:11:20 destination > 2022-05-09 01:11:20 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):125 - Preparing staging area in destination started for schema MARKETO stream activities_change_data_value: tmp table: _airbyte_tmp_wkb_activities_change_data_value, stage: 2022/05/09/01/573662A5-8424-4198-9EA1-896135465D7E/
2022-05-09 01:11:20 destination > 2022-05-09 01:11:20 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting...
2022-05-09 01:11:21 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Created
2022-05-09 01:11:21 destination > 2022-05-09 01:11:21 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@1d50a7ca
2022-05-09 01:11:21 destination > 2022-05-09 01:11:21 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed.
2022-05-09 01:11:21 destination > 2022-05-09 01:11:21 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection
2022-05-09 01:11:22 destination > 2022-05-09 01:11:22 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing staging area in destination completed for schema MARKETO stream activities_change_data_value
2022-05-09 01:11:22 destination > 2022-05-09 01:11:22 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):125 - Preparing staging area in destination started for schema MARKETO stream activity_types: tmp table: _airbyte_tmp_irw_activity_types, stage: 2022/05/09/01/573662A5-8424-4198-9EA1-896135465D7E/
2022-05-09 01:11:22 destination > 2022-05-09 01:11:22 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection
2022-05-09 01:11:22 destination > 2022-05-09 01:11:22 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing staging area in destination completed for schema MARKETO stream activity_types
2022-05-09 01:11:22 destination > 2022-05-09 01:11:22 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):125 - Preparing staging area in destination started for schema MARKETO stream campaigns: tmp table: _airbyte_tmp_kcy_campaigns, stage: 2022/05/09/01/573662A5-8424-4198-9EA1-896135465D7E/
2022-05-09 01:11:22 destination > 2022-05-09 01:11:22 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection
2022-05-09 01:11:22 destination > 2022-05-09 01:11:22 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing staging area in destination completed for schema MARKETO stream campaigns
2022-05-09 01:11:22 destination > 2022-05-09 01:11:22 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):125 - Preparing staging area in destination started for schema MARKETO stream leads: tmp table: _airbyte_tmp_syl_leads, stage: 2022/05/09/01/573662A5-8424-4198-9EA1-896135465D7E/
2022-05-09 01:11:23 destination > 2022-05-09 01:11:23 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection
2022-05-09 01:11:23 destination > 2022-05-09 01:11:23 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing staging area in destination completed for schema MARKETO stream leads
2022-05-09 01:11:23 destination > 2022-05-09 01:11:23 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):125 - Preparing staging area in destination started for schema MARKETO stream programs: tmp table: _airbyte_tmp_yjy_programs, stage: 2022/05/09/01/573662A5-8424-4198-9EA1-896135465D7E/
2022-05-09 01:11:23 destination > 2022-05-09 01:11:23 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection
2022-05-09 01:11:23 destination > 2022-05-09 01:11:23 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing staging area in destination completed for schema MARKETO stream programs
2022-05-09 01:11:23 destination > 2022-05-09 01:11:23 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):139 - Preparing tmp tables in destination completed.
2022-05-09 01:12:21 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:13:22 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:14:22 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:15:22 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:16:23 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:17:23 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:18:23 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:19:24 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:20:24 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:21:25 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:22:25 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:23:25 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:24:26 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:25:26 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:26:26 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:27:27 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:28:27 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:29:27 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:30:28 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:31:28 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:32:28 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:33:29 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:34:29 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:35:30 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:36:30 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:37:30 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:38:31 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:39:31 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:40:31 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:41:32 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:42:32 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:43:33 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:44:33 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:45:33 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:46:34 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:47:34 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:48:34 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:49:35 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:50:35 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:51:35 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:52:36 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:53:36 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:54:37 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:55:37 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:56:37 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:57:38 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:58:38 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 01:59:38 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:00:39 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:01:39 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:02:39 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:03:40 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:04:40 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:05:40 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:06:41 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:07:41 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:08:42 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:09:42 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:10:42 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:11:43 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:12:43 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:13:44 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:14:44 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:15:44 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:16:45 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:17:45 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:18:45 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:19:46 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:20:46 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:21:46 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:22:47 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:23:47 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:24:48 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:25:48 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:26:48 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:27:49 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:28:49 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:29:49 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:30:50 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:31:50 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:32:50 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:33:51 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:34:51 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:35:51 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:36:52 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:37:52 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:38:53 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:39:53 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:40:53 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:41:54 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:42:54 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:43:54 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:44:55 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:45:55 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Queued
2022-05-09 02:46:56 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Processing
2022-05-09 02:47:56 source > Export activities_change_data_value from 2022-05-08T02:52:31Z to 2022-06-07T02:52:31Z status is Completed
2022-05-09 02:47:58 destination > 2022-05-09 02:47:58 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):55 - Starting a new buffer for stream activities_change_data_value (current state: 0 bytes in 0 buffers)
2022-05-09 02:47:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1000 (314 KB)
2022-05-09 02:47:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 2000 (647 KB)
2022-05-09 02:47:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 3000 (978 KB)
2022-05-09 02:48:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 4000 (1 MB)
2022-05-09 02:48:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 5000 (1 MB)
2022-05-09 02:48:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 6000 (1 MB)
2022-05-09 02:48:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 7000 (2 MB)
2022-05-09 02:48:01 source > Setting state of activities_change_data_value stream to {'activityDate': '2022-05-09T02:45:38Z'}
2022-05-09 02:48:01 source > Read 7356 records from activities_change_data_value stream
2022-05-09 02:48:01 source > Finished syncing SourceMarketo
2022-05-09 02:48:01 source > SourceMarketo runtimes:

2022-05-09 02:48:01 source > Syncing stream: activity_types 
2022-05-09 02:48:01 destination > 2022-05-09 02:48:01 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):55 - Starting a new buffer for stream activity_types (current state: 351 KB in 1 buffers)
2022-05-09 02:48:01 source > Read 70 records from activity_types stream
2022-05-09 02:48:01 source > Finished syncing SourceMarketo
2022-05-09 02:48:01 source > SourceMarketo runtimes:

2022-05-09 02:48:01 source > Syncing stream: campaigns 
2022-05-09 02:48:01 source > Setting state of campaigns stream to {'createdAt': '2022-05-06T20:08:05Z'}
2022-05-09 02:48:04 source > Setting state of campaigns stream to {'createdAt': '2022-05-06T20:08:05Z'}
2022-05-09 02:48:04 source > Read 2 records from campaigns stream
2022-05-09 02:48:04 source > Finished syncing SourceMarketo
2022-05-09 02:48:04 source > SourceMarketo runtimes:

2022-05-09 02:48:04 source > Syncing stream: leads 
2022-05-09 02:48:04 source > Setting state of leads stream to {'updatedAt': '2022-05-08T03:14:26Z'}
2022-05-09 02:48:05 source > Export leads from 2022-05-08T03:14:26Z to 2022-06-07T03:14:26Z status is Created
2022-05-09 02:49:06 source > Export leads from 2022-05-08T03:14:26Z to 2022-06-07T03:14:26Z status is Queued
2022-05-09 02:50:06 source > Export leads from 2022-05-08T03:14:26Z to 2022-06-07T03:14:26Z status is Queued
2022-05-09 02:51:06 source > Export leads from 2022-05-08T03:14:26Z to 2022-06-07T03:14:26Z status is Queued
2022-05-09 02:52:07 source > Export leads from 2022-05-08T03:14:26Z to 2022-06-07T03:14:26Z status is Queued
2022-05-09 02:53:07 source > Export leads from 2022-05-08T03:14:26Z to 2022-06-07T03:14:26Z status is Queued
2022-05-09 02:54:07 source > Export leads from 2022-05-08T03:14:26Z to 2022-06-07T03:14:26Z status is Queued
2022-05-09 02:55:08 source > Export leads from 2022-05-08T03:14:26Z to 2022-06-07T03:14:26Z status is Queued
2022-05-09 02:56:08 source > Export leads from 2022-05-08T03:14:26Z to 2022-06-07T03:14:26Z status is Queued
2022-05-09 02:57:09 source > Export leads from 2022-05-08T03:14:26Z to 2022-06-07T03:14:26Z status is Queued
2022-05-09 02:58:09 source > Export leads from 2022-05-08T03:14:26Z to 2022-06-07T03:14:26Z status is Queued
2022-05-09 02:59:09 source > Export leads from 2022-05-08T03:14:26Z to 2022-06-07T03:14:26Z status is Queued
2022-05-09 03:00:10 source > Export leads from 2022-05-08T03:14:26Z to 2022-06-07T03:14:26Z status is Queued
2022-05-09 03:01:10 source > Export leads from 2022-05-08T03:14:26Z to 2022-06-07T03:14:26Z status is Queued
2022-05-09 03:02:10 source > Export leads from 2022-05-08T03:14:26Z to 2022-06-07T03:14:26Z status is Queued
2022-05-09 03:03:11 source > Export leads from 2022-05-08T03:14:26Z to 2022-06-07T03:14:26Z status is Queued
2022-05-09 03:04:11 source > Export leads from 2022-05-08T03:14:26Z to 2022-06-07T03:14:26Z status is Queued
2022-05-09 03:05:11 source > Export leads from 2022-05-08T03:14:26Z to 2022-06-07T03:14:26Z status is Queued
2022-05-09 03:06:12 source > Export leads from 2022-05-08T03:14:26Z to 2022-06-07T03:14:26Z status is Queued
2022-05-09 03:07:12 source > Export leads from 2022-05-08T03:14:26Z to 2022-06-07T03:14:26Z status is Queued
2022-05-09 03:08:13 source > Export leads from 2022-05-08T03:14:26Z to 2022-06-07T03:14:26Z status is Queued
2022-05-09 03:09:13 source > Export leads from 2022-05-08T03:14:26Z to 2022-06-07T03:14:26Z status is Queued
2022-05-09 03:10:13 source > Export leads from 2022-05-08T03:14:26Z to 2022-06-07T03:14:26Z status is Queued
2022-05-09 03:11:14 source > Export leads from 2022-05-08T03:14:26Z to 2022-06-07T03:14:26Z status is Queued
2022-05-09 03:12:14 source > Export leads from 2022-05-08T03:14:26Z to 2022-06-07T03:14:26Z status is Queued
2022-05-09 03:13:15 source > Export leads from 2022-05-08T03:14:26Z to 2022-06-07T03:14:26Z status is Queued
2022-05-09 03:14:15 source > Export leads from 2022-05-08T03:14:26Z to 2022-06-07T03:14:26Z status is Completed
2022-05-09 03:14:16 destination > 2022-05-09 03:14:16 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):55 - Starting a new buffer for stream campaigns (current state: 351 KB in 2 buffers)
2022-05-09 03:14:16 destination > 2022-05-09 03:14:16 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):55 - Starting a new buffer for stream leads (current state: 351 KB in 3 buffers)
2022-05-09 03:14:16 source > Setting state of leads stream to {'updatedAt': '2022-05-09T03:09:10Z'}
2022-05-09 03:14:16 source > Read 59 records from leads stream
2022-05-09 03:14:16 source > Finished syncing SourceMarketo
2022-05-09 03:14:16 source > SourceMarketo runtimes:

2022-05-09 03:14:16 source > Syncing stream: programs 
2022-05-09 03:14:16 source > Setting state of programs stream to {'updatedAt': '2022-05-06T21:28:38Z'}
2022-05-09 03:14:16 source > Setting state of programs stream to {'updatedAt': '2022-05-06T21:28:38Z'}
2022-05-09 03:14:16 source > Read 1 records from programs stream
2022-05-09 03:14:16 source > Finished syncing SourceMarketo
2022-05-09 03:14:16 source > SourceMarketo runtimes:

2022-05-09 03:14:16 source > Finished syncing SourceMarketo
2022-05-09 03:14:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):305 - Total records read: 7492 (2 MB)
2022-05-09 03:14:17 INFO i.a.w.DefaultReplicationWorker(run):163 - One of source or destination thread complete. Waiting on the other.
2022-05-09 03:14:17 destination > 2022-05-09 03:14:17 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):55 - Starting a new buffer for stream programs (current state: 351 KB in 4 buffers)
2022-05-09 03:14:17 destination > 2022-05-09 03:14:17 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded.
2022-05-09 03:14:17 destination > 2022-05-09 03:14:17 INFO i.a.i.d.b.BufferedStreamConsumer(close):170 - executing on success close procedure.
2022-05-09 03:14:17 destination > 2022-05-09 03:14:17 INFO i.a.i.d.r.SerializedBufferingStrategy(flushAll):92 - Flushing all 5 current buffers (351 KB in total)
2022-05-09 03:14:17 destination > 2022-05-09 03:14:17 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$flushAll$2):95 - Flushing buffer of stream leads (10 bytes)
2022-05-09 03:14:17 destination > 2022-05-09 03:14:17 INFO i.a.i.d.s.StagingConsumerFactory(lambda$flushBufferFunction$3):158 - Flushing buffer for stream leads (10 bytes) to staging
2022-05-09 03:14:17 destination > 2022-05-09 03:14:17 INFO i.a.i.d.r.BaseSerializedBuffer(flush):131 - Wrapping up compression and write GZIP trailer data.
2022-05-09 03:14:17 destination > 2022-05-09 03:14:17 INFO i.a.i.d.r.BaseSerializedBuffer(flush):138 - Finished writing data to 7cb41c5d-dbae-4244-b4f0-e33423306fad11892658469323342931.csv.gz (12 KB)
2022-05-09 03:14:18 destination > 2022-05-09 03:14:18 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection
2022-05-09 03:14:18 destination > 2022-05-09 03:14:18 INFO i.a.i.d.r.FileBuffer(deleteFile):81 - Deleting tempFile data 7cb41c5d-dbae-4244-b4f0-e33423306fad11892658469323342931.csv.gz
2022-05-09 03:14:18 destination > 2022-05-09 03:14:18 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$flushAll$2):95 - Flushing buffer of stream activity_types (10 bytes)
2022-05-09 03:14:18 destination > 2022-05-09 03:14:18 INFO i.a.i.d.s.StagingConsumerFactory(lambda$flushBufferFunction$3):158 - Flushing buffer for stream activity_types (10 bytes) to staging
2022-05-09 03:14:18 destination > 2022-05-09 03:14:18 INFO i.a.i.d.r.BaseSerializedBuffer(flush):131 - Wrapping up compression and write GZIP trailer data.
2022-05-09 03:14:18 destination > 2022-05-09 03:14:18 INFO i.a.i.d.r.BaseSerializedBuffer(flush):138 - Finished writing data to 6c36f965-c33c-4412-b85b-d5cbe5166e944548243680040606417.csv.gz (5 KB)
2022-05-09 03:14:18 destination > 2022-05-09 03:14:18 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection
2022-05-09 03:14:18 destination > 2022-05-09 03:14:18 INFO i.a.i.d.r.FileBuffer(deleteFile):81 - Deleting tempFile data 6c36f965-c33c-4412-b85b-d5cbe5166e944548243680040606417.csv.gz
2022-05-09 03:14:18 destination > 2022-05-09 03:14:18 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$flushAll$2):95 - Flushing buffer of stream programs (10 bytes)
2022-05-09 03:14:18 destination > 2022-05-09 03:14:18 INFO i.a.i.d.s.StagingConsumerFactory(lambda$flushBufferFunction$3):158 - Flushing buffer for stream programs (10 bytes) to staging
2022-05-09 03:14:18 destination > 2022-05-09 03:14:18 INFO i.a.i.d.r.BaseSerializedBuffer(flush):131 - Wrapping up compression and write GZIP trailer data.
2022-05-09 03:14:18 destination > 2022-05-09 03:14:18 INFO i.a.i.d.r.BaseSerializedBuffer(flush):138 - Finished writing data to e625a127-cb68-4ed4-bc2a-e3bb847399f17004175165195743680.csv.gz (340 bytes)
2022-05-09 03:14:18 destination > 2022-05-09 03:14:18 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection
2022-05-09 03:14:18 destination > 2022-05-09 03:14:18 INFO i.a.i.d.r.FileBuffer(deleteFile):81 - Deleting tempFile data e625a127-cb68-4ed4-bc2a-e3bb847399f17004175165195743680.csv.gz
2022-05-09 03:14:18 destination > 2022-05-09 03:14:18 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$flushAll$2):95 - Flushing buffer of stream activities_change_data_value (351 KB)
2022-05-09 03:14:18 destination > 2022-05-09 03:14:18 INFO i.a.i.d.s.StagingConsumerFactory(lambda$flushBufferFunction$3):158 - Flushing buffer for stream activities_change_data_value (351 KB) to staging
2022-05-09 03:14:18 destination > 2022-05-09 03:14:18 INFO i.a.i.d.r.BaseSerializedBuffer(flush):131 - Wrapping up compression and write GZIP trailer data.
2022-05-09 03:14:18 destination > 2022-05-09 03:14:18 INFO i.a.i.d.r.BaseSerializedBuffer(flush):138 - Finished writing data to 7c36e011-306f-4ab5-851e-5e0ed58cc8fe11294557498687379379.csv.gz (361 KB)
2022-05-09 03:14:19 destination > 2022-05-09 03:14:19 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection
2022-05-09 03:14:19 destination > 2022-05-09 03:14:19 INFO i.a.i.d.r.FileBuffer(deleteFile):81 - Deleting tempFile data 7c36e011-306f-4ab5-851e-5e0ed58cc8fe11294557498687379379.csv.gz
2022-05-09 03:14:19 destination > 2022-05-09 03:14:19 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$flushAll$2):95 - Flushing buffer of stream campaigns (10 bytes)
2022-05-09 03:14:19 destination > 2022-05-09 03:14:19 INFO i.a.i.d.s.StagingConsumerFactory(lambda$flushBufferFunction$3):158 - Flushing buffer for stream campaigns (10 bytes) to staging
2022-05-09 03:14:19 destination > 2022-05-09 03:14:19 INFO i.a.i.d.r.BaseSerializedBuffer(flush):131 - Wrapping up compression and write GZIP trailer data.
2022-05-09 03:14:19 destination > 2022-05-09 03:14:19 INFO i.a.i.d.r.BaseSerializedBuffer(flush):138 - Finished writing data to 4bb4a893-087a-47ef-89a3-af6bfdd3fc497687061344328597104.csv.gz (343 bytes)
2022-05-09 03:14:19 destination > 2022-05-09 03:14:19 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection
2022-05-09 03:14:19 destination > 2022-05-09 03:14:19 INFO i.a.i.d.r.FileBuffer(deleteFile):81 - Deleting tempFile data 4bb4a893-087a-47ef-89a3-af6bfdd3fc497687061344328597104.csv.gz
2022-05-09 03:14:19 destination > 2022-05-09 03:14:19 INFO i.a.i.d.r.SerializedBufferingStrategy(close):119 - Closing buffer for stream leads
2022-05-09 03:14:19 destination > 2022-05-09 03:14:19 INFO i.a.i.d.r.SerializedBufferingStrategy(close):119 - Closing buffer for stream activity_types
2022-05-09 03:14:19 destination > 2022-05-09 03:14:19 INFO i.a.i.d.r.SerializedBufferingStrategy(close):119 - Closing buffer for stream programs
2022-05-09 03:14:19 destination > 2022-05-09 03:14:19 INFO i.a.i.d.r.SerializedBufferingStrategy(close):119 - Closing buffer for stream activities_change_data_value
2022-05-09 03:14:19 destination > 2022-05-09 03:14:19 INFO i.a.i.d.r.SerializedBufferingStrategy(close):119 - Closing buffer for stream campaigns
2022-05-09 03:14:19 destination > 2022-05-09 03:14:19 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):186 - Copying into tables in destination started for 5 streams
2022-05-09 03:14:19 destination > 2022-05-09 03:14:19 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):195 - Copying stream activities_change_data_value of schema MARKETO into tmp table _airbyte_tmp_wkb_activities_change_data_value to final table _airbyte_raw_activities_change_data_value from stage path 2022/05/09/01/573662A5-8424-4198-9EA1-896135465D7E/ with 1 file(s) [7c36e011-306f-4ab5-851e-5e0ed58cc8fe11294557498687379379.csv.gz]
2022-05-09 03:14:21 destination > 2022-05-09 03:14:21 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):195 - Copying stream activity_types of schema MARKETO into tmp table _airbyte_tmp_irw_activity_types to final table _airbyte_raw_activity_types from stage path 2022/05/09/01/573662A5-8424-4198-9EA1-896135465D7E/ with 1 file(s) [6c36f965-c33c-4412-b85b-d5cbe5166e944548243680040606417.csv.gz]
2022-05-09 03:14:22 destination > 2022-05-09 03:14:22 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):195 - Copying stream campaigns of schema MARKETO into tmp table _airbyte_tmp_kcy_campaigns to final table _airbyte_raw_campaigns from stage path 2022/05/09/01/573662A5-8424-4198-9EA1-896135465D7E/ with 1 file(s) [4bb4a893-087a-47ef-89a3-af6bfdd3fc497687061344328597104.csv.gz]
2022-05-09 03:14:23 destination > 2022-05-09 03:14:23 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):195 - Copying stream leads of schema MARKETO into tmp table _airbyte_tmp_syl_leads to final table _airbyte_raw_leads from stage path 2022/05/09/01/573662A5-8424-4198-9EA1-896135465D7E/ with 1 file(s) [7cb41c5d-dbae-4244-b4f0-e33423306fad11892658469323342931.csv.gz]
2022-05-09 03:14:24 destination > 2022-05-09 03:14:24 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):195 - Copying stream programs of schema MARKETO into tmp table _airbyte_tmp_yjy_programs to final table _airbyte_raw_programs from stage path 2022/05/09/01/573662A5-8424-4198-9EA1-896135465D7E/ with 1 file(s) [e625a127-cb68-4ed4-bc2a-e3bb847399f17004175165195743680.csv.gz]
2022-05-09 03:14:25 destination > 2022-05-09 03:14:25 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):217 - Executing finalization of tables.
2022-05-09 03:14:31 destination > 2022-05-09 03:14:31 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):219 - Finalizing tables in destination completed.
2022-05-09 03:14:31 destination > 2022-05-09 03:14:31 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):221 - Cleaning up destination started for 5 streams
2022-05-09 03:14:31 destination > 2022-05-09 03:14:31 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):225 - Cleaning tmp table in destination started for stream activities_change_data_value. schema MARKETO, tmp table name: _airbyte_tmp_wkb_activities_change_data_value
2022-05-09 03:14:31 destination > 2022-05-09 03:14:31 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):231 - Cleaning stage in destination started for stream activities_change_data_value. schema MARKETO, stage: MARKETO_ACTIVITIES_CHANGE_DATA_VALUE
2022-05-09 03:14:31 destination > 2022-05-09 03:14:31 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):225 - Cleaning tmp table in destination started for stream activity_types. schema MARKETO, tmp table name: _airbyte_tmp_irw_activity_types
2022-05-09 03:14:31 destination > 2022-05-09 03:14:31 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):231 - Cleaning stage in destination started for stream activity_types. schema MARKETO, stage: MARKETO_ACTIVITY_TYPES
2022-05-09 03:14:31 destination > 2022-05-09 03:14:31 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):225 - Cleaning tmp table in destination started for stream campaigns. schema MARKETO, tmp table name: _airbyte_tmp_kcy_campaigns
2022-05-09 03:14:31 destination > 2022-05-09 03:14:31 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):231 - Cleaning stage in destination started for stream campaigns. schema MARKETO, stage: MARKETO_CAMPAIGNS
2022-05-09 03:14:31 destination > 2022-05-09 03:14:31 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):225 - Cleaning tmp table in destination started for stream leads. schema MARKETO, tmp table name: _airbyte_tmp_syl_leads
2022-05-09 03:14:31 destination > 2022-05-09 03:14:31 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):231 - Cleaning stage in destination started for stream leads. schema MARKETO, stage: MARKETO_LEADS
2022-05-09 03:14:31 destination > 2022-05-09 03:14:31 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):225 - Cleaning tmp table in destination started for stream programs. schema MARKETO, tmp table name: _airbyte_tmp_yjy_programs
2022-05-09 03:14:32 destination > 2022-05-09 03:14:32 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):231 - Cleaning stage in destination started for stream programs. schema MARKETO, stage: MARKETO_PROGRAMS
2022-05-09 03:14:32 destination > 2022-05-09 03:14:32 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):236 - Cleaning up destination completed.
2022-05-09 03:14:32 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):349 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@5f4cf412[type=STATE,log=<null>,spec=<null>,connectionStatus=<null>,catalog=<null>,record=<null>,state=io.airbyte.protocol.models.AirbyteStateMessage@518b118b[data={"leads":{"updatedAt":"2022-05-09T03:09:10Z"},"programs":{"updatedAt":"2022-05-06T21:28:38Z"},"campaigns":{"createdAt":"2022-05-06T20:08:05Z"},"activities_change_data_value":{"activityDate":"2022-05-09T02:45:38Z"}},additionalProperties={}],additionalProperties={}]
2022-05-09 03:14:32 destination > 2022-05-09 03:14:32 INFO i.a.i.b.IntegrationRunner(runInternal):169 - Completed integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-05-09 03:14:33 INFO i.a.w.DefaultReplicationWorker(run):165 - Source and destination threads complete.
2022-05-09 03:14:33 INFO i.a.w.DefaultReplicationWorker(run):228 - sync summary: io.airbyte.config.ReplicationAttemptSummary@6a814d28[status=completed,recordsSynced=7488,bytesSynced=2615157,startTime=1652058677867,endTime=1652066073631,totalStats=io.airbyte.config.SyncStats@40336468[recordsEmitted=7488,bytesEmitted=2615157,stateMessagesEmitted=4,recordsCommitted=7488],streamStats=[io.airbyte.config.StreamSyncStats@30f27f32[streamName=campaigns,stats=io.airbyte.config.SyncStats@552c125b[recordsEmitted=2,bytesEmitted=548,stateMessagesEmitted=<null>,recordsCommitted=2]], io.airbyte.config.StreamSyncStats@35a4eddb[streamName=activities_change_data_value,stats=io.airbyte.config.SyncStats@6e6fcf23[recordsEmitted=7356,bytesEmitted=2460659,stateMessagesEmitted=<null>,recordsCommitted=7356]], io.airbyte.config.StreamSyncStats@4dc72633[streamName=leads,stats=io.airbyte.config.SyncStats@78cc4b1a[recordsEmitted=59,bytesEmitted=128179,stateMessagesEmitted=<null>,recordsCommitted=59]], io.airbyte.config.StreamSyncStats@6a94bbed[streamName=activity_types,stats=io.airbyte.config.SyncStats@7a92674b[recordsEmitted=70,bytesEmitted=25376,stateMessagesEmitted=<null>,recordsCommitted=70]], io.airbyte.config.StreamSyncStats@e903094[streamName=programs,stats=io.airbyte.config.SyncStats@141e3ec7[recordsEmitted=1,bytesEmitted=395,stateMessagesEmitted=<null>,recordsCommitted=1]]]]
2022-05-09 03:14:33 INFO i.a.w.DefaultReplicationWorker(run):248 - Source output at least one state message
2022-05-09 03:14:33 INFO i.a.w.DefaultReplicationWorker(run):254 - State capture: Updated state to: Optional[io.airbyte.config.State@5b1aa47a[state={"leads":{"updatedAt":"2022-05-09T03:09:10Z"},"programs":{"updatedAt":"2022-05-06T21:28:38Z"},"campaigns":{"createdAt":"2022-05-06T20:08:05Z"},"activities_change_data_value":{"activityDate":"2022-05-09T02:45:38Z"}}]]
2022-05-09 03:14:33 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-05-09 03:14:33 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$1):147 - sync summary: io.airbyte.config.StandardSyncOutput@63521c40[standardSyncSummary=io.airbyte.config.StandardSyncSummary@5e7a2bfe[status=completed,recordsSynced=7488,bytesSynced=2615157,startTime=1652058677867,endTime=1652066073631,totalStats=io.airbyte.config.SyncStats@40336468[recordsEmitted=7488,bytesEmitted=2615157,stateMessagesEmitted=4,recordsCommitted=7488],streamStats=[io.airbyte.config.StreamSyncStats@30f27f32[streamName=campaigns,stats=io.airbyte.config.SyncStats@552c125b[recordsEmitted=2,bytesEmitted=548,stateMessagesEmitted=<null>,recordsCommitted=2]], io.airbyte.config.StreamSyncStats@35a4eddb[streamName=activities_change_data_value,stats=io.airbyte.config.SyncStats@6e6fcf23[recordsEmitted=7356,bytesEmitted=2460659,stateMessagesEmitted=<null>,recordsCommitted=7356]], io.airbyte.config.StreamSyncStats@4dc72633[streamName=leads,stats=io.airbyte.config.SyncStats@78cc4b1a[recordsEmitted=59,bytesEmitted=128179,stateMessagesEmitted=<null>,recordsCommitted=59]], io.airbyte.config.StreamSyncStats@6a94bbed[streamName=activity_types,stats=io.airbyte.config.SyncStats@7a92674b[recordsEmitted=70,bytesEmitted=25376,stateMessagesEmitted=<null>,recordsCommitted=70]], io.airbyte.config.StreamSyncStats@e903094[streamName=programs,stats=io.airbyte.config.SyncStats@141e3ec7[recordsEmitted=1,bytesEmitted=395,stateMessagesEmitted=<null>,recordsCommitted=1]]]],state=io.airbyte.config.State@5b1aa47a[state={"leads":{"updatedAt":"2022-05-09T03:09:10Z"},"programs":{"updatedAt":"2022-05-06T21:28:38Z"},"campaigns":{"createdAt":"2022-05-06T20:08:05Z"},"activities_change_data_value":{"activityDate":"2022-05-09T02:45:38Z"}}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@1b9d0dd0[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@f709b9e[stream=io.airbyte.protocol.models.AirbyteStream@7cb3262c[name=activities_change_data_value,jsonSchema={"type":["null","object"],"$schema":"http://json-schema.org/draft-07/schema#","properties":{"leadId":{"type":["null","integer"]},"reason":{"type":["string","null"]},"source":{"type":["string","null"]},"new_value":{"type":["string","null"]},"old_value":{"type":["string","null"]},"campaignId":{"type":["null","integer"]},"request_id":{"type":["string","null"]},"marketoGUID":{"type":["null","string"]},"activityDate":{"type":["null","string"],"format":"date-time"},"activityTypeId":{"type":["null","integer"]},"modifying_user":{"type":["string","null"]},"api_method_name":{"type":["string","null"]},"primaryAttributeValue":{"type":["null","string"]},"primaryAttributeValueId":{"type":["null","string"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[activityDate],sourceDefinedPrimaryKey=[[marketoGUID]],namespace=MARKETO,additionalProperties={}],syncMode=incremental,cursorField=[activityDate],destinationSyncMode=append_dedup,primaryKey=[[marketoGUID]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@7399c79f[stream=io.airbyte.protocol.models.AirbyteStream@99a7b1[name=activity_types,jsonSchema={"type":["null","object"],"properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]},"attributes":{"type":["null","array"],"items":{"type":["null","object"],"properties":{"name":{"type":["null","string"]},"dataType":{"type":["null","string"]}}}},"description":{"type":["null","string"]},"primaryAttribute":{"type":["null","object"],"properties":{"name":{"type":["null","string"]},"dataType":{"type":["null","string"]}}}},"additionalProperties":false},supportedSyncModes=[full_refresh],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=MARKETO,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@b3e6057[stream=io.airbyte.protocol.models.AirbyteStream@6ed9a55a[name=campaigns,jsonSchema={"type":["null","object"],"properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]},"type":{"type":["null","string"]},"active":{"type":["null","boolean"]},"createdAt":{"type":["null","string"],"format":"date-time"},"programId":{"type":["null","integer"]},"updatedAt":{"type":["null","string"],"format":"date-time"},"description":{"type":["null","string"]},"programName":{"type":["null","string"]},"workspaceName":{"type":["null","string"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[createdAt],sourceDefinedPrimaryKey=[[id]],namespace=MARKETO,additionalProperties={}],syncMode=incremental,cursorField=[createdAt],destinationSyncMode=append_dedup,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@53413221[stream=io.airbyte.protocol.models.AirbyteStream@1e28b3d7[name=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":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[updatedAt],sourceDefinedPrimaryKey=[[id]],namespace=MARKETO,additionalProperties={}],syncMode=incremental,cursorField=[updatedAt],destinationSyncMode=append_dedup,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@66ec449d[stream=io.airbyte.protocol.models.AirbyteStream@45bcce6f[name=programs,jsonSchema={"type":["object","null"],"properties":{"id":{"type":["integer","null"]},"url":{"type":["null","string"]},"name":{"type":["string","null"]},"type":{"type":["null","string"]},"folder":{"type":["object","null"],"properties":{"type":{"type":["null","string"]},"value":{"type":["null","integer"]},"folderName":{"type":["null","string"]}}},"status":{"type":["null","string"]},"channel":{"type":["null","string"]},"createdAt":{"type":["string","null"],"format":"date-time"},"updatedAt":{"type":["string","null"],"format":"date-time"},"workspace":{"type":["null","string"]},"description":{"type":["null","string"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[updatedAt],sourceDefinedPrimaryKey=[[id]],namespace=MARKETO,additionalProperties={}],syncMode=incremental,cursorField=[updatedAt],destinationSyncMode=append_dedup,primaryKey=[[id]],additionalProperties={}]],additionalProperties={}],failures=[]]
2022-05-09 03:14:33 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating...
2022-05-09 03:14:33 INFO i.a.c.p.ConfigRepository(updateConnectionState):731 - Updating connection 954e7537-5ebe-4677-81f8-23a7fb299e5f state: io.airbyte.config.State@4097fe43[state={"leads":{"updatedAt":"2022-05-09T03:09:10Z"},"programs":{"updatedAt":"2022-05-06T21:28:38Z"},"campaigns":{"createdAt":"2022-05-06T20:08:05Z"},"activities_change_data_value":{"activityDate":"2022-05-09T02:45:38Z"}}]
2022-05-09 03:14:33 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/7789/0/logs.log
2022-05-09 03:14:33 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.65-alpha
2022-05-09 03:14:33 INFO i.a.w.DefaultNormalizationWorker(run):46 - Running normalization.
2022-05-09 03:14:33 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):122 - Running with normalization version: airbyte/normalization-snowflake:0.1.74
2022-05-09 03:14:33 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/normalization-snowflake:0.1.74 exists...
2022-05-09 03:14:33 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/normalization-snowflake:0.1.74 was found locally.
2022-05-09 03:14:33 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 7789
2022-05-09 03:14:33 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/7789/0/normalize --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.35.65-alpha airbyte/normalization-snowflake:0.1.74 run --integration-type snowflake --config destination_config.json --catalog destination_catalog.json
2022-05-09 03:14:34 normalization > Running: transform-config --config destination_config.json --integration-type snowflake --out /data/7789/0/normalize
2022-05-09 03:14:34 normalization > Namespace(config='destination_config.json', integration_type=<DestinationType.snowflake: 'snowflake'>, out='/data/7789/0/normalize')
2022-05-09 03:14:34 normalization > transform_snowflake
2022-05-09 03:14:34 normalization > Running: transform-catalog --integration-type snowflake --profile-config-dir /data/7789/0/normalize --catalog destination_catalog.json --out /data/7789/0/normalize/models/generated/ --json-column _airbyte_data
2022-05-09 03:14:34 normalization > Processing destination_catalog.json...
2022-05-09 03:14:34 normalization >   Generating airbyte_ctes/MARKETO/ACTIVITIES_CHANGE_DATA_VALUE_AB1.sql from activities_change_data_value
2022-05-09 03:14:34 normalization >   Generating airbyte_ctes/MARKETO/ACTIVITIES_CHANGE_DATA_VALUE_AB2.sql from activities_change_data_value
2022-05-09 03:14:34 normalization >   Generating airbyte_views/MARKETO/ACTIVITIES_CHANGE_DATA_VALUE_STG.sql from activities_change_data_value
2022-05-09 03:14:34 normalization >   Generating airbyte_incremental/scd/MARKETO/ACTIVITIES_CHANGE_DATA_VALUE_SCD.sql from activities_change_data_value
2022-05-09 03:14:34 normalization >   Generating airbyte_incremental/MARKETO/ACTIVITIES_CHANGE_DATA_VALUE.sql from activities_change_data_value
2022-05-09 03:14:34 normalization >   Generating airbyte_ctes/MARKETO/ACTIVITY_TYPES_AB1.sql from activity_types
2022-05-09 03:14:34 normalization >   Generating airbyte_ctes/MARKETO/ACTIVITY_TYPES_AB2.sql from activity_types
2022-05-09 03:14:34 normalization >   Generating airbyte_ctes/MARKETO/ACTIVITY_TYPES_AB3.sql from activity_types
2022-05-09 03:14:34 normalization >   Generating airbyte_tables/MARKETO/ACTIVITY_TYPES.sql from activity_types
2022-05-09 03:14:34 normalization >   Generating airbyte_ctes/MARKETO/CAMPAIGNS_AB1.sql from campaigns
2022-05-09 03:14:34 normalization >   Generating airbyte_ctes/MARKETO/CAMPAIGNS_AB2.sql from campaigns
2022-05-09 03:14:34 normalization >   Generating airbyte_views/MARKETO/CAMPAIGNS_STG.sql from campaigns
2022-05-09 03:14:34 normalization >   Generating airbyte_incremental/scd/MARKETO/CAMPAIGNS_SCD.sql from campaigns
2022-05-09 03:14:34 normalization >   Generating airbyte_incremental/MARKETO/CAMPAIGNS.sql from campaigns
2022-05-09 03:14:34 normalization >   Generating airbyte_ctes/MARKETO/LEADS_AB1.sql from leads
2022-05-09 03:14:34 normalization >   Generating airbyte_ctes/MARKETO/LEADS_AB2.sql from leads
2022-05-09 03:14:34 normalization >   Generating airbyte_views/MARKETO/LEADS_STG.sql from leads
2022-05-09 03:14:34 normalization >   Generating airbyte_incremental/scd/MARKETO/LEADS_SCD.sql from leads
2022-05-09 03:14:34 normalization >   Generating airbyte_incremental/MARKETO/LEADS.sql from leads
2022-05-09 03:14:34 normalization >   Generating airbyte_ctes/MARKETO/PROGRAMS_AB1.sql from programs
2022-05-09 03:14:34 normalization >   Generating airbyte_ctes/MARKETO/PROGRAMS_AB2.sql from programs
2022-05-09 03:14:34 normalization >   Generating airbyte_views/MARKETO/PROGRAMS_STG.sql from programs
2022-05-09 03:14:34 normalization >   Generating airbyte_incremental/scd/MARKETO/PROGRAMS_SCD.sql from programs
2022-05-09 03:14:34 normalization >   Generating airbyte_incremental/MARKETO/PROGRAMS.sql from programs
2022-05-09 03:14:34 normalization >   Generating airbyte_ctes/MARKETO/ACTIVITY_TYPES_ATTRIBUTES_AB1.sql from activity_types/attributes
2022-05-09 03:14:34 normalization >   Generating airbyte_ctes/MARKETO/ACTIVITY_TYPES_ATTRIBUTES_AB2.sql from activity_types/attributes
2022-05-09 03:14:34 normalization >   Generating airbyte_ctes/MARKETO/ACTIVITY_TYPES_ATTRIBUTES_AB3.sql from activity_types/attributes
2022-05-09 03:14:34 normalization >   Generating airbyte_tables/MARKETO/ACTIVITY_TYPES_ATTRIBUTES.sql from activity_types/attributes
2022-05-09 03:14:34 normalization >   Generating airbyte_ctes/MARKETO/ACTIVITY_TYPES_PRIMARYATTRIBUTE_AB1.sql from activity_types/primaryAttribute
2022-05-09 03:14:34 normalization >   Generating airbyte_ctes/MARKETO/ACTIVITY_TYPES_PRIMARYATTRIBUTE_AB2.sql from activity_types/primaryAttribute
2022-05-09 03:14:34 normalization >   Generating airbyte_ctes/MARKETO/ACTIVITY_TYPES_PRIMARYATTRIBUTE_AB3.sql from activity_types/primaryAttribute
2022-05-09 03:14:34 normalization >   Generating airbyte_tables/MARKETO/ACTIVITY_TYPES_PRIMARYATTRIBUTE.sql from activity_types/primaryAttribute
2022-05-09 03:14:34 normalization >   Generating airbyte_ctes/MARKETO/PROGRAMS_FOLDER_AB1.sql from programs/folder
2022-05-09 03:14:34 normalization >   Generating airbyte_ctes/MARKETO/PROGRAMS_FOLDER_AB2.sql from programs/folder
2022-05-09 03:14:34 normalization >   Generating airbyte_ctes/MARKETO/PROGRAMS_FOLDER_AB3.sql from programs/folder
2022-05-09 03:14:34 normalization >   Generating airbyte_incremental/MARKETO/PROGRAMS_FOLDER.sql from programs/folder
2022-05-09 03:14:34 normalization > detected no config file for ssh, assuming ssh is off.
2022-05-09 03:14:37 normalization >            [--event-buffer-size EVENT_BUFFER_SIZE]
2022-05-09 03:14:37 normalization >   --event-buffer-size EVENT_BUFFER_SIZE
2022-05-09 03:14:37 normalization > 
2022-05-09 03:14:37 normalization > DBT >=1.0.0 detected; using 10K event buffer size
2022-05-09 03:14:37 normalization > 
2022-05-09 03:14:39 normalization > 03:14:39  Running with dbt=1.0.0
2022-05-09 03:14:39 normalization > 03:14:39  Partial parse save file not found. Starting full parse.
2022-05-09 03:14:41 normalization > 03:14:41  Found 36 models, 0 tests, 0 snapshots, 0 analyses, 528 macros, 0 operations, 0 seed files, 5 sources, 0 exposures, 0 metrics
2022-05-09 03:14:41 normalization > 03:14:41  
2022-05-09 03:14:44 normalization > 03:14:44  Concurrency: 5 threads (target='prod')
2022-05-09 03:14:44 normalization > 03:14:44  
2022-05-09 03:14:44 normalization > 03:14:44  1 of 16 START view model _AIRBYTE_MARKETO.ACTIVITIES_CHANGE_DATA_VALUE_STG.............................................. [RUN]
2022-05-09 03:14:44 normalization > 03:14:44  2 of 16 START view model _AIRBYTE_MARKETO.CAMPAIGNS_STG................................................................. [RUN]
2022-05-09 03:14:44 normalization > 03:14:44  3 of 16 START view model _AIRBYTE_MARKETO.PROGRAMS_STG.................................................................. [RUN]
2022-05-09 03:14:44 normalization > 03:14:44  4 of 16 START view model _AIRBYTE_MARKETO.LEADS_STG..................................................................... [RUN]
2022-05-09 03:14:45 normalization > 03:14:44  5 of 16 START table model MARKETO.ACTIVITY_TYPES........................................................................ [RUN]
2022-05-09 03:14:47 normalization > 03:14:47  3 of 16 OK created view model _AIRBYTE_MARKETO.PROGRAMS_STG............................................................. [SUCCESS 1 in 2.68s]
2022-05-09 03:14:47 normalization > 03:14:47  6 of 16 START incremental model MARKETO.PROGRAMS_SCD.................................................................... [RUN]
2022-05-09 03:14:47 normalization > 03:14:47  1 of 16 OK created view model _AIRBYTE_MARKETO.ACTIVITIES_CHANGE_DATA_VALUE_STG......................................... [SUCCESS 1 in 2.94s]
2022-05-09 03:14:47 normalization > 03:14:47  7 of 16 START incremental model MARKETO.ACTIVITIES_CHANGE_DATA_VALUE_SCD................................................ [RUN]
2022-05-09 03:14:47 normalization > 03:14:47  4 of 16 OK created view model _AIRBYTE_MARKETO.LEADS_STG................................................................ [SUCCESS 1 in 3.02s]
2022-05-09 03:14:47 normalization > 03:14:47  2 of 16 OK created view model _AIRBYTE_MARKETO.CAMPAIGNS_STG............................................................ [SUCCESS 1 in 3.12s]
2022-05-09 03:14:47 normalization > 03:14:47  8 of 16 START incremental model MARKETO.LEADS_SCD....................................................................... [RUN]
2022-05-09 03:14:48 normalization > 03:14:47  9 of 16 START incremental model MARKETO.CAMPAIGNS_SCD................................................................... [RUN]
2022-05-09 03:14:49 normalization > 03:14:49  5 of 16 OK created table model MARKETO.ACTIVITY_TYPES................................................................... [SUCCESS 1 in 4.02s]
2022-05-09 03:14:49 normalization > 03:14:49  10 of 16 START table model MARKETO.ACTIVITY_TYPES_ATTRIBUTES............................................................ [RUN]
2022-05-09 03:14:50 normalization > 03:14:50  10 of 16 OK created table model MARKETO.ACTIVITY_TYPES_ATTRIBUTES....................................................... [SUCCESS 1 in 1.52s]
2022-05-09 03:14:50 normalization > 03:14:50  11 of 16 START table model MARKETO.ACTIVITY_TYPES_PRIMARYATTRIBUTE...................................................... [RUN]
2022-05-09 03:14:51 normalization > 03:14:51  11 of 16 OK created table model MARKETO.ACTIVITY_TYPES_PRIMARYATTRIBUTE................................................. [SUCCESS 1 in 1.25s]
2022-05-09 03:14:53 normalization > 03:14:53  6 of 16 OK created incremental model MARKETO.PROGRAMS_SCD............................................................... [SUCCESS 1 in 6.00s]
2022-05-09 03:14:53 normalization > 03:14:53  12 of 16 START incremental model MARKETO.PROGRAMS....................................................................... [RUN]
2022-05-09 03:14:53 normalization > 03:14:53  13 of 16 START incremental model MARKETO.PROGRAMS_FOLDER................................................................ [RUN]
2022-05-09 03:14:53 normalization > 03:14:53  9 of 16 OK created incremental model MARKETO.CAMPAIGNS_SCD.............................................................. [SUCCESS 1 in 5.93s]
2022-05-09 03:14:54 normalization > 03:14:54  14 of 16 START incremental model MARKETO.CAMPAIGNS...................................................................... [RUN]
2022-05-09 03:14:54 normalization > 03:14:54  7 of 16 OK created incremental model MARKETO.ACTIVITIES_CHANGE_DATA_VALUE_SCD........................................... [SUCCESS 1 in 6.50s]
2022-05-09 03:14:54 normalization > 03:14:54  15 of 16 START incremental model MARKETO.ACTIVITIES_CHANGE_DATA_VALUE................................................... [RUN]
2022-05-09 03:14:58 normalization > 03:14:58  8 of 16 OK created incremental model MARKETO.LEADS_SCD.................................................................. [SUCCESS 1 in 10.62s]
2022-05-09 03:14:58 normalization > 03:14:58  16 of 16 START incremental model MARKETO.LEADS.......................................................................... [RUN]
2022-05-09 03:14:58 normalization > 03:14:58  12 of 16 OK created incremental model MARKETO.PROGRAMS.................................................................. [SUCCESS 1 in 5.31s]
2022-05-09 03:14:59 normalization > 03:14:59  13 of 16 OK created incremental model MARKETO.PROGRAMS_FOLDER........................................................... [SUCCESS 1 in 5.63s]
2022-05-09 03:14:59 normalization > 03:14:59  14 of 16 OK created incremental model MARKETO.CAMPAIGNS................................................................. [SUCCESS 1 in 5.41s]
2022-05-09 03:15:00 normalization > 03:15:00  15 of 16 OK created incremental model MARKETO.ACTIVITIES_CHANGE_DATA_VALUE.............................................. [SUCCESS 1 in 5.88s]
2022-05-09 03:15:04 normalization > 03:15:04  16 of 16 OK created incremental model MARKETO.LEADS..................................................................... [SUCCESS 1 in 5.94s]
2022-05-09 03:15:04 normalization > 03:15:04  
2022-05-09 03:15:04 normalization > 03:15:04  Finished running 4 view models, 3 table models, 9 incremental models in 23.01s.
2022-05-09 03:15:04 normalization > 03:15:04  
2022-05-09 03:15:04 normalization > 03:15:04  Completed successfully
2022-05-09 03:15:04 normalization > 03:15:04  
2022-05-09 03:15:04 normalization > 03:15:04  Done. PASS=16 WARN=0 ERROR=0 SKIP=0 TOTAL=16
2022-05-09 03:15:05 INFO i.a.w.DefaultNormalizationWorker(run):69 - Normalization executed in 31 seconds.
2022-05-09 03:15:05 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-05-09 03:15:05 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating...
2022-05-09 03:15:05 WARN i.a.s.p.JobNotifier(notifyJob):123 - Failed to successfully notify success: io.airbyte.config.Notification@715d68a9[notificationType=slack,sendOnSuccess=false,sendOnFailure=false,slackConfiguration=io.airbyte.config.SlackNotificationConfiguration@21ad749d[webhook=],customerioConfiguration=<null>,additionalProperties={}]
2022-05-09 03:15:05 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. 
errors: $.access_token: is missing but it is required, $.refresh_token: is missing but it is required
2022-05-09 03:15:05 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. 
errors: $.method: does not have a value in the enumeration [Standard]