2022-02-05 06:17:38 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.35.16-alpha
2022-02-05 06:17:38 INFO i.a.w.t.TemporalAttemptExecution(get):115 - Docker volume job log path: /tmp/workspace/365/0/logs.log
2022-02-05 06:17:38 INFO i.a.w.t.TemporalAttemptExecution(get):120 - Executing worker wrapper. Airbyte version: 0.35.16-alpha
2022-02-05 06:17:38 WARN i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):65 - Waiting for database to become available...
2022-02-05 06:17:38 INFO i.a.d.i.j.JobsDatabaseInstance(lambda$static$2):25 - Testing if jobs database is ready...
2022-02-05 06:17:39 INFO i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):90 - Database available!
2022-02-05 06:17:39 INFO i.a.d.Databases(createPostgresDatabaseWithRetry):48 - Database available!
2022-02-05 06:17:39 INFO i.a.w.DefaultReplicationWorker(run):103 - start sync worker. job id: 365 attempt id: 0
2022-02-05 06:17:39 INFO i.a.w.DefaultReplicationWorker(run):115 - configured sync modes: {null.leads=incremental - append_dedup}
2022-02-05 06:17:39 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination...
2022-02-05 06:17:39 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-bigquery:0.6.7 exists...
2022-02-05 06:17:39 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-bigquery:0.6.7 was found locally.
2022-02-05 06:17:39 INFO i.a.w.p.DockerProcessFactory(create):157 - Preparing command: docker run --rm --init -i -w /data/365/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local airbyte/destination-bigquery:0.6.7 write --config destination_config.json --catalog destination_catalog.json
2022-02-05 06:17:39 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-marketo:0.1.3 exists...
2022-02-05 06:17:39 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-marketo:0.1.3 was found locally.
2022-02-05 06:17:39 INFO i.a.w.p.DockerProcessFactory(create):157 - Preparing command: docker run --rm --init -i -w /data/365/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local airbyte/source-marketo:0.1.3 read --config source_config.json --catalog source_catalog.json
2022-02-05 06:17:39 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):307 - Destination output thread started.
2022-02-05 06:17:39 INFO i.a.w.DefaultReplicationWorker(run):147 - Waiting for source and destination threads to complete.
2022-02-05 06:17:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):268 - Replication thread started.
2022-02-05 06:17:40 destination > SLF4J: Class path contains multiple SLF4J bindings.
2022-02-05 06:17:40 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.16.0.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-02-05 06:17:40 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-02-05 06:17:40 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-02-05 06:17:40 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-02-05 06:17:41 source > Starting syncing SourceMarketo
2022-02-05 06:17:41 source > Syncing stream: leads 
2022-02-05 06:17:42 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-02-05 06:17:42 source > Finished syncing SourceMarketo
2022-02-05 06:17:42 source > SourceMarketo runtimes:

