2023-02-09 16:22:27 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):138 - Cloud storage job log path: /workspace/14503/0/logs.log
2023-02-09 16:23:27 [42mnormalization[0m > Running: transform-config --config destination_config.json --integration-type snowflake --out /config
2023-02-09 16:23:27 [42mnormalization[0m > Namespace(config='destination_config.json', integration_type=<DestinationType.SNOWFLAKE: 'snowflake'>, out='/config')
2023-02-09 16:23:27 [42mnormalization[0m > transform_snowflake
2023-02-09 16:23:27 [42mnormalization[0m > Running: transform-catalog --integration-type snowflake --profile-config-dir /config --catalog destination_catalog.json --out /config/models/generated/ --json-column _airbyte_data
2023-02-09 16:23:27 [42mnormalization[0m > Processing destination_catalog.json...
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/ADDRESS_AB1.sql from address
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/ADDRESS_AB2.sql from address
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/ADDRESS_AB3.sql from address
2023-02-09 16:23:27 [42mnormalization[0m >   Adding drop table hook for ADDRESS_SCD to ADDRESS
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_tables/<client_name>_PINNACLE_FA/ADDRESS.sql from address
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/ADJUSTMENT_AB1.sql from adjustment
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/ADJUSTMENT_AB2.sql from adjustment
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/ADJUSTMENT_AB3.sql from adjustment
2023-02-09 16:23:27 [42mnormalization[0m >   Adding drop table hook for ADJUSTMENT_SCD to ADJUSTMENT
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_tables/<client_name>_PINNACLE_FA/ADJUSTMENT.sql from adjustment
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/CUSTOMERS_AB1.sql from customers
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/CUSTOMERS_AB2.sql from customers
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/CUSTOMERS_AB3.sql from customers
2023-02-09 16:23:27 [42mnormalization[0m >   Adding drop table hook for CUSTOMERS_SCD to CUSTOMERS
2023-02-09 16:22:27 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.29
2023-02-09 16:22:27 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2023-02-09 16:22:27 [32mINFO[m i.a.c.EnvConfigs(getEnvOrDefault):1175 - Using default value for environment variable METRIC_CLIENT: ''
2023-02-09 16:22:27 [33mWARN[m i.a.m.l.MetricClientFactory(initialize):60 - Metric client is already initialized to
2023-02-09 16:22:27 [32mINFO[m i.a.w.g.DefaultReplicationWorker(run):150 - start sync worker. job id: 14503 attempt id: 0
2023-02-09 16:22:27 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2023-02-09 16:22:27 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- START REPLICATION -----
2023-02-09 16:22:27 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2023-02-09 16:22:27 [32mINFO[m i.a.w.g.DefaultReplicationWorker(run):165 - configured sync modes: {proview.models=full_refresh - overwrite, proview.invoicedetail=full_refresh - overwrite, proview.payalloc=full_refresh - overwrite, proview.invoices=full_refresh - overwrite, proview.adjustment=full_refresh - overwrite, proview.payments=full_refresh - overwrite, proview.stock=full_refresh - overwrite, proview.sites=full_refresh - overwrite, proview.purchaseorderdetail=full_refresh - overwrite, proview.newstock=full_refresh - overwrite, pro.ic=full_refresh - overwrite, proview.quotes=full_refresh - overwrite, proview.setprice=full_refresh - overwrite, proview.oldparts=full_refresh - overwrite, proview.phones=full_refresh - overwrite, proview.salesledger=full_refresh - overwrite, delivery.address=full_refresh - overwrite, proview.purchaseledger=full_refresh - overwrite, proview.salesallocation=full_refresh - overwrite, proview.parts=full_refresh - overwrite, proview.search=full_refresh - overwrite, proview.invdetail=full_refresh - overwrite, proview.purchaseorder=full_refresh - overwrite, proview.icversion=full_refresh - overwrite, proview.vehistok=full_refresh - overwrite, proview.customers=full_refresh - overwrite}
2023-02-09 16:22:27 [32mINFO[m i.a.w.i.DefaultAirbyteDestination(start):78 - Running destination...
2023-02-09 16:22:27 [32mINFO[m i.a.w.p.KubeProcessFactory(create):96 - Attempting to start pod = destination-snowflake-write-14503-0-pomjq for airbyte/destination-snowflake:0.4.44 with resources io.airbyte.config.ResourceRequirements@65bc0445[cpuRequest=,cpuLimit=,memoryRequest=2Gi,memoryLimit=]
2023-02-09 16:22:27 [32mINFO[m i.a.w.p.KubeProcessFactory(create):99 - destination-snowflake-write-14503-0-pomjq stdoutLocalPort = 9038
2023-02-09 16:22:27 [32mINFO[m i.a.w.p.KubeProcessFactory(create):102 - destination-snowflake-write-14503-0-pomjq stderrLocalPort = 9039
2023-02-09 16:22:27 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$11):620 - Creating stderr socket server...
2023-02-09 16:22:27 [32mINFO[m i.a.w.p.KubePodProcess(<init>):533 - Creating pod destination-snowflake-write-14503-0-pomjq...
2023-02-09 16:22:27 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):602 - Creating stdout socket server...
2023-02-09 16:22:27 [32mINFO[m i.a.w.p.KubePodProcess(waitForInitPodToRun):313 - Waiting for init container to be ready before copying files...
2023-02-09 16:22:44 [32mINFO[m i.a.w.t.s.a.JobCreationAndStatusUpdateActivityImpl(createNewJob):141 - Found the following streams to reset for connection 7eda945f-91ba-4121-80c6-f17b7dc34de7: []
2023-02-09 16:22:44 [32mINFO[m i.a.p.j.DefaultJobPersistence(enqueueJob):173 - enqueuing pending job for scope: 7eda945f-91ba-4121-80c6-f17b7dc34de7
2023-02-09 16:22:44 [32mINFO[m i.a.w.t.s.a.JobCreationAndStatusUpdateActivityImpl(createNewJob):175 - New job created, with id: 14506
2023-02-09 16:23:01 [32mINFO[m i.a.w.p.KubePodProcess(waitForInitPodToRun):317 - Init container present..
2023-02-09 16:23:03 [32mINFO[m i.a.w.p.KubePodProcess(waitForInitPodToRun):320 - Init container ready..
2023-02-09 16:23:03 [32mINFO[m i.a.w.p.KubePodProcess(<init>):564 - Copying files...
2023-02-09 16:23:03 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - Uploading file: destination_config.json
2023-02-09 16:23:03 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):270 - kubectl cp /tmp/b9d1692a-91ea-4a2f-9da9-a7a58b6f5e3e/destination_config.json default/destination-snowflake-write-14503-0-pomjq:/config/destination_config.json -c init
2023-02-09 16:23:03 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):273 - Waiting for kubectl cp to complete
2023-02-09 16:23:04 [1;31mERROR[m i.a.w.g.DefaultReplicationWorker(replicate):257 - Sync worker failed.
io.airbyte.workers.exception.WorkerException: java.io.IOException: kubectl cp failed with exit code 1
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:140) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.AirbyteIntegrationLauncher.write(AirbyteIntegrationLauncher.java:193) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.internal.DefaultAirbyteDestination.start(DefaultAirbyteDestination.java:79) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.replicate(DefaultReplicationWorker.java:195) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:173) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:89) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$5(TemporalAttemptExecution.java:195) ~[io.airbyte-airbyte-workers-0.40.29.jar:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
Caused by: java.lang.RuntimeException: java.io.IOException: kubectl cp failed with exit code 1
	at io.airbyte.workers.process.KubePodProcess.copyFilesToKubeConfigVolume(KubePodProcess.java:289) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.KubePodProcess.<init>(KubePodProcess.java:565) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:136) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	... 7 more
Caused by: java.io.IOException: kubectl cp failed with exit code 1
	at io.airbyte.workers.process.KubePodProcess.copyFilesToKubeConfigVolume(KubePodProcess.java:283) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.KubePodProcess.<init>(KubePodProcess.java:565) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:136) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	... 7 more
2023-02-09 16:23:04 [32mINFO[m i.a.w.g.DefaultReplicationWorker(prepStateForLaterSaving):552 - Source did not output any state messages
2023-02-09 16:23:04 [33mWARN[m i.a.w.g.DefaultReplicationWorker(prepStateForLaterSaving):563 - State capture: No state retained.
2023-02-09 16:23:04 [32mINFO[m i.a.w.g.DefaultReplicationWorker(getReplicationOutput):483 - sync summary: {
  "status" : "failed",
  "recordsSynced" : 0,
  "bytesSynced" : 0,
  "startTime" : 1675959747180,
  "endTime" : 1675959784338,
  "totalStats" : {
    "bytesEmitted" : 0,
    "destinationStateMessagesEmitted" : 0,
    "destinationWriteEndTime" : 0,
    "destinationWriteStartTime" : 0,
    "meanSecondsBeforeSourceStateMessageEmitted" : 0,
    "maxSecondsBeforeSourceStateMessageEmitted" : 0,
    "maxSecondsBetweenStateMessageEmittedandCommitted" : 0,
    "meanSecondsBetweenStateMessageEmittedandCommitted" : 0,
    "recordsEmitted" : 0,
    "recordsCommitted" : 0,
    "replicationEndTime" : 1675959784338,
    "replicationStartTime" : 1675959747180,
    "sourceReadEndTime" : 0,
    "sourceReadStartTime" : 0,
    "sourceStateMessagesEmitted" : 0
  },
  "streamStats" : [ ]
}
2023-02-09 16:23:04 [32mINFO[m i.a.w.g.DefaultReplicationWorker(getReplicationOutput):484 - failures: [ ]
2023-02-09 16:23:04 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2023-02-09 16:23:04 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2023-02-09 16:23:04 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- END REPLICATION -----
2023-02-09 16:23:04 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2023-02-09 16:23:04 [32mINFO[m i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):209 - sync summary: io.airbyte.config.StandardSyncOutput@440a20e0[standardSyncSummary=io.airbyte.config.StandardSyncSummary@2bc1a16[status=failed,recordsSynced=0,bytesSynced=0,startTime=1675959747180,endTime=1675959784338,totalStats=io.airbyte.config.SyncStats@33b1535a[bytesEmitted=0,destinationStateMessagesEmitted=0,destinationWriteEndTime=0,destinationWriteStartTime=0,estimatedBytes=<null>,estimatedRecords=<null>,meanSecondsBeforeSourceStateMessageEmitted=0,maxSecondsBeforeSourceStateMessageEmitted=0,maxSecondsBetweenStateMessageEmittedandCommitted=0,meanSecondsBetweenStateMessageEmittedandCommitted=0,recordsEmitted=0,recordsCommitted=0,replicationEndTime=1675959784338,replicationStartTime=1675959747180,sourceReadEndTime=0,sourceReadStartTime=0,sourceStateMessagesEmitted=0,additionalProperties={}],streamStats=[]],normalizationSummary=<null>,webhookOperationSummary=<null>,state=<null>,outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@2f9bb5a6[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@3a039d95[stream=io.airbyte.protocol.models.AirbyteStream@580d4c69[name=address,jsonSchema={"type":"object","properties":{"fax":{"type":"string"},"zip":{"type":"string"},"city":{"type":"string"},"dname":{"type":"string"},"state":{"type":"string"},"phone1":{"type":"string"},"phone2":{"type":"string"},"phone3":{"type":"string"},"contact":{"type":"string"},"country":{"type":"string"},"created":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"address1":{"type":"string"},"address2":{"type":"string"},"address3":{"type":"string"},"ordernumber":{"type":"number","airbyte_type":"integer"},"invoicenumber":{"type":"number","airbyte_type":"integer"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<client_name>_PINNACLE_FA,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@611fffb1[stream=io.airbyte.protocol.models.AirbyteStream@13db50b1[name=adjustment,jsonSchema={"type":"object","properties":{"date":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"user":{"type":"string"},"amount":{"type":"number"},"reason":{"type":"string"},"adjustid":{"type":"number","airbyte_type":"integer"},"customer":{"type":"string"},"allocated":{"type":"number"},"adjusttype":{"type":"string"},"unallocated":{"type":"number"},"allocateddate":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<client_name>_PINNACLE_FA,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@3592886a[stream=io.airbyte.protocol.models.AirbyteStream@74ef4b5[name=customers,jsonSchema={"type":"object","properties":{"bfax":{"type":"string"},"bzip":{"type":"string"},"hold":{"type":"string"},"name":{"type":"string"},"site":{"type":"number","airbyte_type":"integer"},"disc1":{"type":"number"},"disc2":{"type":"number"},"disc3":{"type":"number"},"disc4":{"type":"number"},"disc5":{"type":"number"},"noneu":{"type":"boolean"},"notes":{"type":"string"},"taxno":{"type":"string"},"bemail":{"type":"string"},"bline1":{"type":"string"},"bline2":{"type":"string"},"bline3":{"type":"string"},"bline4":{"type":"string"},"bname1":{"type":"string"},"bname2":{"type":"string"},"bname3":{"type":"string"},"bstate":{"type":"string"},"pblink":{"type":"number","airbyte_type":"integer"},"phone3":{"type":"string"},"salesp":{"type":"string"},"account":{"type":"string"},"balance":{"type":"number"},"bphone1":{"type":"string"},"bphone2":{"type":"string"},"country":{"type":"string"},"custcat":{"type":"string"},"taxdate":{"type":"string","format":"date"},"traceid":{"type":"string"},"bcontact":{"type":"string"},"bdelzone":{"type":"string"},"capricno":{"type":"string"},"interest":{"type":"boolean"},"open_bal":{"type":"number"},"stateday":{"type":"number","airbyte_type":"integer"},"converted":{"type":"string"},"creditlim":{"type":"number"},"open_date":{"type":"string","format":"date"},"shortcode":{"type":"string"},"taxexempt":{"type":"string"},"accounting":{"type":"string"},"creditcash":{"type":"string"},"custrecord":{"type":"number","airbyte_type":"integer"},"statementemail":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<client_name>_PINNACLE_FA,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@19b2619a[stream=io.airbyte.protocol.models.AirbyteStream@5025e4c5[name=ic,jsonSchema={"type":"object","properties":{"ic":{"type":"string"},"part":{"type":"string"},"model":{"type":"string"},"lfflag":{"type":"string"},"endyear":{"type":"number","airbyte_type":"integer"},"holcode":{"type":"string"},"listprice":{"type":"number","airbyte_type":"integer"},"startyear":{"type":"number","airbyte_type":"integer"},"description":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<client_name>_PINNACLE_FA,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@71d5f773[stream=io.airbyte.protocol.models.AirbyteStream@14e5ea0[name=icversion,jsonSchema={"type":"object","properties":{"icversion":{"type":"string"}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<client_name>_PINNACLE_FA,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@b7a41a2[stream=io.airbyte.protocol.models.AirbyteStream@74868fc4[name=invdetail,jsonSchema={"type":"object","properties":{"ver":{"type":"string"},"tax1":{"type":"number"},"tax2":{"type":"number"},"text":{"type":"string"},"type":{"type":"string"},"year":{"type":"string"},"model":{"type":"string"},"price":{"type":"number"},"wamnt":{"type":"number"},"wrate":{"type":"number"},"wtax1":{"type":"number"},"wtax2":{"type":"number"},"wtype":{"type":"string"},"reason":{"type":"string"},"suramt":{"type":"number"},"unique":{"type":"number","airbyte_type":"integer"},"yardid":{"type":"string"},"iccomms":{"type":"string"},"surtax1":{"type":"number"},"surtax2":{"type":"number"},"taxcode":{"type":"string"},"taxonly":{"type":"boolean"},"taxrate":{"type":"number"},"taxtype":{"type":"string"},"discount":{"type":"number"},"multiloc":{"type":"number","airbyte_type":"integer"},"surcharge":{"type":"string"},"surchtext":{"type":"string"},"threshold":{"type":"boolean"},"wosalerec":{"type":"string"},"foundprice":{"type":"number"},"invoice_id":{"type":"number","airbyte_type":"integer"},"invoice_no":{"type":"number","airbyte_type":"integer"},"itemnumber":{"type":"number","airbyte_type":"integer"},"detailnumber":{"type":"number","airbyte_type":"integer"},"parentnumber":{"type":"number","airbyte_type":"integer"},"invoicedetail_id":{"type":"number","airbyte_type":"integer"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<client_name>_PINNACLE_FA,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@2ab69048[stream=io.airbyte.protocol.models.AirbyteStream@59fe60e0[name=invoicedetail,jsonSchema={"type":"object","properties":{"tag":{"type":"string"},"vin":{"type":"string"},"part":{"type":"string"},"tax1":{"type":"number"},"tax2":{"type":"number"},"icver":{"type":"string"},"model":{"type":"string"},"price":{"type":"number"},"reason":{"type":"string"},"unique":{"type":"number","airbyte_type":"integer"},"newpart":{"type":"boolean"},"taxcode":{"type":"string"},"taxonly":{"type":"boolean"},"taxrate":{"type":"number"},"taxtext":{"type":"string"},"altindex":{"type":"string"},"corepart":{"type":"boolean"},"icnumber":{"type":"string"},"itemtext":{"type":"string"},"multiloc":{"type":"number","airbyte_type":"integer"},"vstockno":{"type":"string"},"disporder":{"type":"number","airbyte_type":"integer"},"modelyear":{"type":"number","airbyte_type":"integer"},"wosalerec":{"type":"string"},"foundprice":{"type":"number"},"iccomments":{"type":"string"},"invoice_id":{"type":"number","airbyte_type":"integer"},"itemnumber":{"type":"number","airbyte_type":"integer"},"odoreading":{"type":"number","airbyte_type":"integer"},"orderprice":{"type":"number"},"quoteprice":{"type":"number"},"detatiltype":{"type":"string"},"detailnumber":{"type":"number","airbyte_type":"integer"},"inventory_id":{"type":"number","airbyte_type":"integer"},"parentnumber":{"type":"number","airbyte_type":"integer"},"invoicedetail_id":{"type":"number","airbyte_type":"integer"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<client_name>_PINNACLE_FA,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@504d2c[stream=io.airbyte.protocol.models.AirbyteStream@40680a4d[name=invoices,jsonSchema={"type":"object","properties":{"ver":{"type":"string"},"paid":{"type":"boolean"},"pono":{"type":"number","airbyte_type":"integer"},"tax1":{"type":"number"},"tax2":{"type":"number"},"tax3":{"type":"number"},"time":{"type":"string"},"cbpid":{"type":"number","airbyte_type":"integer"},"dpbid":{"type":"number","airbyte_type":"integer"},"fcode":{"type":"string"},"frtid":{"type":"number","airbyte_type":"integer"},"stmnt":{"type":"number","airbyte_type":"integer"},"taxno":{"type":"string"},"total":{"type":"number"},"wtax1":{"type":"number"},"wtax2":{"type":"number"},"intamt":{"type":"number"},"paytax":{"type":"string"},"ro_num":{"type":"string"},"taxfrt":{"type":"boolean"},"taxgen":{"type":"boolean"},"taxlab":{"type":"boolean"},"taxsur":{"type":"boolean"},"taxtax":{"type":"boolean"},"taxwty":{"type":"boolean"},"wtotal":{"type":"number"},"claimno":{"type":"string"},"contact":{"type":"string"},"cpblink":{"type":"number","airbyte_type":"integer"},"cust_po":{"type":"string"},"dpblink":{"type":"number","airbyte_type":"integer"},"freight":{"type":"number"},"frtlink":{"type":"number","airbyte_type":"integer"},"intflag":{"type":"boolean"},"invtype":{"type":"string"},"orderby":{"type":"string"},"pay_det":{"type":"string"},"paytype":{"type":"string"},"surtax1":{"type":"number"},"surtax2":{"type":"number"},"taxcode":{"type":"string"},"taxonly":{"type":"boolean"},"taxrate":{"type":"number"},"thresh1":{"type":"number"},"thresh2":{"type":"number"},"till_no":{"type":"number","airbyte_type":"integer"},"traceid":{"type":"string"},"amtoutst":{"type":"number"},"cust_det":{"type":"string"},"custcode":{"type":"number","airbyte_type":"integer"},"custtype":{"type":"string"},"ftaxcode":{"type":"string"},"ftaxrate":{"type":"number"},"interest":{"type":"number"},"multiloc":{"type":"number","airbyte_type":"integer"},"paid_amt":{"type":"number"},"surtotal":{"type":"number"},"taxrate1":{"type":"number"},"taxrate2":{"type":"number"},"converted":{"type":"string"},"cred_code":{"type":"string"},"cred_desc":{"type":"string"},"credit_no":{"type":"number","airbyte_type":"integer"},"custrecno":{"type":"number","airbyte_type":"integer"},"deliv_det":{"type":"string"},"deliv_zip":{"type":"string"},"delrecord":{"type":"number","airbyte_type":"integer"},"dept_code":{"type":"string"},"flocaltax":{"type":"boolean"},"freightt1":{"type":"number"},"freightt2":{"type":"number"},"o_invoice":{"type":"number","airbyte_type":"integer"},"qbxfer_dt":{"type":"string","format":"date"},"quote_num":{"type":"number","airbyte_type":"integer"},"salespers":{"type":"string"},"tax1rule1":{"type":"boolean"},"tax2rule1":{"type":"boolean"},"taxexempt":{"type":"string"},"deliv_zone":{"type":"string"},"invoice_da":{"type":"string","format":"date"},"invoice_id":{"type":"number","airbyte_type":"integer"},"invoice_no":{"type":"number","airbyte_type":"integer"},"order_dept":{"type":"string"},"shipp_meth":{"type":"string"},"sourceyard":{"type":"string"},"wo_sales_p":{"type":"string"},"work_orddt":{"type":"string","format":"date"},"work_ordno":{"type":"number","airbyte_type":"integer"},"customervin":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<client_name>_PINNACLE_FA,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@5e42e6d8[stream=io.airbyte.protocol.models.AirbyteStream@74117490[name=models,jsonSchema={"type":"object","properties":{"code":{"type":"string"},"name":{"type":"string"},"hidden":{"type":"boolean"},"manuname":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<client_name>_PINNACLE_FA,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@762a7e13[stream=io.airbyte.protocol.models.AirbyteStream@761038f9[name=newstock,jsonSchema={"type":"object","properties":{"cc":{"type":"string"},"ic":{"type":"string"},"bin":{"type":"string"},"part":{"type":"string"},"year":{"type":"string"},"miles":{"type":"number","airbyte_type":"integer"},"model":{"type":"string"},"datein":{"type":"string","format":"date"},"popart":{"type":"boolean"},"rprice":{"type":"number"},"status":{"type":"string"},"tprice":{"type":"number"},"unique":{"type":"number","airbyte_type":"integer"},"wprice":{"type":"number"},"yardid":{"type":"string"},"bod_col":{"type":"string"},"resolve":{"type":"string"},"vpblink":{"type":"number","airbyte_type":"integer"},"altindex":{"type":"string"},"assembly":{"type":"boolean"},"bod_type":{"type":"string"},"box_type":{"type":"string"},"checkval":{"type":"number","airbyte_type":"integer"},"comments":{"type":"string"},"ene_type":{"type":"string"},"multiloc":{"type":"number","airbyte_type":"integer"},"storeman":{"type":"string"},"transmit":{"type":"boolean"},"verified":{"type":"string","format":"date"},"vstockno":{"type":"string"},"checkedon":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"condition":{"type":"string"},"converted":{"type":"string"},"costprice":{"type":"number"},"isprivate":{"type":"boolean"},"ticket_no":{"type":"string"},"dismantler":{"type":"string"},"doublecond":{"type":"string"},"global_acc":{"type":"string"},"holdstatus":{"type":"string"},"lastpriced":{"type":"string","format":"date"},"lastupdate":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"objectword":{"type":"number","airbyte_type":"integer"},"repair_hrs":{"type":"number"},"inventoryid":{"type":"number","airbyte_type":"integer"},"privatenote":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<client_name>_PINNACLE_FA,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@3f2d74c5[stream=io.airbyte.protocol.models.AirbyteStream@40e72244[name=oldparts,jsonSchema={"type":"object","properties":{"cc":{"type":"string"},"ic":{"type":"string"},"bin":{"type":"string"},"part":{"type":"string"},"year":{"type":"string"},"miles":{"type":"number","airbyte_type":"integer"},"model":{"type":"string"},"datein":{"type":"string","format":"date"},"rprice":{"type":"number"},"status":{"type":"string"},"tprice":{"type":"number"},"unique":{"type":"number","airbyte_type":"integer"},"wprice":{"type":"number"},"yardid":{"type":"string"},"bod_col":{"type":"string"},"resolve":{"type":"string"},"altindex":{"type":"string"},"assembly":{"type":"boolean"},"bod_type":{"type":"string"},"box_type":{"type":"string"},"checkval":{"type":"number","airbyte_type":"integer"},"comments":{"type":"string"},"ene_type":{"type":"string"},"how_sold":{"type":"string"},"multiloc":{"type":"number","airbyte_type":"integer"},"storeman":{"type":"string"},"transmit":{"type":"boolean"},"verified":{"type":"string","format":"date"},"vstockno":{"type":"string"},"who_sold":{"type":"string"},"condition":{"type":"string"},"converted":{"type":"string"},"costprice":{"type":"number"},"credit_no":{"type":"number","airbyte_type":"integer"},"restocked":{"type":"string","format":"date"},"sold_date":{"type":"string","format":"date"},"sold_time":{"type":"string"},"ticket_no":{"type":"string"},"dismantler":{"type":"string"},"doublecond":{"type":"string"},"global_acc":{"type":"string"},"holdstatus":{"type":"string"},"invoice_no":{"type":"number","airbyte_type":"integer"},"lastpriced":{"type":"string","format":"date"},"objectword":{"type":"number","airbyte_type":"integer"},"price_sold":{"type":"number"},"repair_hrs":{"type":"number"},"visibledate":{"type":"string","format":"date"},"deletereason":{"type":"string"},"inventory_id":{"type":"number","airbyte_type":"integer"},"currentstatus":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<client_name>_PINNACLE_FA,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@659806ad[stream=io.airbyte.protocol.models.AirbyteStream@12382d17[name=parts,jsonSchema={"type":"object","properties":{"code":{"type":"string"},"name":{"type":"string"},"hidden":{"type":"boolean"},"lrflag":{"type":"string"},"adpcode":{"type":"string"},"bodypart":{"type":"boolean"},"mechanical":{"type":"boolean"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<client_name>_PINNACLE_FA,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@4667f8c9[stream=io.airbyte.protocol.models.AirbyteStream@3f6b1743[name=payalloc,jsonSchema={"type":"object","properties":{"amount":{"type":"number"},"hidden":{"type":"boolean"},"descript":{"type":"string"},"whoalloc":{"type":"string"},"allocdate":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"paymentid":{"type":"number","airbyte_type":"integer"},"transtype":{"type":"string"},"allocpayid":{"type":"number","airbyte_type":"integer"},"invoice_no":{"type":"number","airbyte_type":"integer"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<client_name>_PINNACLE_FA,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@1a63d36d[stream=io.airbyte.protocol.models.AirbyteStream@49e005a3[name=payments,jsonSchema={"type":"object","properties":{"date":{"type":"string","format":"date"},"till":{"type":"number","airbyte_type":"integer"},"amount":{"type":"number"},"created":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"paytype":{"type":"string"},"bankcode":{"type":"string"},"bankname":{"type":"string"},"btrannum":{"type":"string"},"cardtype":{"type":"string"},"custlink":{"type":"number","airbyte_type":"integer"},"multiloc":{"type":"number","airbyte_type":"integer"},"saletype":{"type":"string"},"allocdate":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"btrancode":{"type":"string"},"btranname":{"type":"string"},"payeename":{"type":"string"},"paymentid":{"type":"number","airbyte_type":"integer"},"paymethod":{"type":"string"},"refnumber":{"type":"string"},"btranplace":{"type":"string"},"cardnumber":{"type":"string"},"whocreated":{"type":"string"},"work_ordno":{"type":"number","airbyte_type":"integer"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<client_name>_PINNACLE_FA,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@30b81de6[stream=io.airbyte.protocol.models.AirbyteStream@570ed5bd[name=phones,jsonSchema={"type":"object","properties":{"id":{"type":"number","airbyte_type":"integer"},"fax":{"type":"string"},"old":{"type":"boolean"},"zip":{"type":"string"},"add1":{"type":"string"},"add2":{"type":"string"},"add3":{"type":"string"},"city":{"type":"string"},"link":{"type":"number","airbyte_type":"integer"},"site":{"type":"number","airbyte_type":"integer"},"con_1":{"type":"string"},"con_2":{"type":"string"},"con_3":{"type":"string"},"email":{"type":"string"},"memo1":{"type":"string"},"memo2":{"type":"string"},"memo3":{"type":"string"},"name1":{"type":"string"},"name2":{"type":"string"},"state":{"type":"string"},"bidder":{"type":"string"},"entype":{"type":"string"},"secret":{"type":"boolean"},"seller":{"type":"string"},"source":{"type":"string"},"yardid":{"type":"string"},"chgtax2":{"type":"string"},"country":{"type":"string"},"geogloc":{"type":"string"},"phone_1":{"type":"string"},"phone_2":{"type":"string"},"phone_3":{"type":"string"},"towcomp":{"type":"string"},"traceid":{"type":"string"},"category":{"type":"string"},"discount":{"type":"number"},"frtprint":{"type":"number","airbyte_type":"integer"},"location":{"type":"string"},"taxrate1":{"type":"number"},"taxrate2":{"type":"number"},"converted":{"type":"string"},"shortcode":{"type":"string"},"userfield1":{"type":"string"},"userfield2":{"type":"string"},"userfield3":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<client_name>_PINNACLE_FA,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@53728c8a[stream=io.airbyte.protocol.models.AirbyteStream@1af6565a[name=purchaseledger,jsonSchema={"type":"object","properties":{"vendor":{"type":"number","airbyte_type":"integer"},"multiloc":{"type":"number","airbyte_type":"integer"},"ponumber":{"type":"number","airbyte_type":"integer"},"saletype":{"type":"string"},"trantype":{"type":"string"},"username":{"type":"string"},"payamount":{"type":"number"},"billamount":{"type":"number"},"createddate":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"description":{"type":"string"},"allocateddate":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"informationonly":{"type":"boolean"},"purchaseorder_id":{"type":"number","airbyte_type":"integer"},"purchaseledger_id":{"type":"number","airbyte_type":"integer"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<client_name>_PINNACLE_FA,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@6ad12fcf[stream=io.airbyte.protocol.models.AirbyteStream@4bd3bc15[name=purchaseorder,jsonSchema={"type":"object","properties":{"vers":{"type":"number","airbyte_type":"integer"},"total":{"type":"number"},"vendor":{"type":"number","airbyte_type":"integer"},"ordered":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"updated":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"category":{"type":"string"},"multiloc":{"type":"number","airbyte_type":"integer"},"ponumber":{"type":"number","airbyte_type":"integer"},"ordertype":{"type":"string"},"totaltax1":{"type":"number"},"totaltax2":{"type":"number"},"cancelnote":{"type":"string"},"whocreated":{"type":"string"},"datecreated":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"freightlaid":{"type":"boolean"},"orderstatus":{"type":"string"},"cancelreason":{"type":"string"},"vendorcontact":{"type":"string"},"whoupdated_id":{"type":"string"},"remote_po_sent":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"remotewonumber":{"type":"number","airbyte_type":"integer"},"purchaseorder_id":{"type":"number","airbyte_type":"integer"},"vendorinvoicenumber":{"type":"string"},"credited_purchaseorder_id":{"type":"number","airbyte_type":"integer"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<client_name>_PINNACLE_FA,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@c026f39[stream=io.airbyte.protocol.models.AirbyteStream@24eeac65[name=purchaseorderdetail,jsonSchema={"type":"object","properties":{"part":{"type":"string"},"icver":{"type":"string"},"model":{"type":"string"},"unique":{"type":"number","airbyte_type":"integer"},"itemnew":{"type":"boolean"},"mileskm":{"type":"boolean"},"icnumber":{"type":"string"},"itemtax1":{"type":"number"},"itemtax2":{"type":"number"},"itemtext":{"type":"string"},"quantity":{"type":"number","airbyte_type":"integer"},"taxrate1":{"type":"number"},"taxrate2":{"type":"number"},"vstockno":{"type":"string"},"disporder":{"type":"number","airbyte_type":"integer"},"istaxable":{"type":"boolean"},"itemprice":{"type":"number"},"modelyear":{"type":"number","airbyte_type":"integer"},"vendortag":{"type":"string"},"vendorvin":{"type":"string"},"cancelnote":{"type":"string"},"itemnumber":{"type":"number","airbyte_type":"integer"},"detatiltype":{"type":"string"},"cancelreason":{"type":"string"},"dateexpected":{"type":"string","format":"date"},"datereceived":{"type":"string","format":"date"},"detailnumber":{"type":"number","airbyte_type":"integer"},"parentnumber":{"type":"number","airbyte_type":"integer"},"taxinclusive":{"type":"boolean"},"datecancelled":{"type":"string","format":"date"},"totalitemtax1":{"type":"number"},"totalitemtax2":{"type":"number"},"totalitemprice":{"type":"number"},"vendorvstockno":{"type":"string"},"vendorinvnumber":{"type":"number","airbyte_type":"integer"},"purchaseorder_id":{"type":"number","airbyte_type":"integer"},"dateaddedintoinventory":{"type":"string","format":"date"},"purchaseorderdetail_id":{"type":"number","airbyte_type":"integer"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<client_name>_PINNACLE_FA,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@47a24060[stream=io.airbyte.protocol.models.AirbyteStream@11c76f95[name=quotes,jsonSchema={"type":"object","properties":{"tax1":{"type":"number"},"tax2":{"type":"number"},"vers":{"type":"string"},"taxno":{"type":"string"},"total":{"type":"number"},"wtax1":{"type":"number"},"wtax2":{"type":"number"},"ro_num":{"type":"string"},"wtotal":{"type":"number"},"claimno":{"type":"string"},"cust_po":{"type":"string"},"freight":{"type":"number"},"orderby":{"type":"string"},"paytype":{"type":"string"},"surtax1":{"type":"number"},"surtax2":{"type":"number"},"till_no":{"type":"number","airbyte_type":"integer"},"traceid":{"type":"string"},"updated":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"custcode":{"type":"number","airbyte_type":"integer"},"custtype":{"type":"string"},"multiloc":{"type":"number","airbyte_type":"integer"},"surtotal":{"type":"number"},"deliv_zip":{"type":"string"},"delrecord":{"type":"number","airbyte_type":"integer"},"dept_code":{"type":"string"},"freightt1":{"type":"number"},"freightt2":{"type":"number"},"salespers":{"type":"string"},"taxexempt":{"type":"string"},"order_dept":{"type":"string"},"shipp_meth":{"type":"string"},"wo_sales_p":{"type":"string"},"datecreated":{"type":"string","format":"date"},"ordernumber":{"type":"number","airbyte_type":"integer"},"orderstatus":{"type":"string"},"timecreated":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<client_name>_PINNACLE_FA,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@ea3b133[stream=io.airbyte.protocol.models.AirbyteStream@5fffb906[name=salesallocation,jsonSchema={"type":"object","properties":{"user":{"type":"string"},"amount":{"type":"number"},"hidden":{"type":"boolean"},"multiloc":{"type":"number","airbyte_type":"integer"},"ledgerpayid":{"type":"number","airbyte_type":"integer"},"allocationid":{"type":"number","airbyte_type":"integer"},"ledgerbillid":{"type":"number","airbyte_type":"integer"},"allocationdate":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<client_name>_PINNACLE_FA,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@a0b43d9[stream=io.airbyte.protocol.models.AirbyteStream@209a2eca[name=salesledger,jsonSchema={"type":"object","properties":{"user":{"type":"string"},"hidden":{"type":"boolean"},"created":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"custlink":{"type":"number","airbyte_type":"integer"},"ledgerid":{"type":"number","airbyte_type":"integer"},"multiloc":{"type":"number","airbyte_type":"integer"},"saletype":{"type":"string"},"allocated":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"payamount":{"type":"number"},"paymentid":{"type":"number","airbyte_type":"integer"},"transtype":{"type":"string"},"billamount":{"type":"number"},"invoice_id":{"type":"number","airbyte_type":"integer"},"description":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<client_name>_PINNACLE_FA,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@33a339c3[stream=io.airbyte.protocol.models.AirbyteStream@11b69138[name=search,jsonSchema={"type":"object","properties":{"ic":{"type":"string"},"date":{"type":"string","format":"date"},"part":{"type":"string"},"time":{"type":"string"},"user":{"type":"string"},"year":{"type":"number","airbyte_type":"integer"},"model":{"type":"string"},"status":{"type":"string"},"altindex":{"type":"string"},"custcode":{"type":"number","airbyte_type":"integer"},"duration":{"type":"number"},"multiloc":{"type":"number","airbyte_type":"integer"},"salesrec":{"type":"string"},"search_id":{"type":"number","airbyte_type":"integer"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<client_name>_PINNACLE_FA,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@41731d5c[stream=io.airbyte.protocol.models.AirbyteStream@30ee87c6[name=setprice,jsonSchema={"type":"object","properties":{"core":{"type":"number"},"list":{"type":"number"},"ic_no":{"type":"string"},"model":{"type":"string"},"price":{"type":"number"},"price2":{"type":"number"},"newcost":{"type":"number"},"surplus":{"type":"number"},"core_buy":{"type":"number"},"coreupdn":{"type":"string"},"minprice":{"type":"number"},"new_date":{"type":"string","format":"date"},"core_date":{"type":"string","format":"date"},"core_fact":{"type":"number"},"nminlevel":{"type":"number","airbyte_type":"integer"},"npmarkup1":{"type":"number"},"npmarkup2":{"type":"number"},"part_code":{"type":"string"},"priceupdn":{"type":"string"},"recommend":{"type":"string"},"price2date":{"type":"string","format":"date"},"price_date":{"type":"string","format":"date"},"price_fact":{"type":"number"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<client_name>_PINNACLE_FA,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@1a29cd39[stream=io.airbyte.protocol.models.AirbyteStream@3f33b015[name=sites,jsonSchema={"type":"object","properties":{"fax":{"type":"string"},"zip":{"type":"string"},"city":{"type":"string"},"email":{"type":"string"},"state":{"type":"string"},"taxid":{"type":"string"},"urgid":{"type":"string"},"phone1":{"type":"string"},"phone2":{"type":"string"},"country":{"type":"string"},"yardurl":{"type":"string"},"address1":{"type":"string"},"address2":{"type":"string"},"address3":{"type":"string"},"edenname":{"type":"string"},"multiloc":{"type":"number","airbyte_type":"integer"},"yardname":{"type":"string"},"edenstore":{"type":"number","airbyte_type":"integer"},"shortcode":{"type":"string"},"maincontact":{"type":"string"},"dealernumber":{"type":"string"},"licensenumber":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<client_name>_PINNACLE_FA,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@6673c352[stream=io.airbyte.protocol.models.AirbyteStream@22e7a8ed[name=stock,jsonSchema={"type":"object","properties":{"cc":{"type":"string"},"ic":{"type":"string"},"bin":{"type":"string"},"part":{"type":"string"},"year":{"type":"string"},"miles":{"type":"number","airbyte_type":"integer"},"model":{"type":"string"},"datein":{"type":"string","format":"date"},"popart":{"type":"boolean"},"rprice":{"type":"number"},"status":{"type":"string"},"tprice":{"type":"number"},"unique":{"type":"number","airbyte_type":"integer"},"wprice":{"type":"number"},"yardid":{"type":"string"},"bod_col":{"type":"string"},"resolve":{"type":"string"},"altindex":{"type":"string"},"assembly":{"type":"boolean"},"bod_type":{"type":"string"},"box_type":{"type":"string"},"checkval":{"type":"number","airbyte_type":"integer"},"comments":{"type":"string"},"ene_type":{"type":"string"},"multiloc":{"type":"number","airbyte_type":"integer"},"storeman":{"type":"string"},"transmit":{"type":"boolean"},"verified":{"type":"string","format":"date"},"vstockno":{"type":"string"},"checkedon":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"condition":{"type":"string"},"converted":{"type":"string"},"costprice":{"type":"number"},"isprivate":{"type":"boolean"},"ticket_no":{"type":"string"},"dismantler":{"type":"string"},"doublecond":{"type":"string"},"global_acc":{"type":"string"},"holdstatus":{"type":"string"},"lastpriced":{"type":"string","format":"date"},"lastupdate":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"objectword":{"type":"number","airbyte_type":"integer"},"repair_hrs":{"type":"number"},"privatenote":{"type":"string"},"visibledate":{"type":"string","format":"date"},"inventory_id":{"type":"number","airbyte_type":"integer"},"currentstatus":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<client_name>_PINNACLE_FA,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@7673e98d[stream=io.airbyte.protocol.models.AirbyteStream@54e25c4e[name=vehistok,jsonSchema={"type":"object","properties":{"abs":{"type":"string"},"bui":{"type":"boolean"},"belt":{"type":"string"},"cost":{"type":"number"},"jack":{"type":"string"},"keys":{"type":"string"},"log1":{"type":"boolean"},"log2":{"type":"boolean"},"log3":{"type":"boolean"},"log4":{"type":"boolean"},"log5":{"type":"boolean"},"trim":{"type":"string"},"year":{"type":"number","airbyte_type":"integer"},"doors":{"type":"string"},"keyno":{"type":"string"},"miles":{"type":"number","airbyte_type":"integer"},"orgno":{"type":"string"},"regno":{"type":"string"},"stall":{"type":"string"},"airbag":{"type":"string"},"aircon":{"type":"string"},"cruise":{"type":"string"},"eng_no":{"type":"string"},"fender":{"type":"string"},"no_cyl":{"type":"string"},"status":{"type":"string"},"vin_no":{"type":"string"},"weight":{"type":"number"},"wheels":{"type":"string"},"arnauto":{"type":"string"},"bakcode":{"type":"string"},"battery":{"type":"string"},"eng_no2":{"type":"string"},"ext_col":{"type":"string"},"int_col":{"type":"string"},"mirrors":{"type":"string"},"miscstk":{"type":"boolean"},"mod_sys":{"type":"string"},"numtags":{"type":"number","airbyte_type":"integer"},"spoiler":{"type":"string"},"sunroof":{"type":"string"},"towhook":{"type":"string"},"user_id":{"type":"string"},"bid_comm":{"type":"number"},"comments":{"type":"string"},"dism_end":{"type":"string"},"eng_size":{"type":"number"},"handheld":{"type":"boolean"},"inv_date":{"type":"string","format":"date"},"location":{"type":"string"},"meldcode":{"type":"string"},"misccost":{"type":"number"},"multiloc":{"type":"number","airbyte_type":"integer"},"no_gears":{"type":"string"},"numextra":{"type":"number","airbyte_type":"integer"},"part_req":{"type":"string"},"pool_fee":{"type":"number"},"pu_notes":{"type":"string"},"radio_yn":{"type":"string"},"tot_tags":{"type":"number"},"tow_cheq":{"type":"string"},"vstockno":{"type":"string"},"axle_code":{"type":"string"},"breakdate":{"type":"string","format":"date"},"claim_num":{"type":"string"},"converted":{"type":"string"},"duplicode":{"type":"string"},"fuel_type":{"type":"string"},"hasimages":{"type":"boolean"},"owner_lnk":{"type":"number","airbyte_type":"integer"},"pick_name":{"type":"string"},"pinpadtot":{"type":"number"},"prnt_date":{"type":"string","format":"date"},"processed":{"type":"string"},"prod_date":{"type":"string","format":"date"},"purch_chq":{"type":"string"},"sold_date":{"type":"string","format":"date"},"title_num":{"type":"string"},"tot_extra":{"type":"number"},"transcode":{"type":"string"},"transdate":{"type":"string","format":"date"},"transtime":{"type":"string"},"whoto_lnk":{"type":"number","airbyte_type":"integer"},"whoto_mem":{"type":"string"},"adjust_nam":{"type":"string"},"anticiprev":{"type":"number"},"antrevb4in":{"type":"number"},"arrive_dat":{"type":"string","format":"date"},"bidder_lnk":{"type":"number","airbyte_type":"integer"},"bidder_mem":{"type":"string"},"body_style":{"type":"string"},"clear_date":{"type":"string","format":"date"},"crush_date":{"type":"string","format":"date"},"curr_sales":{"type":"number"},"delete_dat":{"type":"string","format":"date"},"depollcost":{"type":"number"},"dism_comms":{"type":"string"},"dism_start":{"type":"string"},"dismantler":{"type":"string"},"drive_type":{"type":"string"},"driver_lnk":{"type":"number","airbyte_type":"integer"},"dsmntl_dat":{"type":"string","format":"date"},"elect_wind":{"type":"string"},"enter_date":{"type":"string","format":"date"},"est_arrdat":{"type":"string","format":"date"},"extcolcode":{"type":"string"},"forsale_pr":{"type":"number"},"indsmt_dat":{"type":"string","format":"date"},"intrimcode":{"type":"string"},"not_tow_dt":{"type":"string","format":"date"},"notify_dat":{"type":"string","format":"date"},"part_added":{"type":"string"},"pickup_lnk":{"type":"number","airbyte_type":"integer"},"pickup_mem":{"type":"string"},"power_lock":{"type":"string"},"powersteer":{"type":"string"},"prebid_lnk":{"type":"number","airbyte_type":"integer"},"prebid_mem":{"type":"string"},"prm_damage":{"type":"string"},"proj_sales":{"type":"number"},"purch_date":{"type":"string","format":"date"},"sale_reduc":{"type":"number"},"sec_damage":{"type":"string"},"seller_lnk":{"type":"number","airbyte_type":"integer"},"seller_mem":{"type":"string"},"sold_price":{"type":"number"},"sparewheel":{"type":"string"},"store_cheq":{"type":"string"},"store_chrg":{"type":"number"},"suspension":{"type":"string"},"title_stat":{"type":"string"},"title_type":{"type":"string"},"tow_charge":{"type":"number"},"towable_yn":{"type":"string"},"towcom_lnk":{"type":"number","airbyte_type":"integer"},"towcom_mem":{"type":"string"},"trans_type":{"type":"string"},"v_classify":{"type":"string"},"vendorcost":{"type":"number"},"wheel_size":{"type":"number","airbyte_type":"integer"},"xtra_damag":{"type":"string"},"glassscolor":{"type":"string"},"licenseplate":{"type":"string"},"stocknumber_id":{"type":"number","airbyte_type":"integer"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<client_name>_PINNACLE_FA,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}]],additionalProperties={}],failures=[]]
2023-02-09 16:23:04 [32mINFO[m i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):214 - Sync summary length: 41996
2023-02-09 16:23:04 [32mINFO[m i.a.c.t.TemporalUtils(withBackgroundHeartbeat):283 - Stopping temporal heartbeating...
2023-02-09 16:23:05 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to get normalization statuses
2023-02-09 16:23:06 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):138 - Cloud storage job log path: /workspace/14503/0/logs.log
2023-02-09 16:23:06 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.29
2023-02-09 16:23:06 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2023-02-09 16:23:06 [32mINFO[m i.a.w.n.DefaultNormalizationRunner(runProcess):125 - Running with normalization version: airbyte/normalization-snowflake:0.2.25
2023-02-09 16:23:06 [32mINFO[m i.a.w.p.KubeProcessFactory(create):96 - Attempting to start pod = normalization-snowflake-normalize-14503-0-blria for airbyte/normalization-snowflake:0.2.25 with resources io.airbyte.config.ResourceRequirements@4a14b0b5[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2023-02-09 16:23:06 [32mINFO[m i.a.w.p.KubeProcessFactory(create):99 - normalization-snowflake-normalize-14503-0-blria stdoutLocalPort = 9008
2023-02-09 16:23:06 [32mINFO[m i.a.w.p.KubeProcessFactory(create):102 - normalization-snowflake-normalize-14503-0-blria stderrLocalPort = 9009
2023-02-09 16:23:06 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2023-02-09 16:23:06 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- START DEFAULT NORMALIZATION -----
2023-02-09 16:23:06 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2023-02-09 16:23:06 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):602 - Creating stdout socket server...
2023-02-09 16:23:06 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$11):620 - Creating stderr socket server...
2023-02-09 16:23:06 [32mINFO[m i.a.w.p.KubePodProcess(<init>):533 - Creating pod normalization-snowflake-normalize-14503-0-blria...
2023-02-09 16:23:06 [32mINFO[m i.a.w.p.KubePodProcess(waitForInitPodToRun):313 - Waiting for init container to be ready before copying files...
2023-02-09 16:23:06 [32mINFO[m i.a.w.p.KubePodProcess(waitForInitPodToRun):317 - Init container present..
2023-02-09 16:23:07 [32mINFO[m i.a.w.p.KubePodProcess(waitForInitPodToRun):320 - Init container ready..
2023-02-09 16:23:07 [32mINFO[m i.a.w.p.KubePodProcess(<init>):564 - Copying files...
2023-02-09 16:23:07 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - Uploading file: destination_config.json
2023-02-09 16:23:07 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):270 - kubectl cp /tmp/c0198a64-ebb0-4f50-903a-31b5ed01d17a/destination_config.json default/normalization-snowflake-normalize-14503-0-blria:/config/destination_config.json -c init
2023-02-09 16:23:07 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):273 - Waiting for kubectl cp to complete
2023-02-09 16:23:08 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):287 - kubectl cp complete, closing process
2023-02-09 16:23:08 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - Uploading file: destination_catalog.json
2023-02-09 16:23:08 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):270 - kubectl cp /tmp/fab9ea29-091e-422f-8da2-66c02363c358/destination_catalog.json default/normalization-snowflake-normalize-14503-0-blria:/config/destination_catalog.json -c init
2023-02-09 16:23:08 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):273 - Waiting for kubectl cp to complete
2023-02-09 16:23:08 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):287 - kubectl cp complete, closing process
2023-02-09 16:23:08 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - Uploading file: FINISHED_UPLOADING
2023-02-09 16:23:08 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):270 - kubectl cp /tmp/7911bf4a-67fc-4a7d-8a1e-aff6b19cfee7/FINISHED_UPLOADING default/normalization-snowflake-normalize-14503-0-blria:/config/FINISHED_UPLOADING -c init
2023-02-09 16:23:08 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):273 - Waiting for kubectl cp to complete
2023-02-09 16:23:08 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):287 - kubectl cp complete, closing process
2023-02-09 16:23:08 [32mINFO[m i.a.w.p.KubePodProcess(<init>):567 - Waiting until pod is ready...
2023-02-09 16:23:24 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):611 - Setting stdout...
2023-02-09 16:23:24 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$11):623 - Setting stderr...
2023-02-09 16:23:27 [32mINFO[m i.a.w.p.KubePodProcess(<init>):583 - Reading pod IP...
2023-02-09 16:23:27 [32mINFO[m i.a.w.p.KubePodProcess(<init>):585 - Pod IP: 10.226.16.204
2023-02-09 16:23:27 [32mINFO[m i.a.w.p.KubePodProcess(<init>):592 - Using null stdin output stream...
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_tables/<client_name>_PINNACLE_FA/CUSTOMERS.sql from customers
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/IC_AB1.sql from ic
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/IC_AB2.sql from ic
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/IC_AB3.sql from ic
2023-02-09 16:23:27 [42mnormalization[0m >   Adding drop table hook for IC_SCD to IC
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_tables/<client_name>_PINNACLE_FA/IC.sql from ic
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/ICVERSION_AB1.sql from icversion
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/ICVERSION_AB2.sql from icversion
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/ICVERSION_AB3.sql from icversion
2023-02-09 16:23:27 [42mnormalization[0m >   Adding drop table hook for ICVERSION_SCD to ICVERSION
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_tables/<client_name>_PINNACLE_FA/ICVERSION.sql from icversion
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/INVDETAIL_AB1.sql from invdetail
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/INVDETAIL_AB2.sql from invdetail
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/INVDETAIL_AB3.sql from invdetail
2023-02-09 16:23:27 [42mnormalization[0m >   Adding drop table hook for INVDETAIL_SCD to INVDETAIL
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_tables/<client_name>_PINNACLE_FA/INVDETAIL.sql from invdetail
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/INVOICEDETAIL_AB1.sql from invoicedetail
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/INVOICEDETAIL_AB2.sql from invoicedetail
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/INVOICEDETAIL_AB3.sql from invoicedetail
2023-02-09 16:23:27 [42mnormalization[0m >   Adding drop table hook for INVOICEDETAIL_SCD to INVOICEDETAIL
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_tables/<client_name>_PINNACLE_FA/INVOICEDETAIL.sql from invoicedetail
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/INVOICES_AB1.sql from invoices
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/INVOICES_AB2.sql from invoices
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/INVOICES_AB3.sql from invoices
2023-02-09 16:23:27 [42mnormalization[0m >   Adding drop table hook for INVOICES_SCD to INVOICES
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_tables/<client_name>_PINNACLE_FA/INVOICES.sql from invoices
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/MODELS_AB1.sql from models
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/MODELS_AB2.sql from models
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/MODELS_AB3.sql from models
2023-02-09 16:23:27 [42mnormalization[0m >   Adding drop table hook for MODELS_SCD to MODELS
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_tables/<client_name>_PINNACLE_FA/MODELS.sql from models
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/NEWSTOCK_AB1.sql from newstock
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/NEWSTOCK_AB2.sql from newstock
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/NEWSTOCK_AB3.sql from newstock
2023-02-09 16:23:27 [42mnormalization[0m >   Adding drop table hook for NEWSTOCK_SCD to NEWSTOCK
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_tables/<client_name>_PINNACLE_FA/NEWSTOCK.sql from newstock
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/OLDPARTS_AB1.sql from oldparts
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/OLDPARTS_AB2.sql from oldparts
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/OLDPARTS_AB3.sql from oldparts
2023-02-09 16:23:27 [42mnormalization[0m >   Adding drop table hook for OLDPARTS_SCD to OLDPARTS
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_tables/<client_name>_PINNACLE_FA/OLDPARTS.sql from oldparts
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/PARTS_AB1.sql from parts
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/PARTS_AB2.sql from parts
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/PARTS_AB3.sql from parts
2023-02-09 16:23:27 [42mnormalization[0m >   Adding drop table hook for PARTS_SCD to PARTS
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_tables/<client_name>_PINNACLE_FA/PARTS.sql from parts
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/PAYALLOC_AB1.sql from payalloc
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/PAYALLOC_AB2.sql from payalloc
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/PAYALLOC_AB3.sql from payalloc
2023-02-09 16:23:27 [42mnormalization[0m >   Adding drop table hook for PAYALLOC_SCD to PAYALLOC
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_tables/<client_name>_PINNACLE_FA/PAYALLOC.sql from payalloc
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/PAYMENTS_AB1.sql from payments
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/PAYMENTS_AB2.sql from payments
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/PAYMENTS_AB3.sql from payments
2023-02-09 16:23:27 [42mnormalization[0m >   Adding drop table hook for PAYMENTS_SCD to PAYMENTS
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_tables/<client_name>_PINNACLE_FA/PAYMENTS.sql from payments
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/PHONES_AB1.sql from phones
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/PHONES_AB2.sql from phones
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/PHONES_AB3.sql from phones
2023-02-09 16:23:27 [42mnormalization[0m >   Adding drop table hook for PHONES_SCD to PHONES
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_tables/<client_name>_PINNACLE_FA/PHONES.sql from phones
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/PURCHASELEDGER_AB1.sql from purchaseledger
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/PURCHASELEDGER_AB2.sql from purchaseledger
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/PURCHASELEDGER_AB3.sql from purchaseledger
2023-02-09 16:23:27 [42mnormalization[0m >   Adding drop table hook for PURCHASELEDGER_SCD to PURCHASELEDGER
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_tables/<client_name>_PINNACLE_FA/PURCHASELEDGER.sql from purchaseledger
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/PURCHASEORDER_AB1.sql from purchaseorder
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/PURCHASEORDER_AB2.sql from purchaseorder
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/PURCHASEORDER_AB3.sql from purchaseorder
2023-02-09 16:23:27 [42mnormalization[0m >   Adding drop table hook for PURCHASEORDER_SCD to PURCHASEORDER
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_tables/<client_name>_PINNACLE_FA/PURCHASEORDER.sql from purchaseorder
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/PURCHASEORDERDETAIL_AB1.sql from purchaseorderdetail
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/PURCHASEORDERDETAIL_AB2.sql from purchaseorderdetail
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/PURCHASEORDERDETAIL_AB3.sql from purchaseorderdetail
2023-02-09 16:23:27 [42mnormalization[0m >   Adding drop table hook for PURCHASEORDERDETAIL_SCD to PURCHASEORDERDETAIL
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_tables/<client_name>_PINNACLE_FA/PURCHASEORDERDETAIL.sql from purchaseorderdetail
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/QUOTES_AB1.sql from quotes
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/QUOTES_AB2.sql from quotes
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/QUOTES_AB3.sql from quotes
2023-02-09 16:23:27 [42mnormalization[0m >   Adding drop table hook for QUOTES_SCD to QUOTES
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_tables/<client_name>_PINNACLE_FA/QUOTES.sql from quotes
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/SALESALLOCATION_AB1.sql from salesallocation
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/SALESALLOCATION_AB2.sql from salesallocation
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/SALESALLOCATION_AB3.sql from salesallocation
2023-02-09 16:23:27 [42mnormalization[0m >   Adding drop table hook for SALESALLOCATION_SCD to SALESALLOCATION
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_tables/<client_name>_PINNACLE_FA/SALESALLOCATION.sql from salesallocation
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/SALESLEDGER_AB1.sql from salesledger
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/SALESLEDGER_AB2.sql from salesledger
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/SALESLEDGER_AB3.sql from salesledger
2023-02-09 16:23:27 [42mnormalization[0m >   Adding drop table hook for SALESLEDGER_SCD to SALESLEDGER
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_tables/<client_name>_PINNACLE_FA/SALESLEDGER.sql from salesledger
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/SEARCH_AB1.sql from search
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/SEARCH_AB2.sql from search
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/SEARCH_AB3.sql from search
2023-02-09 16:23:27 [42mnormalization[0m >   Adding drop table hook for SEARCH_SCD to SEARCH
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_tables/<client_name>_PINNACLE_FA/SEARCH.sql from search
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/SETPRICE_AB1.sql from setprice
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/SETPRICE_AB2.sql from setprice
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/SETPRICE_AB3.sql from setprice
2023-02-09 16:23:27 [42mnormalization[0m >   Adding drop table hook for SETPRICE_SCD to SETPRICE
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_tables/<client_name>_PINNACLE_FA/SETPRICE.sql from setprice
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/SITES_AB1.sql from sites
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/SITES_AB2.sql from sites
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/SITES_AB3.sql from sites
2023-02-09 16:23:27 [42mnormalization[0m >   Adding drop table hook for SITES_SCD to SITES
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_tables/<client_name>_PINNACLE_FA/SITES.sql from sites
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/STOCK_AB1.sql from stock
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/STOCK_AB2.sql from stock
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/STOCK_AB3.sql from stock
2023-02-09 16:23:27 [42mnormalization[0m >   Adding drop table hook for STOCK_SCD to STOCK
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_tables/<client_name>_PINNACLE_FA/STOCK.sql from stock
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/VEHISTOK_AB1.sql from vehistok
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/VEHISTOK_AB2.sql from vehistok
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_ctes/<client_name>_PINNACLE_FA/VEHISTOK_AB3.sql from vehistok
2023-02-09 16:23:27 [42mnormalization[0m >   Adding drop table hook for VEHISTOK_SCD to VEHISTOK
2023-02-09 16:23:27 [42mnormalization[0m >   Generating airbyte_tables/<client_name>_PINNACLE_FA/VEHISTOK.sql from vehistok
2023-02-09 16:23:27 [42mnormalization[0m > detected no config file for ssh, assuming ssh is off.
2023-02-09 16:23:29 [42mnormalization[0m >            [--event-buffer-size EVENT_BUFFER_SIZE]
2023-02-09 16:23:29 [42mnormalization[0m >   --event-buffer-size EVENT_BUFFER_SIZE
2023-02-09 16:23:29 [42mnormalization[0m > DBT >=1.0.0 detected; using 10K event buffer size
2023-02-09 16:23:31 [42mnormalization[0m > Running with dbt=1.0.0
2023-02-09 16:23:31 [42mnormalization[0m > Partial parse save file not found. Starting full parse.
2023-02-09 16:23:36 [42mnormalization[0m > [[33mWARNING[0m]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources.
There are 2 unused configuration paths:
- models.airbyte_utils.generated.airbyte_incremental
- models.airbyte_utils.generated.airbyte_views

2023-02-09 16:23:36 [42mnormalization[0m > Found 104 models, 0 tests, 0 snapshots, 0 analyses, 593 macros, 0 operations, 0 seed files, 26 sources, 0 exposures, 0 metrics
2023-02-09 16:23:37 [42mnormalization[0m > Concurrency: 5 threads (target='prod')
2023-02-09 16:23:43 [42mnormalization[0m > 1 of 26 START table model <client_name>_PINNACLE_FA.ICVERSION................................................................... [RUN]
2023-02-09 16:23:43 [42mnormalization[0m > 2 of 26 START table model <client_name>_PINNACLE_FA.IC.......................................................................... [RUN]
2023-02-09 16:23:44 [42mnormalization[0m > 4 of 26 START table model <client_name>_PINNACLE_FA.ADDRESS..................................................................... [RUN]
2023-02-09 16:23:44 [42mnormalization[0m > 3 of 26 START table model <client_name>_PINNACLE_FA.ADJUSTMENT.................................................................. [RUN]
2023-02-09 16:23:44 [42mnormalization[0m > 5 of 26 START table model <client_name>_PINNACLE_FA.CUSTOMERS................................................................... [RUN]
2023-02-09 16:23:47 [42mnormalization[0m > 1 of 26 OK created table model <client_name>_PINNACLE_FA.ICVERSION.............................................................. [[32mSUCCESS 1[0m in 3.45s]
2023-02-09 16:23:47 [42mnormalization[0m > 6 of 26 START table model <client_name>_PINNACLE_FA.MODELS...................................................................... [RUN]
2023-02-09 16:23:48 [42mnormalization[0m > 3 of 26 OK created table model <client_name>_PINNACLE_FA.ADJUSTMENT............................................................. [[32mSUCCESS 1[0m in 4.14s]
2023-02-09 16:23:48 [42mnormalization[0m > 7 of 26 START table model <client_name>_PINNACLE_FA.INVOICEDETAIL............................................................... [RUN]
2023-02-09 16:23:49 [42mnormalization[0m > 6 of 26 OK created table model <client_name>_PINNACLE_FA.MODELS................................................................. [[32mSUCCESS 1[0m in 2.22s]
2023-02-09 16:23:50 [42mnormalization[0m > 4 of 26 OK created table model <client_name>_PINNACLE_FA.ADDRESS................................................................ [[32mSUCCESS 1[0m in 5.92s]
2023-02-09 16:23:50 [42mnormalization[0m > 8 of 26 START table model <client_name>_PINNACLE_FA.PAYALLOC.................................................................... [RUN]
2023-02-09 16:23:50 [42mnormalization[0m > 5 of 26 OK created table model <client_name>_PINNACLE_FA.CUSTOMERS.............................................................. [[32mSUCCESS 1[0m in 5.82s]
2023-02-09 16:23:50 [42mnormalization[0m > 9 of 26 START table model <client_name>_PINNACLE_FA.INVDETAIL................................................................... [RUN]
2023-02-09 16:23:53 [42mnormalization[0m > 10 of 26 START table model <client_name>_PINNACLE_FA.PARTS...................................................................... [RUN]
2023-02-09 16:23:55 [42mnormalization[0m > 10 of 26 OK created table model <client_name>_PINNACLE_FA.PARTS................................................................. [[32mSUCCESS 1[0m in 2.17s]
2023-02-09 16:23:55 [42mnormalization[0m > 11 of 26 START table model <client_name>_PINNACLE_FA.NEWSTOCK................................................................... [RUN]
2023-02-09 16:23:59 [42mnormalization[0m > 11 of 26 OK created table model <client_name>_PINNACLE_FA.NEWSTOCK.............................................................. [[32mSUCCESS 1[0m in 3.61s]
2023-02-09 16:23:59 [42mnormalization[0m > 12 of 26 START table model <client_name>_PINNACLE_FA.OLDPARTS................................................................... [RUN]
2023-02-09 16:24:01 [42mnormalization[0m > 8 of 26 OK created table model <client_name>_PINNACLE_FA.PAYALLOC............................................................... [[32mSUCCESS 1[0m in 11.38s]
2023-02-09 16:24:01 [42mnormalization[0m > 13 of 26 START table model <client_name>_PINNACLE_FA.PAYMENTS................................................................... [RUN]
2023-02-09 16:24:05 [42mnormalization[0m > 2 of 26 OK created table model <client_name>_PINNACLE_FA.IC..................................................................... [[32mSUCCESS 1[0m in 21.87s]
2023-02-09 16:24:05 [42mnormalization[0m > 14 of 26 START table model <client_name>_PINNACLE_FA.PURCHASELEDGER............................................................. [RUN]
2023-02-09 16:24:12 [42mnormalization[0m > 14 of 26 OK created table model <client_name>_PINNACLE_FA.PURCHASELEDGER........................................................ [[32mSUCCESS 1[0m in 6.43s]
2023-02-09 16:24:12 [42mnormalization[0m > 15 of 26 START table model <client_name>_PINNACLE_FA.PHONES..................................................................... [RUN]
2023-02-09 16:24:14 [42mnormalization[0m > 13 of 26 OK created table model <client_name>_PINNACLE_FA.PAYMENTS.............................................................. [[32mSUCCESS 1[0m in 13.09s]
2023-02-09 16:24:14 [42mnormalization[0m > 16 of 26 START table model <client_name>_PINNACLE_FA.PURCHASEORDER.............................................................. [RUN]
2023-02-09 16:24:20 [42mnormalization[0m > 15 of 26 OK created table model <client_name>_PINNACLE_FA.PHONES................................................................ [[32mSUCCESS 1[0m in 7.89s]
2023-02-09 16:24:20 [42mnormalization[0m > 17 of 26 START table model <client_name>_PINNACLE_FA.QUOTES..................................................................... [RUN]
2023-02-09 16:24:21 [42mnormalization[0m > 17 of 26 OK created table model <client_name>_PINNACLE_FA.QUOTES................................................................ [[32mSUCCESS 1[0m in 1.64s]
2023-02-09 16:24:21 [42mnormalization[0m > 18 of 26 START table model <client_name>_PINNACLE_FA.SALESLEDGER................................................................ [RUN]
2023-02-09 16:23:29 [32mINFO[m i.a.w.n.NormalizationAirbyteStreamFactory(filterOutAndHandleNonAirbyteMessageLines):104 -
2023-02-09 16:23:29 [32mINFO[m i.a.w.n.NormalizationAirbyteStreamFactory(filterOutAndHandleNonAirbyteMessageLines):104 -
2023-02-09 16:24:31 [42mnormalization[0m > 16 of 26 OK created table model <client_name>_PINNACLE_FA.PURCHASEORDER......................................................... [[32mSUCCESS 1[0m in 16.81s]
2023-02-09 16:24:31 [42mnormalization[0m > 19 of 26 START table model <client_name>_PINNACLE_FA.SALESALLOCATION............................................................ [RUN]
2023-02-09 16:24:33 [42mnormalization[0m > 7 of 26 OK created table model <client_name>_PINNACLE_FA.INVOICEDETAIL.......................................................... [[32mSUCCESS 1[0m in 44.98s]
2023-02-09 16:24:33 [42mnormalization[0m > 20 of 26 START table model <client_name>_PINNACLE_FA.SEARCH..................................................................... [RUN]
2023-02-09 16:24:36 [42mnormalization[0m > 9 of 26 OK created table model <client_name>_PINNACLE_FA.INVDETAIL.............................................................. [[32mSUCCESS 1[0m in 45.41s]
2023-02-09 16:24:36 [42mnormalization[0m > 21 of 26 START table model <client_name>_PINNACLE_FA.SETPRICE................................................................... [RUN]
2023-02-09 16:24:39 [42mnormalization[0m > 12 of 26 OK created table model <client_name>_PINNACLE_FA.OLDPARTS.............................................................. [[32mSUCCESS 1[0m in 39.47s]
2023-02-09 16:24:39 [42mnormalization[0m > 22 of 26 START table model <client_name>_PINNACLE_FA.SITES...................................................................... [RUN]
2023-02-09 16:24:39 [42mnormalization[0m > 18 of 26 OK created table model <client_name>_PINNACLE_FA.SALESLEDGER........................................................... [[32mSUCCESS 1[0m in 17.61s]
2023-02-09 16:24:39 [42mnormalization[0m > 23 of 26 START table model <client_name>_PINNACLE_FA.INVOICES................................................................... [RUN]
2023-02-09 16:24:40 [42mnormalization[0m > 22 of 26 OK created table model <client_name>_PINNACLE_FA.SITES................................................................. [[32mSUCCESS 1[0m in 1.95s]
2023-02-09 16:24:40 [42mnormalization[0m > 24 of 26 START table model <client_name>_PINNACLE_FA.PURCHASEORDERDETAIL........................................................ [RUN]
2023-02-09 16:24:42 [42mnormalization[0m > 21 of 26 OK created table model <client_name>_PINNACLE_FA.SETPRICE.............................................................. [[32mSUCCESS 1[0m in 6.47s]
2023-02-09 16:24:42 [42mnormalization[0m > 25 of 26 START table model <client_name>_PINNACLE_FA.STOCK...................................................................... [RUN]
2023-02-09 16:24:43 [42mnormalization[0m > 19 of 26 OK created table model <client_name>_PINNACLE_FA.SALESALLOCATION....................................................... [[32mSUCCESS 1[0m in 11.33s]
2023-02-09 16:24:43 [42mnormalization[0m > 26 of 26 START table model <client_name>_PINNACLE_FA.VEHISTOK................................................................... [RUN]
2023-02-09 16:24:50 [42mnormalization[0m > 26 of 26 OK created table model <client_name>_PINNACLE_FA.VEHISTOK.............................................................. [[32mSUCCESS 1[0m in 6.98s]
2023-02-09 16:24:52 [42mnormalization[0m > 25 of 26 OK created table model <client_name>_PINNACLE_FA.STOCK................................................................. [[32mSUCCESS 1[0m in 9.47s]
2023-02-09 16:24:53 [42mnormalization[0m > 20 of 26 OK created table model <client_name>_PINNACLE_FA.SEARCH................................................................ [[32mSUCCESS 1[0m in 20.16s]
2023-02-09 16:25:00 [42mnormalization[0m > 24 of 26 OK created table model <client_name>_PINNACLE_FA.PURCHASEORDERDETAIL................................................... [[32mSUCCESS 1[0m in 19.22s]
2023-02-09 16:25:08 [42mnormalization[0m > 23 of 26 OK created table model <client_name>_PINNACLE_FA.INVOICES.............................................................. [[32mSUCCESS 1[0m in 28.97s]
2023-02-09 16:25:08 [42mnormalization[0m > Finished running 26 table models in 92.16s.
2023-02-09 16:25:08 [42mnormalization[0m > [32mCompleted successfully[0m
2023-02-09 16:25:08 [42mnormalization[0m > Done. PASS=26 WARN=0 ERROR=0 SKIP=0 TOTAL=26
2023-02-09 16:25:09 [32mINFO[m i.a.w.p.KubePodProcess(close):721 - (pod: default / normalization-snowflake-normalize-14503-0-blria) - Closed all resources for pod
2023-02-09 16:25:09 [32mINFO[m i.a.w.n.DefaultNormalizationRunner(close):189 - Terminating normalization process...
2023-02-09 16:25:09 [32mINFO[m i.a.w.n.DefaultNormalizationRunner(close):202 - Normalization process successfully terminated.
2023-02-09 16:25:09 [32mINFO[m i.a.w.g.DefaultNormalizationWorker(run):94 - Normalization executed in 2 minutes 2 seconds for job 14503.
2023-02-09 16:25:09 [32mINFO[m i.a.w.g.DefaultNormalizationWorker(run):106 - Normalization summary: io.airbyte.config.NormalizationSummary@480de439[startTime=1675959786411,endTime=1675959909366,failures=[]]
2023-02-09 16:25:09 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2023-02-09 16:25:09 [32mINFO[m i.a.c.t.TemporalUtils(withBackgroundHeartbeat):283 - Stopping temporal heartbeating...
2023-02-09 16:25:09 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2023-02-09 16:25:09 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- END DEFAULT NORMALIZATION -----
2023-02-09 16:25:09 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2023-02-09 16:25:12 [32mINFO[m i.a.v.j.JsonSchemaValidator(test):130 - JSON schema validation failed.
errors: $.auth_type: must be a constant value OAuth2.0, $.auth_type: does not have a value in the enumeration [OAuth2.0], $.access_token: is missing but it is required, $.refresh_token: is missing but it is required
2023-02-09 16:25:12 [32mINFO[m i.a.v.j.JsonSchemaValidator(test):130 - JSON schema validation failed.
errors: $.auth_type: must be a constant value Key Pair Authentication, $.auth_type: does not have a value in the enumeration [Key Pair Authentication], $.private_key: is missing but it is required
2023-02-09 16:25:12 [32mINFO[m i.a.v.j.JsonSchemaValidator(test):130 - JSON schema validation failed.
errors: $.password: object found, string expected
2023-02-09 16:25:13 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):138 - Cloud storage job log path: /workspace/14503/1/logs.log
2023-02-09 16:25:13 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.29
2023-02-09 16:25:13 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2023-02-09 16:25:13 [32mINFO[m i.a.w.p.KubeProcessFactory(create):96 - Attempting to start pod = source-postgres-check-14503-1-hyrhw for airbyte/source-postgres:1.0.42 with resources io.airbyte.config.ResourceRequirements@677cc9e5[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2023-02-09 16:25:13 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2023-02-09 16:25:13 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK -----
2023-02-09 16:25:13 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2023-02-09 16:27:23 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$6):231 - Running sync worker cancellation...
2023-02-09 16:27:23 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$6):235 - Interrupting worker thread...
2023-02-09 16:27:23 [1;31mERROR[m i.a.w.g.DefaultCheckConnectionWorker(run):124 - Unexpected error while checking connection:
io.airbyte.workers.exception.WorkerException: null
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:140) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.AirbyteIntegrationLauncher.check(AirbyteIntegrationLauncher.java:95) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:71) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:41) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$5(TemporalAttemptExecution.java:195) ~[io.airbyte-airbyte-workers-0.40.29.jar:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
Caused by: java.lang.InterruptedException
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:1681) ~[?:?]
	at java.util.concurrent.LinkedBlockingDeque.pollFirst(LinkedBlockingDeque.java:515) ~[?:?]
	at java.util.concurrent.LinkedBlockingDeque.poll(LinkedBlockingDeque.java:677) ~[?:?]
	at io.airbyte.workers.process.KubePortManagerSingleton.take(KubePortManagerSingleton.java:67) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:98) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	... 5 more
2023-02-09 16:27:23 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$6):238 - Cancelling completable future...
2023-02-09 16:27:23 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2023-02-09 16:27:23 [33mWARN[m i.t.i.a.ActivityTaskExecutors$BaseActivityTaskExecutor(execute):114 - Activity failure. ActivityId=aa946d04-9f0e-3fa5-83f5-f446c3c6798e, activityType=RunWithJobOutput, attempt=1
java.util.concurrent.CancellationException: null
	at java.util.concurrent.CompletableFuture.cancel(CompletableFuture.java:2510) ~[?:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$6(TemporalAttemptExecution.java:241) ~[io.airbyte-airbyte-workers-0.40.29.jar:?]
	at io.airbyte.commons.temporal.CancellationHandler$TemporalCancellationHandler.checkAndHandleCancellation(CancellationHandler.java:52) ~[io.airbyte-airbyte-commons-temporal-0.40.29.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$7(TemporalAttemptExecution.java:244) ~[io.airbyte-airbyte-workers-0.40.29.jar:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:577) ~[?:?]
	at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:358) ~[?:?]
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
2023-02-09 16:27:23 [33mWARN[m i.a.c.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled.
2023-02-09 16:27:23 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getWorkerThread$5):198 - Completing future exceptionally...
io.airbyte.workers.exception.WorkerException: Unexpected error while getting checking connection.
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:126) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:41) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$5(TemporalAttemptExecution.java:195) ~[io.airbyte-airbyte-workers-0.40.29.jar:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
Caused by: io.airbyte.workers.exception.WorkerException
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:140) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.AirbyteIntegrationLauncher.check(AirbyteIntegrationLauncher.java:95) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:71) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	... 3 more
Caused by: java.lang.InterruptedException
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:1681) ~[?:?]
	at java.util.concurrent.LinkedBlockingDeque.pollFirst(LinkedBlockingDeque.java:515) ~[?:?]
	at java.util.concurrent.LinkedBlockingDeque.poll(LinkedBlockingDeque.java:677) ~[?:?]
	at io.airbyte.workers.process.KubePortManagerSingleton.take(KubePortManagerSingleton.java:67) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:98) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.AirbyteIntegrationLauncher.check(AirbyteIntegrationLauncher.java:95) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:71) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	... 3 more
2023-02-09 16:27:23 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2023-02-09 16:27:23 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK -----
2023-02-09 16:27:23 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2023-02-09 16:27:23 [33mWARN[m i.t.i.w.ActivityWorker$TaskHandlerImpl(logExceptionDuringResultReporting):365 - Failure during reporting of activity result to the server. ActivityId = aa946d04-9f0e-3fa5-83f5-f446c3c6798e, ActivityType = RunWithJobOutput, WorkflowId=connection_manager_5c850adc-fc8e-4a6b-93c2-5a03da05e9d3, WorkflowType=ConnectionManagerWorkflow, RunId=6169ef4d-f971-4987-b4f6-739bc90c6bf6
io.grpc.StatusRuntimeException: NOT_FOUND: invalid activityID or activity already timed out or invoking workflow is completed
	at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:271) ~[grpc-stub-1.51.1.jar:1.51.1]
	at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:252) ~[grpc-stub-1.51.1.jar:1.51.1]
	at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:165) ~[grpc-stub-1.51.1.jar:1.51.1]
	at io.temporal.api.workflowservice.v1.WorkflowServiceGrpc$WorkflowServiceBlockingStub.respondActivityTaskFailed(WorkflowServiceGrpc.java:3866) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.lambda$sendReply$1(ActivityWorker.java:320) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.lambda$retry$0(GrpcRetryer.java:52) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcSyncRetryer.retry(GrpcSyncRetryer.java:67) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:60) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retry(GrpcRetryer.java:50) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.sendReply(ActivityWorker.java:315) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:252) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:206) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:179) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:93) ~[temporal-sdk-1.17.0.jar:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
2023-02-09 16:27:43 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):138 - Cloud storage job log path: /workspace/14503/1/logs.log
2023-02-09 16:27:43 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.29
2023-02-09 16:27:43 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2023-02-09 16:27:43 [32mINFO[m i.a.w.p.KubeProcessFactory(create):96 - Attempting to start pod = source-postgres-check-14503-1-filyd for airbyte/source-postgres:1.0.42 with resources io.airbyte.config.ResourceRequirements@677cc9e5[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2023-02-09 16:27:43 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2023-02-09 16:27:43 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK -----
2023-02-09 16:27:43 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2023-02-09 16:29:53 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$6):231 - Running sync worker cancellation...
2023-02-09 16:29:53 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$6):235 - Interrupting worker thread...
2023-02-09 16:29:53 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$6):238 - Cancelling completable future...
2023-02-09 16:29:53 [33mWARN[m i.a.c.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled.
2023-02-09 16:29:53 [1;31mERROR[m i.a.w.g.DefaultCheckConnectionWorker(run):124 - Unexpected error while checking connection:
io.airbyte.workers.exception.WorkerException: null
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:140) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.AirbyteIntegrationLauncher.check(AirbyteIntegrationLauncher.java:95) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:71) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:41) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$5(TemporalAttemptExecution.java:195) ~[io.airbyte-airbyte-workers-0.40.29.jar:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
Caused by: java.lang.InterruptedException
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:1681) ~[?:?]
	at java.util.concurrent.LinkedBlockingDeque.pollFirst(LinkedBlockingDeque.java:515) ~[?:?]
	at java.util.concurrent.LinkedBlockingDeque.poll(LinkedBlockingDeque.java:677) ~[?:?]
	at io.airbyte.workers.process.KubePortManagerSingleton.take(KubePortManagerSingleton.java:67) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:98) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	... 5 more
2023-02-09 16:29:53 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2023-02-09 16:29:53 [33mWARN[m i.t.i.a.ActivityTaskExecutors$BaseActivityTaskExecutor(execute):114 - Activity failure. ActivityId=aa946d04-9f0e-3fa5-83f5-f446c3c6798e, activityType=RunWithJobOutput, attempt=2
java.util.concurrent.CancellationException: null
	at java.util.concurrent.CompletableFuture.cancel(CompletableFuture.java:2510) ~[?:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$6(TemporalAttemptExecution.java:241) ~[io.airbyte-airbyte-workers-0.40.29.jar:?]
	at io.airbyte.commons.temporal.CancellationHandler$TemporalCancellationHandler.checkAndHandleCancellation(CancellationHandler.java:52) ~[io.airbyte-airbyte-commons-temporal-0.40.29.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$7(TemporalAttemptExecution.java:244) ~[io.airbyte-airbyte-workers-0.40.29.jar:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:577) ~[?:?]
	at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:358) ~[?:?]
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
2023-02-09 16:29:53 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getWorkerThread$5):198 - Completing future exceptionally...
io.airbyte.workers.exception.WorkerException: Unexpected error while getting checking connection.
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:126) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:41) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$5(TemporalAttemptExecution.java:195) ~[io.airbyte-airbyte-workers-0.40.29.jar:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
Caused by: io.airbyte.workers.exception.WorkerException
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:140) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.AirbyteIntegrationLauncher.check(AirbyteIntegrationLauncher.java:95) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:71) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	... 3 more
Caused by: java.lang.InterruptedException
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:1681) ~[?:?]
	at java.util.concurrent.LinkedBlockingDeque.pollFirst(LinkedBlockingDeque.java:515) ~[?:?]
	at java.util.concurrent.LinkedBlockingDeque.poll(LinkedBlockingDeque.java:677) ~[?:?]
	at io.airbyte.workers.process.KubePortManagerSingleton.take(KubePortManagerSingleton.java:67) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:98) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.AirbyteIntegrationLauncher.check(AirbyteIntegrationLauncher.java:95) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:71) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	... 3 more
2023-02-09 16:29:53 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2023-02-09 16:29:53 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK -----
2023-02-09 16:29:53 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2023-02-09 16:29:53 [33mWARN[m i.t.i.w.ActivityWorker$TaskHandlerImpl(logExceptionDuringResultReporting):365 - Failure during reporting of activity result to the server. ActivityId = aa946d04-9f0e-3fa5-83f5-f446c3c6798e, ActivityType = RunWithJobOutput, WorkflowId=connection_manager_5c850adc-fc8e-4a6b-93c2-5a03da05e9d3, WorkflowType=ConnectionManagerWorkflow, RunId=6169ef4d-f971-4987-b4f6-739bc90c6bf6
io.grpc.StatusRuntimeException: NOT_FOUND: invalid activityID or activity already timed out or invoking workflow is completed
	at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:271) ~[grpc-stub-1.51.1.jar:1.51.1]
	at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:252) ~[grpc-stub-1.51.1.jar:1.51.1]
	at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:165) ~[grpc-stub-1.51.1.jar:1.51.1]
	at io.temporal.api.workflowservice.v1.WorkflowServiceGrpc$WorkflowServiceBlockingStub.respondActivityTaskFailed(WorkflowServiceGrpc.java:3866) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.lambda$sendReply$1(ActivityWorker.java:320) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.lambda$retry$0(GrpcRetryer.java:52) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcSyncRetryer.retry(GrpcSyncRetryer.java:67) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:60) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retry(GrpcRetryer.java:50) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.sendReply(ActivityWorker.java:315) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:252) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:206) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:179) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:93) ~[temporal-sdk-1.17.0.jar:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
2023-02-09 16:30:43 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):138 - Cloud storage job log path: /workspace/14503/1/logs.log
2023-02-09 16:30:43 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.29
2023-02-09 16:30:43 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2023-02-09 16:30:43 [32mINFO[m i.a.w.p.KubeProcessFactory(create):96 - Attempting to start pod = source-postgres-check-14503-1-sdavl for airbyte/source-postgres:1.0.42 with resources io.airbyte.config.ResourceRequirements@677cc9e5[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2023-02-09 16:30:43 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2023-02-09 16:30:43 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK -----
2023-02-09 16:30:43 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2023-02-09 16:31:00 [32mINFO[m i.a.w.p.KubeProcessFactory(create):99 - source-postgres-check-14503-1-sdavl stdoutLocalPort = 9003
2023-02-09 16:31:21 [32mINFO[m i.a.w.p.KubeProcessFactory(create):102 - source-postgres-check-14503-1-sdavl stderrLocalPort = 9017
2023-02-09 16:31:21 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):602 - Creating stdout socket server...
2023-02-09 16:31:21 [32mINFO[m i.a.w.p.KubePodProcess(<init>):533 - Creating pod source-postgres-check-14503-1-sdavl...
2023-02-09 16:31:21 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$11):620 - Creating stderr socket server...
2023-02-09 16:31:21 [32mINFO[m i.a.w.p.KubePodProcess(waitForInitPodToRun):313 - Waiting for init container to be ready before copying files...
2023-02-09 16:31:21 [32mINFO[m i.a.w.p.KubePodProcess(waitForInitPodToRun):317 - Init container present..
2023-02-09 16:31:22 [32mINFO[m i.a.w.p.KubePodProcess(waitForInitPodToRun):320 - Init container ready..
2023-02-09 16:31:22 [32mINFO[m i.a.w.p.KubePodProcess(<init>):564 - Copying files...
2023-02-09 16:31:22 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - Uploading file: source_config.json
2023-02-09 16:31:22 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):270 - kubectl cp /tmp/0c5fffae-9370-4b2a-b4d1-e273971b400e/source_config.json default/source-postgres-check-14503-1-sdavl:/config/source_config.json -c init
2023-02-09 16:31:22 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):273 - Waiting for kubectl cp to complete
2023-02-09 16:31:23 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):287 - kubectl cp complete, closing process
2023-02-09 16:31:23 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - Uploading file: FINISHED_UPLOADING
2023-02-09 16:31:23 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):270 - kubectl cp /tmp/b2d01989-a042-4535-bdfc-0cf21e588433/FINISHED_UPLOADING default/source-postgres-check-14503-1-sdavl:/config/FINISHED_UPLOADING -c init
2023-02-09 16:31:23 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):273 - Waiting for kubectl cp to complete
2023-02-09 16:31:23 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):287 - kubectl cp complete, closing process
2023-02-09 16:31:23 [32mINFO[m i.a.w.p.KubePodProcess(<init>):567 - Waiting until pod is ready...
2023-02-09 16:31:25 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):611 - Setting stdout...
2023-02-09 16:31:25 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$11):623 - Setting stderr...
2023-02-09 16:31:26 [32mINFO[m i.a.w.p.KubePodProcess(<init>):583 - Reading pod IP...
2023-02-09 16:31:26 [32mINFO[m i.a.w.p.KubePodProcess(<init>):585 - Pod IP: 10.226.16.115
2023-02-09 16:31:26 [32mINFO[m i.a.w.p.KubePodProcess(<init>):592 - Using null stdin output stream...
2023-02-09 16:31:26 [32mINFO[m i.a.w.i.VersionedAirbyteStreamFactory(create):102 - Reading messages from protocol version 0.2.0
2023-02-09 16:31:27 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Running source under deployment mode: OSS
2023-02-09 16:31:27 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Starting source: io.airbyte.integrations.base.ssh.SshWrappedSource
2023-02-09 16:31:27 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - integration args: {check=null, config=source_config.json}
2023-02-09 16:31:27 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2023-02-09 16:31:27 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Command: CHECK
2023-02-09 16:31:27 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'}
2023-02-09 16:31:27 [33mWARN[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):164 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-02-09 16:31:27 [33mWARN[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):164 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-02-09 16:31:28 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Starting connection with method: NO_TUNNEL
2023-02-09 16:31:28 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - using CDC: false
2023-02-09 16:31:28 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - HikariPool-1 - Starting...
2023-02-09 16:31:28 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - HikariPool-1 - Start completed.
2023-02-09 16:31:29 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - using CDC: false
2023-02-09 16:31:29 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Attempting to get metadata from the database to see if we can connect.
2023-02-09 16:31:29 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - HikariPool-1 - Shutdown initiated...
2023-02-09 16:31:29 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - HikariPool-1 - Shutdown completed.
2023-02-09 16:31:29 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2023-02-09 16:31:29 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Completed source: io.airbyte.integrations.base.ssh.SshWrappedSource
2023-02-09 16:31:29 [32mINFO[m i.a.w.p.KubePodProcess(close):721 - (pod: default / source-postgres-check-14503-1-sdavl) - Closed all resources for pod
2023-02-09 16:31:29 [32mINFO[m i.a.w.g.DefaultCheckConnectionWorker(run):114 - Check connection job received output: io.airbyte.config.StandardCheckConnectionOutput@6f9612fc[status=succeeded,message=<null>]
2023-02-09 16:31:29 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2023-02-09 16:31:29 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2023-02-09 16:31:29 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK -----
2023-02-09 16:31:29 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2023-02-09 16:31:30 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):138 - Cloud storage job log path: /workspace/14503/1/logs.log
2023-02-09 16:31:30 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.29
2023-02-09 16:31:30 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2023-02-09 16:31:30 [32mINFO[m i.a.w.p.KubeProcessFactory(create):96 - Attempting to start pod = destination-snowflake-check-14503-1-fawko for airbyte/destination-snowflake:0.4.44 with resources io.airbyte.config.ResourceRequirements@677cc9e5[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2023-02-09 16:31:30 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2023-02-09 16:31:30 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK -----
2023-02-09 16:31:30 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2023-02-09 16:33:40 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$6):231 - Running sync worker cancellation...
2023-02-09 16:33:40 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$6):235 - Interrupting worker thread...
2023-02-09 16:33:40 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$6):238 - Cancelling completable future...
2023-02-09 16:33:40 [33mWARN[m i.a.c.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled.
2023-02-09 16:33:40 [1;31mERROR[m i.a.w.g.DefaultCheckConnectionWorker(run):124 - Unexpected error while checking connection:
io.airbyte.workers.exception.WorkerException: null
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:140) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.AirbyteIntegrationLauncher.check(AirbyteIntegrationLauncher.java:95) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:71) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:41) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$5(TemporalAttemptExecution.java:195) ~[io.airbyte-airbyte-workers-0.40.29.jar:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
Caused by: java.lang.InterruptedException
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:1681) ~[?:?]
	at java.util.concurrent.LinkedBlockingDeque.pollFirst(LinkedBlockingDeque.java:515) ~[?:?]
	at java.util.concurrent.LinkedBlockingDeque.poll(LinkedBlockingDeque.java:677) ~[?:?]
	at io.airbyte.workers.process.KubePortManagerSingleton.take(KubePortManagerSingleton.java:67) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:98) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	... 5 more
2023-02-09 16:33:40 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2023-02-09 16:33:40 [33mWARN[m i.t.i.a.ActivityTaskExecutors$BaseActivityTaskExecutor(execute):114 - Activity failure. ActivityId=ab5ce1ec-cf25-3f01-bdbf-01da7dc76e8f, activityType=RunWithJobOutput, attempt=1
java.util.concurrent.CancellationException: null
	at java.util.concurrent.CompletableFuture.cancel(CompletableFuture.java:2510) ~[?:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$6(TemporalAttemptExecution.java:241) ~[io.airbyte-airbyte-workers-0.40.29.jar:?]
	at io.airbyte.commons.temporal.CancellationHandler$TemporalCancellationHandler.checkAndHandleCancellation(CancellationHandler.java:52) ~[io.airbyte-airbyte-commons-temporal-0.40.29.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$7(TemporalAttemptExecution.java:244) ~[io.airbyte-airbyte-workers-0.40.29.jar:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:577) ~[?:?]
	at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:358) ~[?:?]
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
2023-02-09 16:33:40 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getWorkerThread$5):198 - Completing future exceptionally...
io.airbyte.workers.exception.WorkerException: Unexpected error while getting checking connection.
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:126) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:41) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$5(TemporalAttemptExecution.java:195) ~[io.airbyte-airbyte-workers-0.40.29.jar:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
Caused by: io.airbyte.workers.exception.WorkerException
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:140) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.AirbyteIntegrationLauncher.check(AirbyteIntegrationLauncher.java:95) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:71) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	... 3 more
Caused by: java.lang.InterruptedException
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:1681) ~[?:?]
	at java.util.concurrent.LinkedBlockingDeque.pollFirst(LinkedBlockingDeque.java:515) ~[?:?]
	at java.util.concurrent.LinkedBlockingDeque.poll(LinkedBlockingDeque.java:677) ~[?:?]
	at io.airbyte.workers.process.KubePortManagerSingleton.take(KubePortManagerSingleton.java:67) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:98) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.AirbyteIntegrationLauncher.check(AirbyteIntegrationLauncher.java:95) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:71) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	... 3 more
2023-02-09 16:33:40 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2023-02-09 16:33:40 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK -----
2023-02-09 16:33:40 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2023-02-09 16:33:40 [33mWARN[m i.t.i.w.ActivityWorker$TaskHandlerImpl(logExceptionDuringResultReporting):365 - Failure during reporting of activity result to the server. ActivityId = ab5ce1ec-cf25-3f01-bdbf-01da7dc76e8f, ActivityType = RunWithJobOutput, WorkflowId=connection_manager_5c850adc-fc8e-4a6b-93c2-5a03da05e9d3, WorkflowType=ConnectionManagerWorkflow, RunId=6169ef4d-f971-4987-b4f6-739bc90c6bf6
io.grpc.StatusRuntimeException: NOT_FOUND: invalid activityID or activity already timed out or invoking workflow is completed
	at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:271) ~[grpc-stub-1.51.1.jar:1.51.1]
	at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:252) ~[grpc-stub-1.51.1.jar:1.51.1]
	at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:165) ~[grpc-stub-1.51.1.jar:1.51.1]
	at io.temporal.api.workflowservice.v1.WorkflowServiceGrpc$WorkflowServiceBlockingStub.respondActivityTaskFailed(WorkflowServiceGrpc.java:3866) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.lambda$sendReply$1(ActivityWorker.java:320) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.lambda$retry$0(GrpcRetryer.java:52) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcSyncRetryer.retry(GrpcSyncRetryer.java:67) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:60) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retry(GrpcRetryer.java:50) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.sendReply(ActivityWorker.java:315) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:252) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:206) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:179) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:93) ~[temporal-sdk-1.17.0.jar:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
2023-02-09 16:34:00 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):138 - Cloud storage job log path: /workspace/14503/1/logs.log
2023-02-09 16:34:00 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.29
2023-02-09 16:34:00 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2023-02-09 16:34:00 [32mINFO[m i.a.w.p.KubeProcessFactory(create):96 - Attempting to start pod = destination-snowflake-check-14503-1-fqtie for airbyte/destination-snowflake:0.4.44 with resources io.airbyte.config.ResourceRequirements@677cc9e5[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2023-02-09 16:34:00 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2023-02-09 16:34:00 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK -----
2023-02-09 16:34:00 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2023-02-09 16:36:10 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$6):231 - Running sync worker cancellation...
2023-02-09 16:36:10 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$6):235 - Interrupting worker thread...
2023-02-09 16:36:10 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$6):238 - Cancelling completable future...
2023-02-09 16:36:10 [33mWARN[m i.a.c.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled.
2023-02-09 16:36:10 [1;31mERROR[m i.a.w.g.DefaultCheckConnectionWorker(run):124 - Unexpected error while checking connection:
io.airbyte.workers.exception.WorkerException: null
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:140) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.AirbyteIntegrationLauncher.check(AirbyteIntegrationLauncher.java:95) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:71) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:41) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$5(TemporalAttemptExecution.java:195) ~[io.airbyte-airbyte-workers-0.40.29.jar:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
Caused by: java.lang.InterruptedException
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:1681) ~[?:?]
	at java.util.concurrent.LinkedBlockingDeque.pollFirst(LinkedBlockingDeque.java:515) ~[?:?]
	at java.util.concurrent.LinkedBlockingDeque.poll(LinkedBlockingDeque.java:677) ~[?:?]
	at io.airbyte.workers.process.KubePortManagerSingleton.take(KubePortManagerSingleton.java:67) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:98) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	... 5 more
2023-02-09 16:36:10 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2023-02-09 16:36:10 [33mWARN[m i.t.i.a.ActivityTaskExecutors$BaseActivityTaskExecutor(execute):114 - Activity failure. ActivityId=ab5ce1ec-cf25-3f01-bdbf-01da7dc76e8f, activityType=RunWithJobOutput, attempt=2
java.util.concurrent.CancellationException: null
	at java.util.concurrent.CompletableFuture.cancel(CompletableFuture.java:2510) ~[?:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$6(TemporalAttemptExecution.java:241) ~[io.airbyte-airbyte-workers-0.40.29.jar:?]
	at io.airbyte.commons.temporal.CancellationHandler$TemporalCancellationHandler.checkAndHandleCancellation(CancellationHandler.java:52) ~[io.airbyte-airbyte-commons-temporal-0.40.29.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$7(TemporalAttemptExecution.java:244) ~[io.airbyte-airbyte-workers-0.40.29.jar:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:577) ~[?:?]
	at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:358) ~[?:?]
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
2023-02-09 16:36:10 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getWorkerThread$5):198 - Completing future exceptionally...
io.airbyte.workers.exception.WorkerException: Unexpected error while getting checking connection.
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:126) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:41) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$5(TemporalAttemptExecution.java:195) ~[io.airbyte-airbyte-workers-0.40.29.jar:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
Caused by: io.airbyte.workers.exception.WorkerException
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:140) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.AirbyteIntegrationLauncher.check(AirbyteIntegrationLauncher.java:95) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:71) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	... 3 more
Caused by: java.lang.InterruptedException
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:1681) ~[?:?]
	at java.util.concurrent.LinkedBlockingDeque.pollFirst(LinkedBlockingDeque.java:515) ~[?:?]
	at java.util.concurrent.LinkedBlockingDeque.poll(LinkedBlockingDeque.java:677) ~[?:?]
	at io.airbyte.workers.process.KubePortManagerSingleton.take(KubePortManagerSingleton.java:67) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:98) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.AirbyteIntegrationLauncher.check(AirbyteIntegrationLauncher.java:95) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:71) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	... 3 more
2023-02-09 16:36:10 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2023-02-09 16:36:10 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK -----
2023-02-09 16:36:10 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2023-02-09 16:36:10 [33mWARN[m i.t.i.w.ActivityWorker$TaskHandlerImpl(logExceptionDuringResultReporting):365 - Failure during reporting of activity result to the server. ActivityId = ab5ce1ec-cf25-3f01-bdbf-01da7dc76e8f, ActivityType = RunWithJobOutput, WorkflowId=connection_manager_5c850adc-fc8e-4a6b-93c2-5a03da05e9d3, WorkflowType=ConnectionManagerWorkflow, RunId=6169ef4d-f971-4987-b4f6-739bc90c6bf6
io.grpc.StatusRuntimeException: NOT_FOUND: invalid activityID or activity already timed out or invoking workflow is completed
	at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:271) ~[grpc-stub-1.51.1.jar:1.51.1]
	at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:252) ~[grpc-stub-1.51.1.jar:1.51.1]
	at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:165) ~[grpc-stub-1.51.1.jar:1.51.1]
	at io.temporal.api.workflowservice.v1.WorkflowServiceGrpc$WorkflowServiceBlockingStub.respondActivityTaskFailed(WorkflowServiceGrpc.java:3866) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.lambda$sendReply$1(ActivityWorker.java:320) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.lambda$retry$0(GrpcRetryer.java:52) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcSyncRetryer.retry(GrpcSyncRetryer.java:67) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:60) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retry(GrpcRetryer.java:50) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.sendReply(ActivityWorker.java:315) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:252) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:206) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:179) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:93) ~[temporal-sdk-1.17.0.jar:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
2023-02-09 16:37:00 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):138 - Cloud storage job log path: /workspace/14503/1/logs.log
2023-02-09 16:37:00 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.29
2023-02-09 16:37:00 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2023-02-09 16:37:00 [32mINFO[m i.a.w.p.KubeProcessFactory(create):96 - Attempting to start pod = destination-snowflake-check-14503-1-zmygv for airbyte/destination-snowflake:0.4.44 with resources io.airbyte.config.ResourceRequirements@677cc9e5[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2023-02-09 16:37:00 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2023-02-09 16:37:00 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK -----
2023-02-09 16:37:00 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2023-02-09 16:39:10 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$6):231 - Running sync worker cancellation...
2023-02-09 16:39:10 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$6):235 - Interrupting worker thread...
2023-02-09 16:39:10 [1;31mERROR[m i.a.w.g.DefaultCheckConnectionWorker(run):124 - Unexpected error while checking connection:
io.airbyte.workers.exception.WorkerException: null
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:140) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.AirbyteIntegrationLauncher.check(AirbyteIntegrationLauncher.java:95) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:71) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:41) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$5(TemporalAttemptExecution.java:195) ~[io.airbyte-airbyte-workers-0.40.29.jar:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
Caused by: java.lang.InterruptedException
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:1681) ~[?:?]
	at java.util.concurrent.LinkedBlockingDeque.pollFirst(LinkedBlockingDeque.java:515) ~[?:?]
	at java.util.concurrent.LinkedBlockingDeque.poll(LinkedBlockingDeque.java:677) ~[?:?]
	at io.airbyte.workers.process.KubePortManagerSingleton.take(KubePortManagerSingleton.java:67) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:98) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	... 5 more
2023-02-09 16:39:10 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$6):238 - Cancelling completable future...
2023-02-09 16:39:10 [33mWARN[m i.a.c.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled.
2023-02-09 16:39:10 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2023-02-09 16:39:10 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getWorkerThread$5):198 - Completing future exceptionally...
io.airbyte.workers.exception.WorkerException: Unexpected error while getting checking connection.
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:126) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:41) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$5(TemporalAttemptExecution.java:195) ~[io.airbyte-airbyte-workers-0.40.29.jar:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
Caused by: io.airbyte.workers.exception.WorkerException
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:140) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.AirbyteIntegrationLauncher.check(AirbyteIntegrationLauncher.java:95) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:71) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	... 3 more
Caused by: java.lang.InterruptedException
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:1681) ~[?:?]
	at java.util.concurrent.LinkedBlockingDeque.pollFirst(LinkedBlockingDeque.java:515) ~[?:?]
	at java.util.concurrent.LinkedBlockingDeque.poll(LinkedBlockingDeque.java:677) ~[?:?]
	at io.airbyte.workers.process.KubePortManagerSingleton.take(KubePortManagerSingleton.java:67) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:98) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.AirbyteIntegrationLauncher.check(AirbyteIntegrationLauncher.java:95) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:71) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	... 3 more
2023-02-09 16:39:10 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2023-02-09 16:39:10 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK -----
2023-02-09 16:39:10 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2023-02-09 16:39:10 [33mWARN[m i.t.i.a.ActivityTaskExecutors$BaseActivityTaskExecutor(execute):114 - Activity failure. ActivityId=ab5ce1ec-cf25-3f01-bdbf-01da7dc76e8f, activityType=RunWithJobOutput, attempt=3
java.util.concurrent.CancellationException: null
	at java.util.concurrent.CompletableFuture.cancel(CompletableFuture.java:2510) ~[?:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$6(TemporalAttemptExecution.java:241) ~[io.airbyte-airbyte-workers-0.40.29.jar:?]
	at io.airbyte.commons.temporal.CancellationHandler$TemporalCancellationHandler.checkAndHandleCancellation(CancellationHandler.java:52) ~[io.airbyte-airbyte-commons-temporal-0.40.29.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$7(TemporalAttemptExecution.java:244) ~[io.airbyte-airbyte-workers-0.40.29.jar:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:577) ~[?:?]
	at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:358) ~[?:?]
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
2023-02-09 16:39:10 [33mWARN[m i.t.i.w.ActivityWorker$TaskHandlerImpl(logExceptionDuringResultReporting):365 - Failure during reporting of activity result to the server. ActivityId = ab5ce1ec-cf25-3f01-bdbf-01da7dc76e8f, ActivityType = RunWithJobOutput, WorkflowId=connection_manager_5c850adc-fc8e-4a6b-93c2-5a03da05e9d3, WorkflowType=ConnectionManagerWorkflow, RunId=6169ef4d-f971-4987-b4f6-739bc90c6bf6
io.grpc.StatusRuntimeException: NOT_FOUND: invalid activityID or activity already timed out or invoking workflow is completed
	at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:271) ~[grpc-stub-1.51.1.jar:1.51.1]
	at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:252) ~[grpc-stub-1.51.1.jar:1.51.1]
	at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:165) ~[grpc-stub-1.51.1.jar:1.51.1]
	at io.temporal.api.workflowservice.v1.WorkflowServiceGrpc$WorkflowServiceBlockingStub.respondActivityTaskFailed(WorkflowServiceGrpc.java:3866) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.lambda$sendReply$1(ActivityWorker.java:320) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.lambda$retry$0(GrpcRetryer.java:52) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcSyncRetryer.retry(GrpcSyncRetryer.java:67) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:60) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retry(GrpcRetryer.java:50) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.sendReply(ActivityWorker.java:315) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:252) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:206) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:179) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:93) ~[temporal-sdk-1.17.0.jar:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
2023-02-09 16:41:00 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):138 - Cloud storage job log path: /workspace/14503/1/logs.log
2023-02-09 16:41:00 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.29
2023-02-09 16:41:00 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2023-02-09 16:41:00 [32mINFO[m i.a.w.p.KubeProcessFactory(create):96 - Attempting to start pod = destination-snowflake-check-14503-1-zqwol for airbyte/destination-snowflake:0.4.44 with resources io.airbyte.config.ResourceRequirements@677cc9e5[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2023-02-09 16:41:00 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2023-02-09 16:41:00 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK -----
2023-02-09 16:41:00 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2023-02-09 16:43:10 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$6):231 - Running sync worker cancellation...
2023-02-09 16:43:10 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$6):235 - Interrupting worker thread...
2023-02-09 16:43:10 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$6):238 - Cancelling completable future...
2023-02-09 16:43:10 [1;31mERROR[m i.a.w.g.DefaultCheckConnectionWorker(run):124 - Unexpected error while checking connection:
io.airbyte.workers.exception.WorkerException: null
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:140) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.AirbyteIntegrationLauncher.check(AirbyteIntegrationLauncher.java:95) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:71) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:41) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$5(TemporalAttemptExecution.java:195) ~[io.airbyte-airbyte-workers-0.40.29.jar:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
Caused by: java.lang.InterruptedException
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:1681) ~[?:?]
	at java.util.concurrent.LinkedBlockingDeque.pollFirst(LinkedBlockingDeque.java:515) ~[?:?]
	at java.util.concurrent.LinkedBlockingDeque.poll(LinkedBlockingDeque.java:677) ~[?:?]
	at io.airbyte.workers.process.KubePortManagerSingleton.take(KubePortManagerSingleton.java:67) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:98) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	... 5 more
2023-02-09 16:43:10 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2023-02-09 16:43:10 [33mWARN[m i.t.i.a.ActivityTaskExecutors$BaseActivityTaskExecutor(execute):114 - Activity failure. ActivityId=ab5ce1ec-cf25-3f01-bdbf-01da7dc76e8f, activityType=RunWithJobOutput, attempt=4
java.util.concurrent.CancellationException: null
	at java.util.concurrent.CompletableFuture.cancel(CompletableFuture.java:2510) ~[?:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$6(TemporalAttemptExecution.java:241) ~[io.airbyte-airbyte-workers-0.40.29.jar:?]
	at io.airbyte.commons.temporal.CancellationHandler$TemporalCancellationHandler.checkAndHandleCancellation(CancellationHandler.java:52) ~[io.airbyte-airbyte-commons-temporal-0.40.29.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$7(TemporalAttemptExecution.java:244) ~[io.airbyte-airbyte-workers-0.40.29.jar:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:577) ~[?:?]
	at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:358) ~[?:?]
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
2023-02-09 16:43:10 [33mWARN[m i.a.c.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled.
2023-02-09 16:43:10 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getWorkerThread$5):198 - Completing future exceptionally...
io.airbyte.workers.exception.WorkerException: Unexpected error while getting checking connection.
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:126) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:41) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$5(TemporalAttemptExecution.java:195) ~[io.airbyte-airbyte-workers-0.40.29.jar:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
Caused by: io.airbyte.workers.exception.WorkerException
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:140) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.AirbyteIntegrationLauncher.check(AirbyteIntegrationLauncher.java:95) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:71) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	... 3 more
Caused by: java.lang.InterruptedException
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:1681) ~[?:?]
	at java.util.concurrent.LinkedBlockingDeque.pollFirst(LinkedBlockingDeque.java:515) ~[?:?]
	at java.util.concurrent.LinkedBlockingDeque.poll(LinkedBlockingDeque.java:677) ~[?:?]
	at io.airbyte.workers.process.KubePortManagerSingleton.take(KubePortManagerSingleton.java:67) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:98) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.AirbyteIntegrationLauncher.check(AirbyteIntegrationLauncher.java:95) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:71) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	... 3 more
2023-02-09 16:43:10 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2023-02-09 16:43:10 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK -----
2023-02-09 16:43:10 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2023-02-09 16:43:10 [33mWARN[m i.t.i.w.ActivityWorker$TaskHandlerImpl(logExceptionDuringResultReporting):365 - Failure during reporting of activity result to the server. ActivityId = ab5ce1ec-cf25-3f01-bdbf-01da7dc76e8f, ActivityType = RunWithJobOutput, WorkflowId=connection_manager_5c850adc-fc8e-4a6b-93c2-5a03da05e9d3, WorkflowType=ConnectionManagerWorkflow, RunId=6169ef4d-f971-4987-b4f6-739bc90c6bf6
io.grpc.StatusRuntimeException: NOT_FOUND: invalid activityID or activity already timed out or invoking workflow is completed
	at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:271) ~[grpc-stub-1.51.1.jar:1.51.1]
	at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:252) ~[grpc-stub-1.51.1.jar:1.51.1]
	at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:165) ~[grpc-stub-1.51.1.jar:1.51.1]
	at io.temporal.api.workflowservice.v1.WorkflowServiceGrpc$WorkflowServiceBlockingStub.respondActivityTaskFailed(WorkflowServiceGrpc.java:3866) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.lambda$sendReply$1(ActivityWorker.java:320) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.lambda$retry$0(GrpcRetryer.java:52) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcSyncRetryer.retry(GrpcSyncRetryer.java:67) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:60) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retry(GrpcRetryer.java:50) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.sendReply(ActivityWorker.java:315) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:252) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:206) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:179) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:93) ~[temporal-sdk-1.17.0.jar:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
2023-02-09 16:47:00 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):138 - Cloud storage job log path: /workspace/14503/1/logs.log
2023-02-09 16:47:00 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.29
2023-02-09 16:47:00 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2023-02-09 16:47:00 [32mINFO[m i.a.w.p.KubeProcessFactory(create):96 - Attempting to start pod = destination-snowflake-check-14503-1-emrdb for airbyte/destination-snowflake:0.4.44 with resources io.airbyte.config.ResourceRequirements@677cc9e5[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2023-02-09 16:47:00 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2023-02-09 16:47:00 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK -----
2023-02-09 16:47:00 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2023-02-09 16:49:10 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$6):231 - Running sync worker cancellation...
2023-02-09 16:49:10 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$6):235 - Interrupting worker thread...
2023-02-09 16:49:10 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$6):238 - Cancelling completable future...
2023-02-09 16:49:10 [33mWARN[m i.a.c.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled.
2023-02-09 16:49:10 [1;31mERROR[m i.a.w.g.DefaultCheckConnectionWorker(run):124 - Unexpected error while checking connection:
io.airbyte.workers.exception.WorkerException: null
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:140) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.AirbyteIntegrationLauncher.check(AirbyteIntegrationLauncher.java:95) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:71) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:41) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$5(TemporalAttemptExecution.java:195) ~[io.airbyte-airbyte-workers-0.40.29.jar:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
Caused by: java.lang.InterruptedException
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:1681) ~[?:?]
	at java.util.concurrent.LinkedBlockingDeque.pollFirst(LinkedBlockingDeque.java:515) ~[?:?]
	at java.util.concurrent.LinkedBlockingDeque.poll(LinkedBlockingDeque.java:677) ~[?:?]
	at io.airbyte.workers.process.KubePortManagerSingleton.take(KubePortManagerSingleton.java:67) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:98) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	... 5 more
2023-02-09 16:49:10 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2023-02-09 16:49:10 [33mWARN[m i.t.i.a.ActivityTaskExecutors$BaseActivityTaskExecutor(execute):114 - Activity failure. ActivityId=ab5ce1ec-cf25-3f01-bdbf-01da7dc76e8f, activityType=RunWithJobOutput, attempt=5
java.util.concurrent.CancellationException: null
	at java.util.concurrent.CompletableFuture.cancel(CompletableFuture.java:2510) ~[?:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$6(TemporalAttemptExecution.java:241) ~[io.airbyte-airbyte-workers-0.40.29.jar:?]
	at io.airbyte.commons.temporal.CancellationHandler$TemporalCancellationHandler.checkAndHandleCancellation(CancellationHandler.java:52) ~[io.airbyte-airbyte-commons-temporal-0.40.29.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$7(TemporalAttemptExecution.java:244) ~[io.airbyte-airbyte-workers-0.40.29.jar:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:577) ~[?:?]
	at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:358) ~[?:?]
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
2023-02-09 16:49:10 [33mWARN[m i.t.i.w.ActivityWorker$TaskHandlerImpl(logExceptionDuringResultReporting):365 - Failure during reporting of activity result to the server. ActivityId = ab5ce1ec-cf25-3f01-bdbf-01da7dc76e8f, ActivityType = RunWithJobOutput, WorkflowId=connection_manager_5c850adc-fc8e-4a6b-93c2-5a03da05e9d3, WorkflowType=ConnectionManagerWorkflow, RunId=6169ef4d-f971-4987-b4f6-739bc90c6bf6
io.grpc.StatusRuntimeException: NOT_FOUND: invalid activityID or activity already timed out or invoking workflow is completed
	at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:271) ~[grpc-stub-1.51.1.jar:1.51.1]
	at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:252) ~[grpc-stub-1.51.1.jar:1.51.1]
	at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:165) ~[grpc-stub-1.51.1.jar:1.51.1]
	at io.temporal.api.workflowservice.v1.WorkflowServiceGrpc$WorkflowServiceBlockingStub.respondActivityTaskFailed(WorkflowServiceGrpc.java:3866) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.lambda$sendReply$1(ActivityWorker.java:320) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.lambda$retry$0(GrpcRetryer.java:52) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcSyncRetryer.retry(GrpcSyncRetryer.java:67) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:60) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retry(GrpcRetryer.java:50) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.sendReply(ActivityWorker.java:315) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:252) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:206) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:179) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:93) ~[temporal-sdk-1.17.0.jar:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
2023-02-09 16:49:10 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getWorkerThread$5):198 - Completing future exceptionally...
io.airbyte.workers.exception.WorkerException: Unexpected error while getting checking connection.
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:126) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:41) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$5(TemporalAttemptExecution.java:195) ~[io.airbyte-airbyte-workers-0.40.29.jar:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
Caused by: io.airbyte.workers.exception.WorkerException
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:140) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.AirbyteIntegrationLauncher.check(AirbyteIntegrationLauncher.java:95) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:71) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	... 3 more
Caused by: java.lang.InterruptedException
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:1681) ~[?:?]
	at java.util.concurrent.LinkedBlockingDeque.pollFirst(LinkedBlockingDeque.java:515) ~[?:?]
	at java.util.concurrent.LinkedBlockingDeque.poll(LinkedBlockingDeque.java:677) ~[?:?]
	at io.airbyte.workers.process.KubePortManagerSingleton.take(KubePortManagerSingleton.java:67) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:98) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.process.AirbyteIntegrationLauncher.check(AirbyteIntegrationLauncher.java:95) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:71) ~[io.airbyte-airbyte-commons-worker-0.40.29.jar:?]
	... 3 more
2023-02-09 16:49:10 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -
2023-02-09 16:49:10 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK -----
2023-02-09 16:49:10 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 -