2022-05-09 18:27:02 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.35.65-alpha
2022-05-09 18:27:02 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/7830/2/logs.log
2022-05-09 18:27:02 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.65-alpha
2022-05-09 18:27:02 INFO i.a.w.DefaultReplicationWorker(run):104 - start sync worker. job id: 7830 attempt id: 2
2022-05-09 18:27:02 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}
2022-05-09 18:27:02 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination...
2022-05-09 18:27:02 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-snowflake:0.4.25 exists...
2022-05-09 18:27:02 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-snowflake:0.4.25 was found locally.
2022-05-09 18:27:02 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 7830
2022-05-09 18:27:02 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/7830/2 --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=2 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.35.65-alpha -e WORKER_JOB_ID=7830 airbyte/destination-snowflake:0.4.25 write --config destination_config.json --catalog destination_catalog.json
2022-05-09 18:27:02 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-marketo:0.1.3 exists...
2022-05-09 18:27:02 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-marketo:0.1.3 was found locally.
2022-05-09 18:27:02 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 7830
2022-05-09 18:27:02 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/7830/2 --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=2 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.35.65-alpha -e WORKER_JOB_ID=7830 airbyte/source-marketo:0.1.3 read --config source_config.json --catalog source_catalog.json --state input_state.json
2022-05-09 18:27:02 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):339 - Destination output thread started.
2022-05-09 18:27:02 INFO i.a.w.DefaultReplicationWorker(run):158 - Waiting for source and destination threads to complete.
2022-05-09 18:27:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):279 - Replication thread started.
2022-05-09 18:27:03 destination > SLF4J: Class path contains multiple SLF4J bindings.
2022-05-09 18:27:03 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-05-09 18:27:03 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-05-09 18:27:03 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-05-09 18:27:03 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-05-09 18:27:04 source > Starting syncing SourceMarketo
2022-05-09 18:27:04 destination > 2022-05-09 18:27:04 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-05-09 18:27:04 destination > 2022-05-09 18:27:04 INFO i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-05-09 18:27:04 destination > 2022-05-09 18:27:04 INFO i.a.i.b.IntegrationRunner(runInternal):122 - Command: WRITE
2022-05-09 18:27:04 destination > 2022-05-09 18:27:04 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 18:27:05 destination > 2022-05-09 18:27:05 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 18:27:05 destination > 2022-05-09 18:27:05 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 18:27:05 destination > 2022-05-09 18:27:05 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 18:27:05 destination > 2022-05-09 18:27:05 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 18:27:05 destination > 2022-05-09 18:27:05 INFO i.a.i.d.j.c.SwitchingDestination(getConsumer):65 - Using destination type: INTERNAL_STAGING
2022-05-09 18:27:05 destination > 2022-05-09 18:27:05 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_vwt_activities_change_data_value, outputTableName=_airbyte_raw_activities_change_data_value, syncMode=append_dedup}
2022-05-09 18:27:05 destination > 2022-05-09 18:27:05 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):99 - Write config: WriteConfig{streamName=activity_types, namespace=MARKETO, outputSchemaName=MARKETO, tmpTableName=_airbyte_tmp_cxw_activity_types, outputTableName=_airbyte_raw_activity_types, syncMode=overwrite}
2022-05-09 18:27:05 destination > 2022-05-09 18:27:05 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):99 - Write config: WriteConfig{streamName=leads, namespace=MARKETO, outputSchemaName=MARKETO, tmpTableName=_airbyte_tmp_lhe_leads, outputTableName=_airbyte_raw_leads, syncMode=append_dedup}
2022-05-09 18:27:05 destination > 2022-05-09 18:27:05 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):99 - Write config: WriteConfig{streamName=programs, namespace=MARKETO, outputSchemaName=MARKETO, tmpTableName=_airbyte_tmp_kvw_programs, outputTableName=_airbyte_raw_programs, syncMode=append_dedup}
2022-05-09 18:27:05 destination > 2022-05-09 18:27:05 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-05-09 18:27:05 destination > 2022-05-09 18:27:05 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):117 - Preparing tmp tables in destination started for 4 streams
2022-05-09 18:27:05 destination > 2022-05-09 18:27:05 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_vwt_activities_change_data_value, stage: 2022/05/09/18/7371E327-A691-4833-A6CA-96D1B959A7A0/
2022-05-09 18:27:05 destination > 2022-05-09 18:27:05 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting...
2022-05-09 18:27:05 source > Syncing stream: activities_change_data_value 
2022-05-09 18:27:05 source > Encountered an exception while reading stream SourceMarketo
Traceback (most recent call last):
  File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 108, in read
    internal_config=internal_config,
  File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 141, in _read_stream
    for record in record_iterator:
  File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 175, in _read_incremental
    cursor_field=configured_stream.cursor_field, sync_mode=SyncMode.incremental, stream_state=stream_state
  File "/airbyte/integration_code/source_marketo/source.py", line 185, in stream_slices
    date_slice["id"] = export["exportId"]