2022-02-05 06:17:42 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-02-05 06:17:43 destination > 2022-02-05 06:17:43 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-02-05 06:17:43 destination > 2022-02-05 06:17:43 INFO i.a.i.b.IntegrationRunner(runInternal):105 - Running integration: io.airbyte.integrations.destination.bigquery.BigQueryDestination
2022-02-05 06:17:43 destination > 2022-02-05 06:17:43 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Command: WRITE
2022-02-05 06:17:43 destination > 2022-02-05 06:17:43 INFO i.a.i.b.IntegrationRunner(runInternal):107 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-02-05 06:17:43 destination > 2022-02-05 06:17:43 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-02-05 06:17:43 destination > 2022-02-05 06:17:43 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-02-05 06:17:43 destination > 2022-02-05 06:17:43 INFO i.a.i.d.b.BigQueryUtils(getLoadingMethod):283 - Selected loading method is set to: STANDARD
2022-02-05 06:17:45 destination > 2022-02-05 06:17:45 INFO i.a.i.d.b.BigQueryUtils(createPartitionedTable):123 - Partitioned Table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=marketo_leads, tableId=_airbyte_tmp_plc_leads}} created successfully
2022-02-05 06:17:45 destination > 2022-02-05 06:17:45 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):63 - Airbyte message consumer: succeeded.
2022-02-05 06:17:45 destination > 2022-02-05 06:17:45 INFO i.a.i.d.b.BigQueryRecordConsumer(close):55 - Started closing all connections
2022-02-05 06:17:45 destination > 2022-02-05 06:17:45 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):76 - Field fails during format : 
2022-02-05 06:17:45 destination > 2022-02-05 06:17:45 INFO i.a.i.d.b.f.BigQueryRecordFormatter(printAndCleanFieldFails):70 - No field fails during record format.
2022-02-05 06:17:45 destination > 2022-02-05 06:17:45 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):79 - Closing connector:AbstractBigQueryUploader{table=_airbyte_raw_leads, tmpTable=_airbyte_tmp_plc_leads, syncMode=WRITE_APPEND, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter}
2022-02-05 06:17:45 destination > 2022-02-05 06:17:45 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadData):96 - Uploading data from the tmp table _airbyte_tmp_plc_leads to the source table _airbyte_raw_leads.
2022-02-05 06:17:45 destination > 2022-02-05 06:17:45 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadDataToTableFromTmpTable):121 - Replication finished with no explicit errors. Copying data from tmp tables to permanent
2022-02-05 06:17:50 destination > 2022-02-05 06:17:50 INFO i.a.i.d.b.u.AbstractBigQueryUploader(copyTable):187 - successfully copied table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=marketo_leads, tableId=_airbyte_tmp_plc_leads}} to table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=marketo_leads, tableId=_airbyte_raw_leads}}
2022-02-05 06:17:50 destination > 2022-02-05 06:17:50 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadData):98 - Data is successfully loaded to the source table _airbyte_raw_leads!
2022-02-05 06:17:50 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. 
errors: $: null found, object expected
2022-02-05 06:17:50 ERROR i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$1):70 - Validation failed: null
2022-02-05 06:17:50 destination > 2022-02-05 06:17:50 INFO i.a.i.d.b.u.AbstractBigQueryUploader(uploadData):100 - Final state message is accepted.
2022-02-05 06:17:50 destination > 2022-02-05 06:17:50 INFO i.a.i.d.b.u.AbstractBigQueryUploader(dropTmpTable):112 - Removing tmp tables...
2022-02-05 06:17:50 destination > 2022-02-05 06:17:50 INFO i.a.i.d.b.u.AbstractBigQueryUploader(dropTmpTable):114 - Finishing destination process...completed
2022-02-05 06:17:50 destination > 2022-02-05 06:17:50 INFO i.a.i.d.b.u.AbstractBigQueryUploader(close):86 - Closed connector:AbstractBigQueryUploader{table=_airbyte_raw_leads, tmpTable=_airbyte_tmp_plc_leads, syncMode=WRITE_APPEND, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter}
2022-02-05 06:17:50 destination > 2022-02-05 06:17:50 INFO i.a.i.b.IntegrationRunner(runInternal):153 - Completed integration: io.airbyte.integrations.destination.bigquery.BigQueryDestination
2022-02-05 06:17:50 ERROR i.a.w.DefaultReplicationWorker(run):158 - Sync worker failed.
java.util.concurrent.ExecutionException: java.lang.RuntimeException: java.lang.RuntimeException: Source process exited with non-zero exit code 1
	at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) ~[?:?]
	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) ~[?:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:151) ~[io.airbyte-airbyte-workers-0.35.16-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:56) ~[io.airbyte-airbyte-workers-0.35.16-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:171) ~[io.airbyte-airbyte-workers-0.35.16-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.16-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:125) ~[io.airbyte-airbyte-workers-0.35.16-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:56) ~[io.airbyte-airbyte-workers-0.35.16-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:171) ~[io.airbyte-airbyte-workers-0.35.16-alpha.jar:?]
		at java.lang.Thread.run(Thread.java:833) [?:?]
Caused by: java.lang.RuntimeException: java.lang.RuntimeException: Source process exited with non-zero exit code 1
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:295) ~[io.airbyte-airbyte-workers-0.35.16-alpha.jar:?]
	at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
	... 1 more
Caused by: java.lang.RuntimeException: Source process exited with non-zero exit code 1
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:287) ~[io.airbyte-airbyte-workers-0.35.16-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-02-05 06:17:50 INFO i.a.w.DefaultReplicationWorker(run):217 - sync summary: io.airbyte.config.ReplicationAttemptSummary@47e90b6d[status=failed,recordsSynced=0,bytesSynced=0,startTime=1644041859106,endTime=1644041870805,totalStats=io.airbyte.config.SyncStats@4b2ef486[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]]
2022-02-05 06:17:50 INFO i.a.w.DefaultReplicationWorker(run):239 - Source did not output any state messages
2022-02-05 06:17:50 WARN i.a.w.DefaultReplicationWorker(run):250 - State capture: No state retained.
2022-02-05 06:17:50 INFO i.a.w.t.TemporalAttemptExecution(get):141 - Stopping cancellation check scheduling...
2022-02-05 06:17:50 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$1):149 - sync summary: io.airbyte.config.StandardSyncOutput@1d1fc7f0[standardSyncSummary=io.airbyte.config.StandardSyncSummary@2ee9e60c[status=failed,recordsSynced=0,bytesSynced=0,startTime=1644041859106,endTime=1644041870805,totalStats=io.airbyte.config.SyncStats@4b2ef486[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]],state=<null>,outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@545228ac[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@2314d69a[stream=io.airbyte.protocol.models.AirbyteStream@4057b54f[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=<null>,additionalProperties={}],syncMode=incremental,cursorField=[updatedAt],destinationSyncMode=append_dedup,primaryKey=[[id]],additionalProperties={}]],additionalProperties={}],failures=[io.airbyte.config.FailureReason@216fe2cf[failureOrigin=source,failureType=<null>,internalMessage=java.lang.RuntimeException: java.lang.RuntimeException: Source process exited with non-zero exit code 1,externalMessage=Something went wrong within the source connector,metadata=io.airbyte.config.Metadata@64bda906[additionalProperties={attemptNumber=0, jobId=365}],stacktrace=java.util.concurrent.CompletionException: java.lang.RuntimeException: java.lang.RuntimeException: Source process exited with non-zero exit code 1
	at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315)
	at java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:320)
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1807)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
	at java.base/java.lang.Thread.run(Thread.java:833)
Caused by: java.lang.RuntimeException: java.lang.RuntimeException: Source process exited with non-zero exit code 1
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:295)
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
	... 3 more
Caused by: java.lang.RuntimeException: Source process exited with non-zero exit code 1
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:287)
	... 4 more