KeyError: 'exportId'
2022-05-09 18:27:05 source > Finished syncing SourceMarketo
2022-05-09 18:27:05 source > SourceMarketo runtimes:

2022-05-09 18:27:05 source > 'exportId'
Traceback (most recent call last):
  File "/airbyte/integration_code/main.py", line 13, in <module>
    launch(source, sys.argv[1:])
  File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/entrypoint.py", line 116, in launch
    for message in source_entrypoint.run(parsed_args):
  File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/entrypoint.py", line 107, in run
    for message in generator:
  File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 112, in read
    raise e
  File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 108, in read
    internal_config=internal_config,
  File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 141, in _read_stream
    for record in record_iterator:
  File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 175, in _read_incremental
    cursor_field=configured_stream.cursor_field, sync_mode=SyncMode.incremental, stream_state=stream_state
  File "/airbyte/integration_code/source_marketo/source.py", line 185, in stream_slices
    date_slice["id"] = export["exportId"]
KeyError: 'exportId'
2022-05-09 18:27:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):305 - Total records read: 0 (0 bytes)
2022-05-09 18:27:06 destination > 2022-05-09 18:27:06 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@1d50a7ca
2022-05-09 18:27:06 destination > 2022-05-09 18:27:06 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed.
2022-05-09 18:27:06 destination > 2022-05-09 18:27:06 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection
2022-05-09 18:27:07 destination > 2022-05-09 18:27:07 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 18:27:07 destination > 2022-05-09 18:27:07 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_cxw_activity_types, stage: 2022/05/09/18/7371E327-A691-4833-A6CA-96D1B959A7A0/
2022-05-09 18:27:07 destination > 2022-05-09 18:27:07 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection
2022-05-09 18:27:07 destination > 2022-05-09 18:27:07 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 18:27:07 destination > 2022-05-09 18:27:07 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_lhe_leads, stage: 2022/05/09/18/7371E327-A691-4833-A6CA-96D1B959A7A0/
2022-05-09 18:27:07 destination > 2022-05-09 18:27:07 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection
2022-05-09 18:27:08 destination > 2022-05-09 18:27:08 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 18:27:08 destination > 2022-05-09 18:27:08 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_kvw_programs, stage: 2022/05/09/18/7371E327-A691-4833-A6CA-96D1B959A7A0/
2022-05-09 18:27:08 destination > 2022-05-09 18:27:08 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection
2022-05-09 18:27:08 destination > 2022-05-09 18:27:08 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 18:27:08 destination > 2022-05-09 18:27:08 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):139 - Preparing tmp tables in destination completed.
2022-05-09 18:27:08 destination > 2022-05-09 18:27:08 WARN i.a.i.b.IntegrationRunner(watchForOrphanThreads):229 - The main thread is exiting while children non-daemon threads from a connector are still active.
2022-05-09 18:27:08 destination > Ideally, this situation should not happen...
2022-05-09 18:27:08 destination > Please check with maintainers if the connector or library code should safely clean up its threads before quitting instead.
2022-05-09 18:27:08 destination > The main thread is: main (RUNNABLE)
2022-05-09 18:27:08 destination >  Thread stacktrace: java.base/java.lang.Thread.getStackTrace(Thread.java:1610)
2022-05-09 18:27:08 destination >         at io.airbyte.integrations.base.IntegrationRunner.dumpThread(IntegrationRunner.java:264)
2022-05-09 18:27:08 destination >         at io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:233)
2022-05-09 18:27:08 destination >         at io.airbyte.integrations.base.IntegrationRunner.runConsumer(IntegrationRunner.java:190)
2022-05-09 18:27:08 destination >         at io.airbyte.integrations.base.IntegrationRunner.lambda$runInternal$1(IntegrationRunner.java:163)
2022-05-09 18:27:08 destination >         at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:54)
2022-05-09 18:27:08 destination >         at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:38)
2022-05-09 18:27:08 destination >         at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:163)
2022-05-09 18:27:08 destination >         at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:105)
2022-05-09 18:27:08 destination >         at io.airbyte.integrations.destination.snowflake.SnowflakeDestination.main(SnowflakeDestination.java:30)
2022-05-09 18:27:08 destination > 2022-05-09 18:27:08 WARN i.a.i.b.IntegrationRunner(watchForOrphanThreads):243 - Active non-daemon thread: pool-4-thread-1 (RUNNABLE)
2022-05-09 18:27:08 destination >  Thread stacktrace: java.base@17.0.1/sun.nio.ch.Net.poll(Native Method)
2022-05-09 18:27:08 destination >         at java.base@17.0.1/sun.nio.ch.NioSocketImpl.park(NioSocketImpl.java:181)
2022-05-09 18:27:08 destination >         at java.base@17.0.1/sun.nio.ch.NioSocketImpl.timedRead(NioSocketImpl.java:285)
2022-05-09 18:27:08 destination >         at java.base@17.0.1/sun.nio.ch.NioSocketImpl.implRead(NioSocketImpl.java:309)
2022-05-09 18:27:08 destination >         at java.base@17.0.1/sun.nio.ch.NioSocketImpl.read(NioSocketImpl.java:350)
2022-05-09 18:27:08 destination >         at java.base@17.0.1/sun.nio.ch.NioSocketImpl$1.read(NioSocketImpl.java:803)
2022-05-09 18:27:08 destination >         at java.base@17.0.1/java.net.Socket$SocketInputStream.read(Socket.java:966)
2022-05-09 18:27:08 destination >         at java.base@17.0.1/sun.security.ssl.SSLSocketInputRecord.read(SSLSocketInputRecord.java:478)
2022-05-09 18:27:08 destination >         at java.base@17.0.1/sun.security.ssl.SSLSocketInputRecord.readHeader(SSLSocketInputRecord.java:472)
2022-05-09 18:27:08 destination >         at java.base@17.0.1/sun.security.ssl.SSLSocketInputRecord.bytesInCompletePacket(SSLSocketInputRecord.java:70)
2022-05-09 18:27:08 destination >         at java.base@17.0.1/sun.security.ssl.SSLSocketImpl.readApplicationRecord(SSLSocketImpl.java:1455)
2022-05-09 18:27:08 destination >         at java.base@17.0.1/sun.security.ssl.SSLSocketImpl$AppInputStream.read(SSLSocketImpl.java:1059)
2022-05-09 18:27:08 destination >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.io.SessionInputBufferImpl.streamRead(SessionInputBufferImpl.java:137)
2022-05-09 18:27:08 destination >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.io.SessionInputBufferImpl.fillBuffer(SessionInputBufferImpl.java:153)
2022-05-09 18:27:08 destination >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.io.SessionInputBufferImpl.readLine(SessionInputBufferImpl.java:280)
2022-05-09 18:27:08 destination >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.conn.DefaultHttpResponseParser.parseHead(DefaultHttpResponseParser.java:138)
2022-05-09 18:27:08 destination >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.conn.DefaultHttpResponseParser.parseHead(DefaultHttpResponseParser.java:56)
2022-05-09 18:27:08 destination >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.io.AbstractMessageParser.parse(AbstractMessageParser.java:259)
2022-05-09 18:27:08 destination >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.DefaultBHttpClientConnection.receiveResponseHeader(DefaultBHttpClientConnection.java:163)
2022-05-09 18:27:08 destination >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.conn.CPoolProxy.receiveResponseHeader(CPoolProxy.java:157)
2022-05-09 18:27:08 destination >         at app//net.snowflake.client.jdbc.internal.apache.http.protocol.HttpRequestExecutor.doReceiveResponse(HttpRequestExecutor.java:273)
2022-05-09 18:27:08 destination >         at app//net.snowflake.client.jdbc.internal.apache.http.protocol.HttpRequestExecutor.execute(HttpRequestExecutor.java:125)
2022-05-09 18:27:08 destination >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.execchain.MainClientExec.execute(MainClientExec.java:272)
2022-05-09 18:27:08 destination >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.execchain.ProtocolExec.execute(ProtocolExec.java:186)
2022-05-09 18:27:08 destination >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.execchain.RetryExec.execute(RetryExec.java:89)
2022-05-09 18:27:08 destination >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.execchain.RedirectExec.execute(RedirectExec.java:110)
2022-05-09 18:27:08 destination >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.client.InternalHttpClient.doExecute(InternalHttpClient.java:185)
2022-05-09 18:27:08 destination >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:83)
2022-05-09 18:27:08 destination >         at app//net.snowflake.client.jdbc.internal.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:108)
2022-05-09 18:27:08 destination >         at app//net.snowflake.client.jdbc.RestRequest.execute(RestRequest.java:160)
2022-05-09 18:27:08 destination >         at app//net.snowflake.client.core.HttpUtil.executeRequestInternal(HttpUtil.java:639)
2022-05-09 18:27:08 destination >         at app//net.snowflake.client.core.HttpUtil.executeRequest(HttpUtil.java:584)
2022-05-09 18:27:08 destination >         at app//net.snowflake.client.core.HttpUtil.executeGeneralRequest(HttpUtil.java:551)
2022-05-09 18:27:08 destination >         at app//net.snowflake.client.jdbc.telemetry.TelemetryClient.sendBatch(TelemetryClient.java:256)
2022-05-09 18:27:08 destination >         at app//net.snowflake.client.jdbc.telemetry.TelemetryClient.lambda$sendBatchAsync$0(TelemetryClient.java:204)
2022-05-09 18:27:08 destination >         at app//net.snowflake.client.jdbc.telemetry.TelemetryClient$$Lambda$254/0x0000000801000818.call(Unknown Source)
2022-05-09 18:27:08 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-05-09 18:27:08 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
2022-05-09 18:27:08 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
2022-05-09 18:27:08 destination >         at java.base@17.0.1/java.lang.Thread.run(Thread.java:833)
2022-05-09 18:27:08 destination > 2022-05-09 18:27:08 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded.
2022-05-09 18:27:08 destination > 2022-05-09 18:27:08 INFO i.a.i.d.b.BufferedStreamConsumer(close):170 - executing on success close procedure.
2022-05-09 18:27:08 destination > 2022-05-09 18:27:08 INFO i.a.i.d.r.SerializedBufferingStrategy(flushAll):92 - Flushing all 0 current buffers (0 bytes in total)
2022-05-09 18:27:08 destination > 2022-05-09 18:27:08 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):186 - Copying into tables in destination started for 4 streams
2022-05-09 18:27:08 destination > 2022-05-09 18:27:08 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_vwt_activities_change_data_value to final table _airbyte_raw_activities_change_data_value from stage path 2022/05/09/18/7371E327-A691-4833-A6CA-96D1B959A7A0/ with 0 file(s) []
2022-05-09 18:27:09 destination > 2022-05-09 18:27:09 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):195 - Copying stream activity_types of schema MARKETO into tmp table _airbyte_tmp_cxw_activity_types to final table _airbyte_raw_activity_types from stage path 2022/05/09/18/7371E327-A691-4833-A6CA-96D1B959A7A0/ with 0 file(s) []
2022-05-09 18:27:10 destination > 2022-05-09 18:27:10 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):195 - Copying stream leads of schema MARKETO into tmp table _airbyte_tmp_lhe_leads to final table _airbyte_raw_leads from stage path 2022/05/09/18/7371E327-A691-4833-A6CA-96D1B959A7A0/ with 0 file(s) []
2022-05-09 18:27:11 destination > 2022-05-09 18:27:11 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):195 - Copying stream programs of schema MARKETO into tmp table _airbyte_tmp_kvw_programs to final table _airbyte_raw_programs from stage path 2022/05/09/18/7371E327-A691-4833-A6CA-96D1B959A7A0/ with 0 file(s) []
2022-05-09 18:27:11 destination > 2022-05-09 18:27:11 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):217 - Executing finalization of tables.
2022-05-09 18:27:13 destination > 2022-05-09 18:27:13 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):219 - Finalizing tables in destination completed.
2022-05-09 18:27:13 destination > 2022-05-09 18:27:13 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):221 - Cleaning up destination started for 4 streams
2022-05-09 18:27:13 destination > 2022-05-09 18:27:13 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_vwt_activities_change_data_value
2022-05-09 18:27:13 destination > 2022-05-09 18:27:13 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 18:27:13 destination > 2022-05-09 18:27:13 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_cxw_activity_types
2022-05-09 18:27:13 destination > 2022-05-09 18:27:13 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 18:27:13 destination > 2022-05-09 18:27:13 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_lhe_leads
2022-05-09 18:27:14 destination > 2022-05-09 18:27:14 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 18:27:14 destination > 2022-05-09 18:27:14 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_kvw_programs
2022-05-09 18:27:14 destination > 2022-05-09 18:27:14 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 18:27:14 destination > 2022-05-09 18:27:14 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):236 - Cleaning up destination completed.
2022-05-09 18:27:14 destination > 2022-05-09 18:27:14 INFO i.a.i.b.IntegrationRunner(runInternal):169 - Completed integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-05-09 18:27:16 ERROR i.a.w.DefaultReplicationWorker(run):169 - Sync worker failed.
java.util.concurrent.ExecutionException: io.airbyte.workers.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.DefaultReplicationWorker.run(DefaultReplicationWorker.java:162) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at java.lang.Thread.run(Thread.java:833) [?:?]
	Suppressed: io.airbyte.workers.WorkerException: Source process exit with code 1. This warning is normal if the job was cancelled.
		at io.airbyte.workers.protocols.airbyte.DefaultAirbyteSource.close(DefaultAirbyteSource.java:136) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:126) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
		at java.lang.Thread.run(Thread.java:833) [?:?]