,timestamp=1644041862518]]]
2022-02-05 06:17:50 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):212 - Stopping temporal heartbeating...
2022-02-05 06:17:50 INFO i.a.w.t.TemporalAttemptExecution(get):115 - Docker volume job log path: /tmp/workspace/365/0/logs.log
2022-02-05 06:17:50 INFO i.a.w.t.TemporalAttemptExecution(get):120 - Executing worker wrapper. Airbyte version: 0.35.16-alpha
2022-02-05 06:17:50 WARN i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):65 - Waiting for database to become available...
2022-02-05 06:17:50 INFO i.a.d.i.j.JobsDatabaseInstance(lambda$static$2):25 - Testing if jobs database is ready...
2022-02-05 06:17:50 INFO i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):90 - Database available!
2022-02-05 06:17:50 INFO i.a.d.Databases(createPostgresDatabaseWithRetry):48 - Database available!
2022-02-05 06:17:50 INFO i.a.w.DefaultNormalizationWorker(run):46 - Running normalization.
2022-02-05 06:17:50 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):122 - Running with normalization version: airbyte/normalization:0.1.65
2022-02-05 06:17:50 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/normalization:0.1.65 exists...
2022-02-05 06:17:51 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/normalization:0.1.65 was found locally.
2022-02-05 06:17:51 INFO i.a.w.p.DockerProcessFactory(create):157 - Preparing command: docker run --rm --init -i -w /data/365/0/normalize --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local airbyte/normalization:0.1.65 run --integration-type bigquery --config destination_config.json --catalog destination_catalog.json
2022-02-05 06:17:51 normalization > Running: transform-config --config destination_config.json --integration-type bigquery --out /data/365/0/normalize
2022-02-05 06:17:51 normalization > Namespace(config='destination_config.json', integration_type=<DestinationType.bigquery: 'bigquery'>, out='/data/365/0/normalize')
2022-02-05 06:17:51 normalization > transform_bigquery
2022-02-05 06:17:51 normalization > Running: transform-catalog --integration-type bigquery --profile-config-dir /data/365/0/normalize --catalog destination_catalog.json --out /data/365/0/normalize/models/generated/ --json-column _airbyte_data
2022-02-05 06:17:51 normalization > Processing destination_catalog.json...
2022-02-05 06:17:51 normalization >   Generating airbyte_ctes/marketo_leads/leads_ab1.sql from leads
2022-02-05 06:17:51 normalization >   Generating airbyte_ctes/marketo_leads/leads_ab2.sql from leads
2022-02-05 06:17:51 normalization >   Generating airbyte_views/marketo_leads/leads_stg.sql from leads
2022-02-05 06:17:51 normalization >   Generating airbyte_incremental/scd/marketo_leads/leads_scd.sql from leads
2022-02-05 06:17:51 normalization >   Generating airbyte_incremental/marketo_leads/leads.sql from leads
2022-02-05 06:17:51 normalization > detected no config file for ssh, assuming ssh is off.
2022-02-05 06:17:54 normalization > Running with dbt=0.21.1
2022-02-05 06:17:54 normalization > Unable to do partial parsing because ../build/partial_parse.msgpack not found
2022-02-05 06:17:56 normalization > [WARNING]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources.
2022-02-05 06:17:56 normalization > There are 1 unused configuration paths:
2022-02-05 06:17:56 normalization > - models.airbyte_utils.generated.airbyte_tables
2022-02-05 06:17:56 normalization > 
2022-02-05 06:17:56 normalization > Found 5 models, 0 tests, 0 snapshots, 0 analyses, 516 macros, 0 operations, 0 seed files, 1 source, 0 exposures
2022-02-05 06:17:56 normalization > 
2022-02-05 06:17:57 normalization > 06:17:57 | Concurrency: 8 threads (target='prod')
2022-02-05 06:17:57 normalization > 06:17:57 | 
2022-02-05 06:17:57 normalization > 06:17:57 | 1 of 3 START view model _airbyte_marketo_leads.leads_stg..................................................... [RUN]
2022-02-05 06:17:58 normalization > 06:17:58 | 1 of 3 OK created view model _airbyte_marketo_leads.leads_stg................................................ [OK in 1.03s]
2022-02-05 06:17:58 normalization > 06:17:58 | 2 of 3 START incremental model marketo_leads.leads_scd....................................................... [RUN]
2022-02-05 06:17:58 normalization > 06:17:58 + `bigquery-313713`.marketo_leads.`leads_scd`._airbyte_ab_id does not exist yet. The table will be created or rebuilt with dbt.full_refresh
2022-02-05 06:18:02 normalization > 06:18:02 | 2 of 3 OK created incremental model marketo_leads.leads_scd.................................................. [CREATE TABLE (0.0 rows, 0.0 Bytes processed) in 4.21s]
2022-02-05 06:18:02 normalization > 06:18:02 | 3 of 3 START incremental model marketo_leads.leads........................................................... [RUN]
2022-02-05 06:18:03 normalization > 06:18:03 + `bigquery-313713`.marketo_leads.`leads`._airbyte_ab_id does not exist yet. The table will be created or rebuilt with dbt.full_refresh
2022-02-05 06:18:05 normalization > 06:18:05 | 3 of 3 OK created incremental model marketo_leads.leads...................................................... [CREATE TABLE (0.0 rows, 0.0 Bytes processed) in 2.98s]
2022-02-05 06:18:05 normalization > 06:18:05 | 
2022-02-05 06:18:05 normalization > 06:18:05 | Finished running 1 view model, 2 incremental models in 9.17s.
2022-02-05 06:18:05 normalization > 
2022-02-05 06:18:05 normalization > Completed successfully
2022-02-05 06:18:05 normalization > 
2022-02-05 06:18:05 normalization > Done. PASS=3 WARN=0 ERROR=0 SKIP=0 TOTAL=3
2022-02-05 06:18:06 INFO i.a.w.DefaultNormalizationWorker(run):69 - Normalization executed in 15 seconds.
2022-02-05 06:18:06 INFO i.a.w.t.TemporalAttemptExecution(get):141 - Stopping cancellation check scheduling...
2022-02-05 06:18:06 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):212 - Stopping temporal heartbeating...