Caused by: io.airbyte.workers.DefaultReplicationWorker$SourceException: Source process exited with non-zero exit code 1
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:312) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
	... 1 more
2022-05-09 18:27:16 INFO i.a.w.DefaultReplicationWorker(run):228 - sync summary: io.airbyte.config.ReplicationAttemptSummary@49b218a8[status=failed,recordsSynced=0,bytesSynced=0,startTime=1652120822750,endTime=1652120836002,totalStats=io.airbyte.config.SyncStats@6c1d670a[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]]
2022-05-09 18:27:16 INFO i.a.w.DefaultReplicationWorker(run):250 - Source did not output any state messages
2022-05-09 18:27:16 WARN i.a.w.DefaultReplicationWorker(run):258 - State capture: No new state, falling back on input state: io.airbyte.config.State@2ef74058[state={}]
2022-05-09 18:27:16 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-05-09 18:27:16 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$1):147 - sync summary: io.airbyte.config.StandardSyncOutput@6d1ad5a0[standardSyncSummary=io.airbyte.config.StandardSyncSummary@584dd4c6[status=failed,recordsSynced=0,bytesSynced=0,startTime=1652120822750,endTime=1652120836002,totalStats=io.airbyte.config.SyncStats@6c1d670a[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]],state=io.airbyte.config.State@2ef74058[state={}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@15d3e3c9[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@941435f[stream=io.airbyte.protocol.models.AirbyteStream@324d3002[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@4103969[stream=io.airbyte.protocol.models.AirbyteStream@ed74f89[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@d0fbeb7[stream=io.airbyte.protocol.models.AirbyteStream@56995234[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@5347f2ff[stream=io.airbyte.protocol.models.AirbyteStream@67d85419[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=[io.airbyte.config.FailureReason@1752a453[failureOrigin=source,failureType=<null>,internalMessage=io.airbyte.workers.DefaultReplicationWorker$SourceException: Source process exited with non-zero exit code 1,externalMessage=Something went wrong within the source connector,metadata=io.airbyte.config.Metadata@bc65c7f[additionalProperties={attemptNumber=2, jobId=7830}],stacktrace=java.util.concurrent.CompletionException: io.airbyte.workers.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.DefaultReplicationWorker$SourceException: Source process exited with non-zero exit code 1
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:312)
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
	... 3 more
,retryable=<null>,timestamp=1652120826162]]]
2022-05-09 18:27:16 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating...
2022-05-09 18:27:16 INFO i.a.c.p.ConfigRepository(updateConnectionState):731 - Updating connection 954e7537-5ebe-4677-81f8-23a7fb299e5f state: io.airbyte.config.State@7da6376f[state={}]
2022-05-09 18:27:16 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/7830/2/logs.log
2022-05-09 18:27:16 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.65-alpha
2022-05-09 18:27:16 INFO i.a.w.DefaultNormalizationWorker(run):46 - Running normalization.
2022-05-09 18:27:16 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):122 - Running with normalization version: airbyte/normalization-snowflake:0.1.74
2022-05-09 18:27:16 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/normalization-snowflake:0.1.74 exists...
2022-05-09 18:27:16 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 7830
2022-05-09 18:27:16 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/normalization-snowflake:0.1.74 was found locally.
2022-05-09 18:27:16 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/7830/2/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 18:27:16 normalization > Running: transform-config --config destination_config.json --integration-type snowflake --out /data/7830/2/normalize
2022-05-09 18:27:17 normalization > Namespace(config='destination_config.json', integration_type=<DestinationType.snowflake: 'snowflake'>, out='/data/7830/2/normalize')
2022-05-09 18:27:17 normalization > transform_snowflake
2022-05-09 18:27:17 normalization > Running: transform-catalog --integration-type snowflake --profile-config-dir /data/7830/2/normalize --catalog destination_catalog.json --out /data/7830/2/normalize/models/generated/ --json-column _airbyte_data
2022-05-09 18:27:17 normalization > Processing destination_catalog.json...
2022-05-09 18:27:17 normalization >   Generating airbyte_ctes/MARKETO/ACTIVITIES_CHANGE_DATA_VALUE_AB1.sql from activities_change_data_value
2022-05-09 18:27:17 normalization >   Generating airbyte_ctes/MARKETO/ACTIVITIES_CHANGE_DATA_VALUE_AB2.sql from activities_change_data_value
2022-05-09 18:27:17 normalization >   Generating airbyte_views/MARKETO/ACTIVITIES_CHANGE_DATA_VALUE_STG.sql from activities_change_data_value
2022-05-09 18:27:17 normalization >   Generating airbyte_incremental/scd/MARKETO/ACTIVITIES_CHANGE_DATA_VALUE_SCD.sql from activities_change_data_value
2022-05-09 18:27:17 normalization >   Generating airbyte_incremental/MARKETO/ACTIVITIES_CHANGE_DATA_VALUE.sql from activities_change_data_value
2022-05-09 18:27:17 normalization >   Generating airbyte_ctes/MARKETO/ACTIVITY_TYPES_AB1.sql from activity_types
2022-05-09 18:27:17 normalization >   Generating airbyte_ctes/MARKETO/ACTIVITY_TYPES_AB2.sql from activity_types
2022-05-09 18:27:17 normalization >   Generating airbyte_ctes/MARKETO/ACTIVITY_TYPES_AB3.sql from activity_types
2022-05-09 18:27:17 normalization >   Generating airbyte_tables/MARKETO/ACTIVITY_TYPES.sql from activity_types
2022-05-09 18:27:17 normalization >   Generating airbyte_ctes/MARKETO/LEADS_AB1.sql from leads
2022-05-09 18:27:17 normalization >   Generating airbyte_ctes/MARKETO/LEADS_AB2.sql from leads
2022-05-09 18:27:17 normalization >   Generating airbyte_views/MARKETO/LEADS_STG.sql from leads
2022-05-09 18:27:17 normalization >   Generating airbyte_incremental/scd/MARKETO/LEADS_SCD.sql from leads
2022-05-09 18:27:17 normalization >   Generating airbyte_incremental/MARKETO/LEADS.sql from leads
2022-05-09 18:27:17 normalization >   Generating airbyte_ctes/MARKETO/PROGRAMS_AB1.sql from programs
2022-05-09 18:27:17 normalization >   Generating airbyte_ctes/MARKETO/PROGRAMS_AB2.sql from programs
2022-05-09 18:27:17 normalization >   Generating airbyte_views/MARKETO/PROGRAMS_STG.sql from programs
2022-05-09 18:27:17 normalization >   Generating airbyte_incremental/scd/MARKETO/PROGRAMS_SCD.sql from programs
2022-05-09 18:27:17 normalization >   Generating airbyte_incremental/MARKETO/PROGRAMS.sql from programs
2022-05-09 18:27:17 normalization >   Generating airbyte_ctes/MARKETO/ACTIVITY_TYPES_ATTRIBUTES_AB1.sql from activity_types/attributes
2022-05-09 18:27:17 normalization >   Generating airbyte_ctes/MARKETO/ACTIVITY_TYPES_ATTRIBUTES_AB2.sql from activity_types/attributes
2022-05-09 18:27:17 normalization >   Generating airbyte_ctes/MARKETO/ACTIVITY_TYPES_ATTRIBUTES_AB3.sql from activity_types/attributes
2022-05-09 18:27:17 normalization >   Generating airbyte_tables/MARKETO/ACTIVITY_TYPES_ATTRIBUTES.sql from activity_types/attributes
2022-05-09 18:27:17 normalization >   Generating airbyte_ctes/MARKETO/ACTIVITY_TYPES_PRIMARYATTRIBUTE_AB1.sql from activity_types/primaryAttribute
2022-05-09 18:27:17 normalization >   Generating airbyte_ctes/MARKETO/ACTIVITY_TYPES_PRIMARYATTRIBUTE_AB2.sql from activity_types/primaryAttribute
2022-05-09 18:27:17 normalization >   Generating airbyte_ctes/MARKETO/ACTIVITY_TYPES_PRIMARYATTRIBUTE_AB3.sql from activity_types/primaryAttribute
2022-05-09 18:27:17 normalization >   Generating airbyte_tables/MARKETO/ACTIVITY_TYPES_PRIMARYATTRIBUTE.sql from activity_types/primaryAttribute
2022-05-09 18:27:17 normalization >   Generating airbyte_ctes/MARKETO/PROGRAMS_FOLDER_AB1.sql from programs/folder
2022-05-09 18:27:17 normalization >   Generating airbyte_ctes/MARKETO/PROGRAMS_FOLDER_AB2.sql from programs/folder
2022-05-09 18:27:17 normalization >   Generating airbyte_ctes/MARKETO/PROGRAMS_FOLDER_AB3.sql from programs/folder
2022-05-09 18:27:17 normalization >   Generating airbyte_incremental/MARKETO/PROGRAMS_FOLDER.sql from programs/folder
2022-05-09 18:27:17 normalization > detected no config file for ssh, assuming ssh is off.
2022-05-09 18:27:19 normalization >            [--event-buffer-size EVENT_BUFFER_SIZE]
2022-05-09 18:27:19 normalization >   --event-buffer-size EVENT_BUFFER_SIZE
2022-05-09 18:27:19 normalization > 
2022-05-09 18:27:19 normalization > DBT >=1.0.0 detected; using 10K event buffer size
2022-05-09 18:27:19 normalization > 
2022-05-09 18:27:22 normalization > 18:27:22  Running with dbt=1.0.0
2022-05-09 18:27:22 normalization > 18:27:22  Partial parse save file not found. Starting full parse.
2022-05-09 18:27:25 normalization > 18:27:25  Found 31 models, 0 tests, 0 snapshots, 0 analyses, 528 macros, 0 operations, 0 seed files, 4 sources, 0 exposures, 0 metrics
2022-05-09 18:27:25 normalization > 18:27:25  
2022-05-09 18:27:28 normalization > 18:27:28  Concurrency: 5 threads (target='prod')
2022-05-09 18:27:28 normalization > 18:27:28  
2022-05-09 18:27:28 normalization > 18:27:28  1 of 13 START view model _AIRBYTE_MARKETO.ACTIVITIES_CHANGE_DATA_VALUE_STG.............................................. [RUN]
2022-05-09 18:27:29 normalization > 18:27:29  2 of 13 START view model _AIRBYTE_MARKETO.PROGRAMS_STG.................................................................. [RUN]
2022-05-09 18:27:29 normalization > 18:27:29  3 of 13 START table model MARKETO.ACTIVITY_TYPES........................................................................ [RUN]
2022-05-09 18:27:29 normalization > 18:27:29  4 of 13 START view model _AIRBYTE_MARKETO.LEADS_STG..................................................................... [RUN]
2022-05-09 18:27:31 normalization > 18:27:31  2 of 13 OK created view model _AIRBYTE_MARKETO.PROGRAMS_STG............................................................. [SUCCESS 1 in 2.68s]
2022-05-09 18:27:31 normalization > 18:27:31  5 of 13 START incremental model MARKETO.PROGRAMS_SCD.................................................................... [RUN]
2022-05-09 18:27:31 normalization > 18:27:31  1 of 13 OK created view model _AIRBYTE_MARKETO.ACTIVITIES_CHANGE_DATA_VALUE_STG......................................... [SUCCESS 1 in 3.01s]
2022-05-09 18:27:31 normalization > 18:27:31  6 of 13 START incremental model MARKETO.ACTIVITIES_CHANGE_DATA_VALUE_SCD................................................ [RUN]
2022-05-09 18:27:32 normalization > 18:27:32  4 of 13 OK created view model _AIRBYTE_MARKETO.LEADS_STG................................................................ [SUCCESS 1 in 3.10s]
2022-05-09 18:27:32 normalization > 18:27:32  7 of 13 START incremental model MARKETO.LEADS_SCD....................................................................... [RUN]
2022-05-09 18:27:32 normalization > 18:27:32  3 of 13 OK created table model MARKETO.ACTIVITY_TYPES................................................................... [SUCCESS 1 in 3.33s]
2022-05-09 18:27:32 normalization > 18:27:32  8 of 13 START table model MARKETO.ACTIVITY_TYPES_ATTRIBUTES............................................................. [RUN]
2022-05-09 18:27:32 normalization > 18:27:32  9 of 13 START table model MARKETO.ACTIVITY_TYPES_PRIMARYATTRIBUTE....................................................... [RUN]
2022-05-09 18:27:34 normalization > 18:27:34  8 of 13 OK created table model MARKETO.ACTIVITY_TYPES_ATTRIBUTES........................................................ [SUCCESS 1 in 1.57s]
2022-05-09 18:27:34 normalization > 18:27:34  9 of 13 OK created table model MARKETO.ACTIVITY_TYPES_PRIMARYATTRIBUTE.................................................. [SUCCESS 1 in 1.87s]
2022-05-09 18:27:36 normalization > 18:27:36  6 of 13 OK created incremental model MARKETO.ACTIVITIES_CHANGE_DATA_VALUE_SCD........................................... [SUCCESS 1 in 5.00s]
2022-05-09 18:27:36 normalization > 18:27:36  10 of 13 START incremental model MARKETO.ACTIVITIES_CHANGE_DATA_VALUE................................................... [RUN]
2022-05-09 18:27:38 normalization > 18:27:38  5 of 13 OK created incremental model MARKETO.PROGRAMS_SCD............................................................... [SUCCESS 1 in 6.21s]
2022-05-09 18:27:38 normalization > 18:27:38  11 of 13 START incremental model MARKETO.PROGRAMS....................................................................... [RUN]
2022-05-09 18:27:38 normalization > 18:27:38  12 of 13 START incremental model MARKETO.PROGRAMS_FOLDER................................................................ [RUN]
2022-05-09 18:27:40 normalization > 18:27:40  10 of 13 OK created incremental model MARKETO.ACTIVITIES_CHANGE_DATA_VALUE.............................................. [SUCCESS 1 in 3.24s]
2022-05-09 18:27:40 normalization > 18:27:40  12 of 13 OK created incremental model MARKETO.PROGRAMS_FOLDER........................................................... [SUCCESS 1 in 2.86s]
2022-05-09 18:27:41 normalization > 18:27:41  11 of 13 OK created incremental model MARKETO.PROGRAMS.................................................................. [SUCCESS 1 in 3.21s]
2022-05-09 18:27:41 normalization > 18:27:41  7 of 13 OK created incremental model MARKETO.LEADS_SCD.................................................................. [SUCCESS 1 in 9.31s]
2022-05-09 18:27:41 normalization > 18:27:41  13 of 13 START incremental model MARKETO.LEADS.......................................................................... [RUN]
2022-05-09 18:27:44 normalization > 18:27:44  13 of 13 OK created incremental model MARKETO.LEADS..................................................................... [SUCCESS 1 in 3.21s]
2022-05-09 18:27:44 normalization > 18:27:44  
2022-05-09 18:27:44 normalization > 18:27:44  Finished running 3 view models, 3 table models, 7 incremental models in 19.16s.
2022-05-09 18:27:44 normalization > 18:27:44  
2022-05-09 18:27:44 normalization > 18:27:44  Completed successfully
2022-05-09 18:27:44 normalization > 18:27:44  
2022-05-09 18:27:44 normalization > 18:27:44  Done. PASS=13 WARN=0 ERROR=0 SKIP=0 TOTAL=13
2022-05-09 18:27:45 INFO i.a.w.DefaultNormalizationWorker(run):69 - Normalization executed in 29 seconds.
2022-05-09 18:27:45 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-05-09 18:27:45 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating...
2022-05-09 18:27:45 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 18:27:45 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. 
errors: $.method: does not have a value in the enumeration [Standard]