2022-04-19 10:29:24 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.36.0-alpha 2022-04-19 10:29:24 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/4/2/logs.log 2022-04-19 10:29:24 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.36.0-alpha 2022-04-19 10:29:24 INFO i.a.w.DefaultReplicationWorker(run):104 - start sync worker. job id: 4 attempt id: 2 2022-04-19 10:29:24 INFO i.a.w.DefaultReplicationWorker(run):116 - configured sync modes: {public.company_invoice=full_refresh - append, public.company_contract=full_refresh - append} 2022-04-19 10:29:24 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination... 2022-04-19 10:29:24 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-bigquery:1.1.0 exists... 2022-04-19 10:29:24 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-bigquery:1.1.0 was found locally. 2022-04-19 10:29:24 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 4 2022-04-19 10:29:24 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/4/2 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_CONNECTOR_IMAGE=airbyte/destination-bigquery:1.1.0 -e WORKER_JOB_ATTEMPT=2 -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e AIRBYTE_VERSION=0.36.0-alpha -e WORKER_JOB_ID=4 airbyte/destination-bigquery:1.1.0 write --config destination_config.json --catalog destination_catalog.json 2022-04-19 10:29:24 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-postgres:0.4.10 exists... 2022-04-19 10:29:24 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 4 2022-04-19 10:29:24 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-postgres:0.4.10 was found locally. 2022-04-19 10:29:24 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/4/2 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_CONNECTOR_IMAGE=airbyte/source-postgres:0.4.10 -e WORKER_JOB_ATTEMPT=2 -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e AIRBYTE_VERSION=0.36.0-alpha -e WORKER_JOB_ID=4 airbyte/source-postgres:0.4.10 read --config source_config.json --catalog source_catalog.json 2022-04-19 10:29:24 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):339 - Destination output thread started. 2022-04-19 10:29:25 INFO i.a.w.DefaultReplicationWorker(run):158 - Waiting for source and destination threads to complete. 2022-04-19 10:29:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):279 - Replication thread started. 2022-04-19 10:29:25 destination > SLF4J: Class path contains multiple SLF4J bindings. 2022-04-19 10:29:25 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-04-19 10:29:25 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-04-19 10:29:25 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-04-19 10:29:25 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-04-19 10:29:25 source > SLF4J: Class path contains multiple SLF4J bindings. 2022-04-19 10:29:25 source > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-04-19 10:29:25 source > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.30.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-04-19 10:29:25 source > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-04-19 10:29:26 source > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-04-19 10:29:27 source > 2022-04-19 10:29:27 INFO i.a.i.s.p.PostgresSource(main):364 - starting source: class io.airbyte.integrations.source.postgres.PostgresSource 2022-04-19 10:29:27 destination > 2022-04-19 10:29:27 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json} 2022-04-19 10:29:27 destination > 2022-04-19 10:29:27 INFO i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.destination.bigquery.BigQueryDestination 2022-04-19 10:29:27 destination > 2022-04-19 10:29:27 INFO i.a.i.b.IntegrationRunner(runInternal):122 - Command: WRITE 2022-04-19 10:29:27 destination > 2022-04-19 10:29:27 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'} 2022-04-19 10:29:27 source > 2022-04-19 10:29:27 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {read=null, catalog=source_catalog.json, config=source_config.json} 2022-04-19 10:29:27 source > 2022-04-19 10:29:27 INFO i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedSource 2022-04-19 10:29:27 source > 2022-04-19 10:29:27 INFO i.a.i.b.IntegrationRunner(runInternal):122 - Command: READ 2022-04-19 10:29:27 source > 2022-04-19 10:29:27 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Integration config: IntegrationConfig{command=READ, configPath='source_config.json', catalogPath='source_catalog.json', statePath='null'} 2022-04-19 10:29:27 destination > 2022-04-19 10:29:27 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-04-19 10:29:27 destination > 2022-04-19 10:29:27 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-04-19 10:29:27 destination > 2022-04-19 10:29:27 INFO i.a.i.d.b.BigQueryUtils(getLoadingMethod):295 - Selected loading method is set to: GCS 2022-04-19 10:29:28 source > 2022-04-19 10:29:28 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-04-19 10:29:28 source > 2022-04-19 10:29:28 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-04-19 10:29:28 source > 2022-04-19 10:29:28 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-04-19 10:29:28 source > 2022-04-19 10:29:28 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword multiline - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-04-19 10:29:28 destination > 2022-04-19 10:29:28 INFO i.a.i.d.s.S3FormatConfigs(getS3FormatConfig):22 - S3 format config: {"format_type":"AVRO","flattening":"No flattening","part_size_mb":"5"} 2022-04-19 10:29:28 destination > 2022-04-19 10:29:28 INFO i.a.i.d.b.BigQueryUtils(isKeepFilesInGcs):308 - All tmp files GCS will be kept in bucket when replication is finished 2022-04-19 10:29:28 source > 2022-04-19 10:29:28 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL 2022-04-19 10:29:29 destination > 2022-04-19 10:29:29 INFO i.a.i.d.b.BigQueryDestination(getGcsRecordConsumer):287 - Creating BigQuery staging message consumer with staging ID c2163e8f-9155-4625-933e-889144f76e3d at 2022-04-19T10:29:28.301Z 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.p.PostgresSource(isCdc):253 - using CDC: false 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$getCheckOperations$1):88 - Attempting to get metadata from the database to see if we can connect. 2022-04-19 10:29:29 destination > 2022-04-19 10:29:29 INFO i.a.i.d.b.BigQueryStagingConsumerFactory(lambda$createWriteConfigs$1):86 - BigQuery write config: BigQueryWriteConfig[streamName=company_contract, namespace=null, datasetId=staging, datasetLocation=US, tmpTableId=GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=staging, tableId=_airbyte_tmp_lpy_company_contract}}, targetTableId=GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=staging, tableId=_airbyte_raw_company_contract}}, tableSchema=Schema{fields=[Field{name=_airbyte_ab_id, type=STRING, mode=null, description=null, policyTags=null}, Field{name=_airbyte_emitted_at, type=TIMESTAMP, mode=null, description=null, policyTags=null}, Field{name=_airbyte_data, type=STRING, mode=null, description=null, policyTags=null}]}, syncMode=append, stagedFiles=[]] 2022-04-19 10:29:29 destination > 2022-04-19 10:29:29 INFO i.a.i.d.b.BigQueryStagingConsumerFactory(lambda$createWriteConfigs$1):86 - BigQuery write config: BigQueryWriteConfig[streamName=company_invoice, namespace=null, datasetId=staging, datasetLocation=US, tmpTableId=GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=staging, tableId=_airbyte_tmp_lvh_company_invoice}}, targetTableId=GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=staging, tableId=_airbyte_raw_company_invoice}}, tableSchema=Schema{fields=[Field{name=_airbyte_ab_id, type=STRING, mode=null, description=null, policyTags=null}, Field{name=_airbyte_emitted_at, type=TIMESTAMP, mode=null, description=null, policyTags=null}, Field{name=_airbyte_data, type=STRING, mode=null, description=null, policyTags=null}]}, syncMode=append, stagedFiles=[]] 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.r.CdcStateManager():26 - Initialized CDC state with: null 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='company_invoice', namespace='public'}, New Cursor Field: null. Resetting cursor value 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='company_contract', namespace='public'}, New Cursor Field: null. Resetting cursor value 2022-04-19 10:29:29 destination > 2022-04-19 10:29:29 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started. 2022-04-19 10:29:29 destination > 2022-04-19 10:29:29 INFO i.a.i.d.b.BigQueryStagingConsumerFactory(lambda$onStartFunction$3):98 - Preparing tmp tables in destination started for 2 streams 2022-04-19 10:29:29 destination > 2022-04-19 10:29:29 INFO i.a.i.d.b.BigQueryGcsOperations(createSchemaIfNotExists):86 - Creating dataset staging 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company_invoice column company_invoice_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company_invoice column company_contract_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company_invoice column source_file_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company_invoice column company_invoice_provided_id (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company_invoice column invoice_payment_date (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company_invoice column invoice_date (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company_invoice column invoice_gross_amount (type numeric[16]) -> Json type io.airbyte.protocol.models.JsonSchemaType@41c204a0 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company_invoice column currency (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company_invoice column invoice_status (type company_invoice_status[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company_invoice column created_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company_invoice column updated_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company_invoice column deleted_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company_invoice column original_currency (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company_invoice column original_invoice_gross_amount (type numeric[16]) -> Json type io.airbyte.protocol.models.JsonSchemaType@41c204a0 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table task_comment column task_comment_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table task_comment column task_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table task_comment column created_by (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table task_comment column text (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table task_comment column created_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table task_comment column updated_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table task_comment column deleted_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table file column file_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table file column file_name (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table file column file_extension (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table file column file_type (type file_type[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table file column file_key (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table file column file_size (type int8[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@41c204a0 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table file column created_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table file column updated_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table file column deleted_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table file column file_origin_type (type file_origin_type[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table file column file_content_type (type file_content_type[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table file column company_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table file column file_content_version (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table representative column representative_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table representative column company_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table representative column first_name (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table representative column last_name (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table representative column capacity (type representative_capacity[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table representative column created_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table representative column updated_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table fintec_bank_user column fintec_bank_user_id (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table fintec_bank_user column company_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table fintec_bank_user column access_token (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table fintec_bank_user column access_token_created_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table fintec_bank_user column access_token_valid_until (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table fintec_bank_user column created_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table fintec_bank_user column updated_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table fintec_bank_user column deleted_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table bank_account column bank_account_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table bank_account column company_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table bank_account column bank_account_state (type bank_account_state[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table bank_account column fintec_bank_user_id (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table bank_account column fintec_bank_account_connection_id (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table bank_account column fintec_bank_account_id (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table bank_account column joint_account (type bool[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@64138b0c 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table bank_account column holder (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table bank_account column iban (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table bank_account column bic (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table bank_account column bank_name (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table bank_account column bank_code (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table bank_account column bank_account_type (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table bank_account column currency (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table bank_account column balance (type numeric[16]) -> Json type io.airbyte.protocol.models.JsonSchemaType@41c204a0 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table bank_account column last_synced_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table bank_account column created_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table bank_account column updated_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table bank_account column deleted_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table bank_account column sepa_id (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payback column payback_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payback column payout_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payback column payback_amount (type numeric[16]) -> Json type io.airbyte.protocol.models.JsonSchemaType@41c204a0 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payback column month_offset (type int4[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@41c204a0 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payback column payback_start_date (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payback column payback_end_date (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payback column payback_date (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payback column payback_status (type payback_status[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payback column created_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payback column updated_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payback column deleted_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payback column company_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company column company_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company column account_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company column company_state (type recap_company_state[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company column company_onboarding_state (type recap_company_onboarding_state[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company column incorporation_form (type company_incorporation_form[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company column annual_recurring_revenue (type company_annual_recurring_revenue[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company column industry (type industry[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company column sales_staff_costs (type numeric[16]) -> Json type io.airbyte.protocol.models.JsonSchemaType@41c204a0 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company column marketing_staff_costs (type numeric[16]) -> Json type io.airbyte.protocol.models.JsonSchemaType@41c204a0 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company column company_name (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company column address_street_and_house_number (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company column address_postal_code (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company column address_city (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company column commercial_register_number (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company column registration_court (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company column founding_date (type date[13]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company column tax_id (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company column website (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company column number_of_employees (type number_of_employees[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:29 source > 2022-04-19 10:29:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company column country_of_incorporation (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company column score (type credit_score[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company column fee (type numeric[16]) -> Json type io.airbyte.protocol.models.JsonSchemaType@41c204a0 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company column investment_limit (type int8[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@41c204a0 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company column horizon_in_months (type int8[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@41c204a0 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company column accept_terms_of_service (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company column accept_data_privace_policy (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company column verify_legal_representative (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company column data_correctness_confirmation (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company column created_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company column updated_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company column benchmark_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company column deleted_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company column creditsafe_id (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company column active_bank_account_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payout_company_contract column payout_company_contract_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payout_company_contract column payout_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payout_company_contract column company_contract_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payout_company_contract column start_month_offset (type int4[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@41c204a0 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payout_company_contract column end_month_offset (type int4[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@41c204a0 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payout_company_contract column payout_company_contract_status (type payout_company_contract_status[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payout_company_contract column payout_amount (type numeric[16]) -> Json type io.airbyte.protocol.models.JsonSchemaType@41c204a0 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payout_company_contract column payback_amount (type numeric[16]) -> Json type io.airbyte.protocol.models.JsonSchemaType@41c204a0 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payout_company_contract column created_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payout_company_contract column updated_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payout_company_contract column deleted_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payout_company_contract column payback_start_date (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payout_company_contract column payback_end_date (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payout_company_contract column problems (type _text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@49dbaaf3 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payout_company_contract column billing_cycle (type billing_cycle[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payout_company_contract column original_currency (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payout_company_contract column original_current_gross_value (type numeric[16]) -> Json type io.airbyte.protocol.models.JsonSchemaType@41c204a0 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payout_company_contract column contract_start_date (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payout_company_contract column contract_end_date (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table risk_model_input column risk_model_input_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table risk_model_input column company_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table risk_model_input column data (type jsonb[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table risk_model_input column created_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table risk_model_input column updated_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table risk_model_input column deleted_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table data_connection column data_connection_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table data_connection column company_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table data_connection column connection_type (type data_connection_type[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table data_connection column stripe_user_id (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table data_connection column stripe_refresh_token (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table data_connection column created_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table data_connection column api_key (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table data_connection column url (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table data_connection column updated_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table data_connection column deleted_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table data_connection column client_id (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table data_connection column client_secret (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table uploaded_file column file_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table uploaded_file column company_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table uploaded_file column user_upload (type bool[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@64138b0c 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table activity_log column activity_log_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table activity_log column linked_entity (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table activity_log column linked_entity_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table activity_log column activity_type (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table activity_log column description (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table activity_log column comment (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table activity_log column change (type jsonb[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table activity_log column created_by (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table activity_log column created_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table activity_log column deleted_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table activity_log column company_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payout column payout_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payout column company_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payout column bank_account_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payout column payout_status (type payout_status[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payout column payout_amount (type numeric[16]) -> Json type io.airbyte.protocol.models.JsonSchemaType@41c204a0 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payout column financing_period_in_months (type int4[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@41c204a0 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payout column financing_fee (type numeric[16]) -> Json type io.airbyte.protocol.models.JsonSchemaType@41c204a0 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payout column payback_start_date (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payout column payback_end_date (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payout column payback_amount (type numeric[16]) -> Json type io.airbyte.protocol.models.JsonSchemaType@41c204a0 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payout column created_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payout column updated_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payout column deleted_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table task column task_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table task column title (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table task column description (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table task column type (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table task column comment_required (type bool[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@64138b0c 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table task column linked_entity (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table task column priority (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table task column category (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table task column completed_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table task column completed_by (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table task column created_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table task column updated_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table task column deleted_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table task column company_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table task column created_by (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table task column linked_entity_type (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table fintec_bank_account_transaction column fintec_bank_account_transaction_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table fintec_bank_account_transaction column bank_account_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table fintec_bank_account_transaction column booking_date (type date[13]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table fintec_bank_account_transaction column amount (type numeric[16]) -> Json type io.airbyte.protocol.models.JsonSchemaType@41c204a0 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table fintec_bank_account_transaction column currency (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table fintec_bank_account_transaction column purpose (type _text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@49dbaaf3 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table fintec_bank_account_transaction column counter_iban (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table fintec_bank_account_transaction column counter_bic (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table fintec_bank_account_transaction column counter_holder (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table fintec_bank_account_transaction column prebooked (type bool[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@64138b0c 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table fintec_bank_account_transaction column canceled (type bool[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@64138b0c 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table fintec_bank_account_transaction column tags (type _text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@49dbaaf3 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table fintec_bank_account_transaction column category_id (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table fintec_bank_account_transaction column creditor_id (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table fintec_bank_account_transaction column new (type bool[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@64138b0c 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table fintec_bank_account_transaction column created_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table representative_file column file_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table representative_file column representative_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table risk_model_scorecard column scorecard_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table risk_model_scorecard column company_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table risk_model_scorecard column created_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table risk_model_scorecard column data (type jsonb[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table risk_model_scorecard column execution_state (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table risk_model_scorecard column risk_model_version (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table risk_model_scorecard column updated_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table risk_model_scorecard column deleted_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table risk_model_scorecard column benchmark_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table risk_model_scorecard column score_result (type jsonb[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table risk_model_scorecard column score_overwrites (type jsonb[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table risk_model_scorecard column file_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table account column account_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table account column keycloak_id (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table account column account_type (type recap_account_type[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table account column first_name (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table account column last_name (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table account column email (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table account column mobile (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table account column created_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table account column updated_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table account column mobile_country (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table account column deleted_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table account column last_sign_in (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table file_source_files column file_file_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table file_source_files column source_file_file_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table file_source_files column created_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table file_source_files column updated_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table file_source_files column deleted_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table fintec_webhook_log column fintec_event_id (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table fintec_webhook_log column fintec_event_type (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table fintec_webhook_log column webhook_data (type json[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table fintec_webhook_log column created_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table fintec_webhook_log column updated_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table fintec_webhook_log column deleted_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company_contract column company_contract_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company_contract column company_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company_contract column source_file_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company_contract column customer_name (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company_contract column company_contract_provided_id (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company_contract column billing_cycle (type billing_cycle[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company_contract column contract_start_date (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company_contract column contract_end_date (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company_contract column latest_billing_date (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company_contract column recap_contract_status (type recap_contract_status[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company_contract column company_contract_status (type company_contract_status[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company_contract column current_gross_value (type numeric[16]) -> Json type io.airbyte.protocol.models.JsonSchemaType@41c204a0 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company_contract column currency (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company_contract column created_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company_contract column updated_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company_contract column deleted_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company_contract column customer_id (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company_contract column original_currency (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company_contract column original_current_gross_value (type numeric[16]) -> Json type io.airbyte.protocol.models.JsonSchemaType@41c204a0 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company_contract column financing_problems (type _text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@49dbaaf3 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table company_contract column financeability (type contract_financeability[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table schema_migrations column version (type varchar[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table data_file column file_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table data_file column transformed_file_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table data_file column company_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table data_file column data_source_type (type data_source_type[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table data_file column data_origin_type (type data_origin_type[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table agreement column agreement_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table agreement column docusign_envelope_id (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table agreement column company_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table agreement column company_sign_access_code (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table agreement column state (type agreement_state[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table agreement column created_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table agreement column updated_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table agreement column deleted_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table agreement column signed_file_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payback_company_contract column payback_company_contract_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payback_company_contract column payback_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payback_company_contract column company_invoice_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payback_company_contract column payout_company_contract_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payback_company_contract column payback_amount (type numeric[16]) -> Json type io.airbyte.protocol.models.JsonSchemaType@41c204a0 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payback_company_contract column estimated_payback_date (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payback_company_contract column payback_company_contract_status (type payback_company_contract_status[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payback_company_contract column created_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payback_company_contract column updated_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payback_company_contract column deleted_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payback_company_contract column payback_company_contract_type (type payback_company_contract_type[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table payback_company_contract column grace_period_end_date (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table benchmark column benchmark_id (type uuid[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table benchmark column name (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table benchmark column data (type jsonb[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table benchmark column created_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table benchmark column updated_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table benchmark column deleted_at (type timestamptz[35]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table benchmark column version (type text[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@a64e035 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.p.PostgresSource(isCdc):253 - using CDC: false 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: company_contract 2022-04-19 10:29:30 source > 2022-04-19 10:29:30 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: company_invoice 2022-04-19 10:29:31 destination > 2022-04-19 10:29:31 INFO i.a.i.d.b.BigQueryGcsOperations(createTmpTableIfNotExists):94 - Creating tmp table GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=staging, tableId=_airbyte_tmp_lpy_company_contract}} 2022-04-19 10:29:31 destination > 2022-04-19 10:29:31 INFO i.a.i.d.b.BigQueryUtils(createPartitionedTable):131 - Partitioned table created successfully: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=staging, tableId=_airbyte_tmp_lpy_company_contract}} 2022-04-19 10:29:31 destination > 2022-04-19 10:29:31 INFO i.a.i.d.b.BigQueryGcsOperations(createStageIfNotExists):101 - Creating staging path for stream company_contract (dataset staging): test/staging_company_contract/2022/04/19/10/c2163e8f-9155-4625-933e-889144f76e3d/ 2022-04-19 10:29:31 destination > 2022-04-19 10:29:31 ERROR i.a.i.b.FailureTrackingAirbyteMessageConsumer(start):39 - Exception while starting consumer 2022-04-19 10:29:31 destination > com.amazonaws.services.s3.model.AmazonS3Exception: Forbidden (Service: Amazon S3; Status Code: 403; Error Code: 403 Forbidden; Request ID: null; S3 Extended Request ID: null; Proxy: null) 2022-04-19 10:29:31 destination > at com.amazonaws.http.AmazonHttpClient$RequestExecutor.handleErrorResponse(AmazonHttpClient.java:1819) ~[aws-java-sdk-core-1.12.14.jar:?] 2022-04-19 10:29:31 destination > at com.amazonaws.http.AmazonHttpClient$RequestExecutor.handleServiceErrorResponse(AmazonHttpClient.java:1403) ~[aws-java-sdk-core-1.12.14.jar:?] 2022-04-19 10:29:31 destination > at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeOneRequest(AmazonHttpClient.java:1372) ~[aws-java-sdk-core-1.12.14.jar:?] 2022-04-19 10:29:31 destination > at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeHelper(AmazonHttpClient.java:1145) ~[aws-java-sdk-core-1.12.14.jar:?] 2022-04-19 10:29:31 destination > at com.amazonaws.http.AmazonHttpClient$RequestExecutor.doExecute(AmazonHttpClient.java:802) ~[aws-java-sdk-core-1.12.14.jar:?] 2022-04-19 10:29:31 destination > at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeWithTimer(AmazonHttpClient.java:770) ~[aws-java-sdk-core-1.12.14.jar:?] 2022-04-19 10:29:31 destination > at com.amazonaws.http.AmazonHttpClient$RequestExecutor.execute(AmazonHttpClient.java:744) ~[aws-java-sdk-core-1.12.14.jar:?] 2022-04-19 10:29:31 destination > at com.amazonaws.http.AmazonHttpClient$RequestExecutor.access$500(AmazonHttpClient.java:704) ~[aws-java-sdk-core-1.12.14.jar:?] 2022-04-19 10:29:31 destination > at com.amazonaws.http.AmazonHttpClient$RequestExecutionBuilderImpl.execute(AmazonHttpClient.java:686) ~[aws-java-sdk-core-1.12.14.jar:?] 2022-04-19 10:29:31 destination > at com.amazonaws.http.AmazonHttpClient.execute(AmazonHttpClient.java:550) ~[aws-java-sdk-core-1.12.14.jar:?] 2022-04-19 10:29:31 destination > at com.amazonaws.http.AmazonHttpClient.execute(AmazonHttpClient.java:530) ~[aws-java-sdk-core-1.12.14.jar:?] 2022-04-19 10:29:31 destination > at com.amazonaws.services.s3.AmazonS3Client.invoke(AmazonS3Client.java:5437) ~[aws-java-sdk-s3-1.12.14.jar:?] 2022-04-19 10:29:31 destination > at com.amazonaws.services.s3.AmazonS3Client.invoke(AmazonS3Client.java:5384) ~[aws-java-sdk-s3-1.12.14.jar:?] 2022-04-19 10:29:31 destination > at com.amazonaws.services.s3.AmazonS3Client.getObjectMetadata(AmazonS3Client.java:1367) ~[aws-java-sdk-s3-1.12.14.jar:?] 2022-04-19 10:29:31 destination > at com.amazonaws.services.s3.AmazonS3Client.getObjectMetadata(AmazonS3Client.java:1341) ~[aws-java-sdk-s3-1.12.14.jar:?] 2022-04-19 10:29:31 destination > at com.amazonaws.services.s3.AmazonS3Client.doesObjectExist(AmazonS3Client.java:1422) ~[aws-java-sdk-s3-1.12.14.jar:?] 2022-04-19 10:29:31 destination > at io.airbyte.integrations.destination.s3.S3StorageOperations.createBucketObjectIfNotExists(S3StorageOperations.java:93) ~[io.airbyte.airbyte-integrations.connectors-destination-s3-0.35.65-alpha.jar:?] 2022-04-19 10:29:31 destination > at io.airbyte.integrations.destination.bigquery.BigQueryGcsOperations.createStageIfNotExists(BigQueryGcsOperations.java:102) ~[io.airbyte.airbyte-integrations.connectors-destination-bigquery-0.35.65-alpha.jar:?] 2022-04-19 10:29:31 destination > at io.airbyte.integrations.destination.bigquery.BigQueryStagingConsumerFactory.lambda$onStartFunction$3(BigQueryStagingConsumerFactory.java:105) ~[io.airbyte.airbyte-integrations.connectors-destination-bigquery-0.35.65-alpha.jar:?] 2022-04-19 10:29:31 destination > at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15) ~[io.airbyte-airbyte-commons-0.35.65-alpha.jar:?] 2022-04-19 10:29:31 destination > at io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer.startTracked(BufferedStreamConsumer.java:118) ~[io.airbyte.airbyte-integrations.bases-base-java-0.35.65-alpha.jar:?] 2022-04-19 10:29:31 destination > at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:54) ~[io.airbyte.airbyte-integrations.bases-base-java-0.35.65-alpha.jar:?] 2022-04-19 10:29:31 destination > at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.start(FailureTrackingAirbyteMessageConsumer.java:36) ~[io.airbyte.airbyte-integrations.bases-base-java-0.35.65-alpha.jar:?] 2022-04-19 10:29:31 destination > at io.airbyte.integrations.base.IntegrationRunner.consumeWriteStream(IntegrationRunner.java:177) ~[io.airbyte.airbyte-integrations.bases-base-java-0.35.65-alpha.jar:?] 2022-04-19 10:29:31 destination > at io.airbyte.integrations.base.IntegrationRunner.lambda$runConsumer$2(IntegrationRunner.java:191) ~[io.airbyte.airbyte-integrations.bases-base-java-0.35.65-alpha.jar:?] 2022-04-19 10:29:31 destination > at io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:220) ~[io.airbyte.airbyte-integrations.bases-base-java-0.35.65-alpha.jar:?] 2022-04-19 10:29:31 destination > at io.airbyte.integrations.base.IntegrationRunner.runConsumer(IntegrationRunner.java:190) ~[io.airbyte.airbyte-integrations.bases-base-java-0.35.65-alpha.jar:?] 2022-04-19 10:29:31 destination > at io.airbyte.integrations.base.IntegrationRunner.lambda$runInternal$1(IntegrationRunner.java:163) ~[io.airbyte.airbyte-integrations.bases-base-java-0.35.65-alpha.jar:?] 2022-04-19 10:29:31 destination > at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:54) [io.airbyte.airbyte-integrations.bases-base-java-0.35.65-alpha.jar:?] 2022-04-19 10:29:31 destination > at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:38) [io.airbyte.airbyte-integrations.bases-base-java-0.35.65-alpha.jar:?] 2022-04-19 10:29:31 destination > at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:163) [io.airbyte.airbyte-integrations.bases-base-java-0.35.65-alpha.jar:?] 2022-04-19 10:29:31 destination > at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:105) [io.airbyte.airbyte-integrations.bases-base-java-0.35.65-alpha.jar:?] 2022-04-19 10:29:31 destination > at io.airbyte.integrations.destination.bigquery.BigQueryDestination.main(BigQueryDestination.java:313) [io.airbyte.airbyte-integrations.connectors-destination-bigquery-0.35.65-alpha.jar:?] 2022-04-19 10:29:31 destination > 2022-04-19 10:29:31 WARN i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):63 - Airbyte message consumer: failed. 2022-04-19 10:29:31 destination > 2022-04-19 10:29:31 ERROR i.a.i.d.b.BufferedStreamConsumer(close):168 - executing on failed close procedure. 2022-04-19 10:29:31 destination > 2022-04-19 10:29:31 INFO i.a.i.d.b.BigQueryStagingConsumerFactory(lambda$onCloseFunction$5):159 - Cleaning up destination started for 2 streams 2022-04-19 10:29:31 destination > 2022-04-19 10:29:31 INFO i.a.i.d.b.BigQueryGcsOperations(dropTableIfExists):172 - Deleting tmp table GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=staging, tableId=_airbyte_tmp_lpy_company_contract}} (dataset staging) 2022-04-19 10:29:32 destination > 2022-04-19 10:29:32 INFO i.a.i.d.b.BigQueryGcsOperations(dropTableIfExists):172 - Deleting tmp table GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=staging, tableId=_airbyte_tmp_lvh_company_invoice}} (dataset staging) 2022-04-19 10:29:32 destination > 2022-04-19 10:29:32 INFO i.a.i.d.b.BigQueryStagingConsumerFactory(lambda$onCloseFunction$5):164 - Cleaning up destination completed. 2022-04-19 10:29:32 destination > Exception in thread "main" com.amazonaws.services.s3.model.AmazonS3Exception: Forbidden (Service: Amazon S3; Status Code: 403; Error Code: 403 Forbidden; Request ID: null; S3 Extended Request ID: null; Proxy: null), S3 Extended Request ID: null 2022-04-19 10:29:32 destination > at com.amazonaws.http.AmazonHttpClient$RequestExecutor.handleErrorResponse(AmazonHttpClient.java:1819) 2022-04-19 10:29:32 destination > at com.amazonaws.http.AmazonHttpClient$RequestExecutor.handleServiceErrorResponse(AmazonHttpClient.java:1403) 2022-04-19 10:29:32 destination > at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeOneRequest(AmazonHttpClient.java:1372) 2022-04-19 10:29:32 destination > at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeHelper(AmazonHttpClient.java:1145) 2022-04-19 10:29:32 destination > at com.amazonaws.http.AmazonHttpClient$RequestExecutor.doExecute(AmazonHttpClient.java:802) 2022-04-19 10:29:32 destination > at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeWithTimer(AmazonHttpClient.java:770) 2022-04-19 10:29:32 destination > at com.amazonaws.http.AmazonHttpClient$RequestExecutor.execute(AmazonHttpClient.java:744) 2022-04-19 10:29:32 destination > at com.amazonaws.http.AmazonHttpClient$RequestExecutor.access$500(AmazonHttpClient.java:704) 2022-04-19 10:29:32 destination > at com.amazonaws.http.AmazonHttpClient$RequestExecutionBuilderImpl.execute(AmazonHttpClient.java:686) 2022-04-19 10:29:32 destination > at com.amazonaws.http.AmazonHttpClient.execute(AmazonHttpClient.java:550) 2022-04-19 10:29:32 destination > at com.amazonaws.http.AmazonHttpClient.execute(AmazonHttpClient.java:530) 2022-04-19 10:29:32 destination > at com.amazonaws.services.s3.AmazonS3Client.invoke(AmazonS3Client.java:5437) 2022-04-19 10:29:32 destination > at com.amazonaws.services.s3.AmazonS3Client.invoke(AmazonS3Client.java:5384) 2022-04-19 10:29:32 destination > at com.amazonaws.services.s3.AmazonS3Client.getObjectMetadata(AmazonS3Client.java:1367) 2022-04-19 10:29:32 destination > at com.amazonaws.services.s3.AmazonS3Client.getObjectMetadata(AmazonS3Client.java:1341) 2022-04-19 10:29:32 destination > at com.amazonaws.services.s3.AmazonS3Client.doesObjectExist(AmazonS3Client.java:1422) 2022-04-19 10:29:32 destination > at io.airbyte.integrations.destination.s3.S3StorageOperations.createBucketObjectIfNotExists(S3StorageOperations.java:93) 2022-04-19 10:29:32 destination > at io.airbyte.integrations.destination.bigquery.BigQueryGcsOperations.createStageIfNotExists(BigQueryGcsOperations.java:102) 2022-04-19 10:29:32 destination > at io.airbyte.integrations.destination.bigquery.BigQueryStagingConsumerFactory.lambda$onStartFunction$3(BigQueryStagingConsumerFactory.java:105) 2022-04-19 10:29:32 destination > at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15) 2022-04-19 10:29:32 destination > at io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer.startTracked(BufferedStreamConsumer.java:118) 2022-04-19 10:29:32 destination > at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:54) 2022-04-19 10:29:32 destination > at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.start(FailureTrackingAirbyteMessageConsumer.java:36) 2022-04-19 10:29:32 destination > at io.airbyte.integrations.base.IntegrationRunner.consumeWriteStream(IntegrationRunner.java:177) 2022-04-19 10:29:32 destination > at io.airbyte.integrations.base.IntegrationRunner.lambda$runConsumer$2(IntegrationRunner.java:191) 2022-04-19 10:29:32 destination > at io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:220) 2022-04-19 10:29:32 destination > at io.airbyte.integrations.base.IntegrationRunner.runConsumer(IntegrationRunner.java:190) 2022-04-19 10:29:32 destination > at io.airbyte.integrations.base.IntegrationRunner.lambda$runInternal$1(IntegrationRunner.java:163) 2022-04-19 10:29:32 destination > at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:54) 2022-04-19 10:29:32 destination > at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:38) 2022-04-19 10:29:32 destination > at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:163) 2022-04-19 10:29:32 destination > at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:105) 2022-04-19 10:29:32 destination > at io.airbyte.integrations.destination.bigquery.BigQueryDestination.main(BigQueryDestination.java:313) 2022-04-19 10:30:32 ERROR i.a.w.DefaultReplicationWorker(run):169 - Sync worker failed. java.util.concurrent.ExecutionException: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1 at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) ~[?:?] at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) ~[?:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:162) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at java.lang.Thread.run(Thread.java:833) [?:?] Suppressed: io.airbyte.workers.WorkerException: Source process exit with code 1. This warning is normal if the job was cancelled. at io.airbyte.workers.protocols.airbyte.DefaultAirbyteSource.close(DefaultAirbyteSource.java:136) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:126) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at java.lang.Thread.run(Thread.java:833) [?:?] Suppressed: java.io.IOException: Stream closed at java.lang.ProcessBuilder$NullOutputStream.write(ProcessBuilder.java:445) ~[?:?] at java.io.OutputStream.write(OutputStream.java:162) ~[?:?] at java.io.BufferedOutputStream.write(BufferedOutputStream.java:123) ~[?:?] at sun.nio.cs.StreamEncoder.writeBytes(StreamEncoder.java:234) ~[?:?] at sun.nio.cs.StreamEncoder.implFlushBuffer(StreamEncoder.java:313) ~[?:?] at sun.nio.cs.StreamEncoder.implFlush(StreamEncoder.java:318) ~[?:?] at sun.nio.cs.StreamEncoder.flush(StreamEncoder.java:160) ~[?:?] at java.io.OutputStreamWriter.flush(OutputStreamWriter.java:248) ~[?:?] at java.io.BufferedWriter.flush(BufferedWriter.java:257) ~[?:?] at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.notifyEndOfStream(DefaultAirbyteDestination.java:98) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.close(DefaultAirbyteDestination.java:111) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:126) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at java.lang.Thread.run(Thread.java:833) [?:?] Caused by: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1 at io.airbyte.workers.DefaultReplicationWorker.lambda$getDestinationOutputRunnable$6(DefaultReplicationWorker.java:354) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ~[?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?] ... 1 more 2022-04-19 10:30:32 WARN i.a.c.i.LineGobbler(voidCall):86 - airbyte-source gobbler IOException: Stream closed. Typically happens when cancelling a job. 2022-04-19 10:30:32 INFO i.a.w.DefaultReplicationWorker(run):228 - sync summary: io.airbyte.config.ReplicationAttemptSummary@36d3cc44[status=failed,recordsSynced=445,bytesSynced=409673,startTime=1650364164838,endTime=1650364232308,totalStats=io.airbyte.config.SyncStats@40804ea1[recordsEmitted=445,bytesEmitted=409673,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@7935d724[streamName=company_contract,stats=io.airbyte.config.SyncStats@30bad5a3[recordsEmitted=445,bytesEmitted=409673,stateMessagesEmitted=,recordsCommitted=]]]] 2022-04-19 10:30:32 INFO i.a.w.DefaultReplicationWorker(run):250 - Source did not output any state messages 2022-04-19 10:30:32 WARN i.a.w.DefaultReplicationWorker(run):261 - State capture: No state retained. 2022-04-19 10:30:32 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2022-04-19 10:30:32 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$1):147 - sync summary: io.airbyte.config.StandardSyncOutput@2a845acf[standardSyncSummary=io.airbyte.config.StandardSyncSummary@3e83e9b7[status=failed,recordsSynced=445,bytesSynced=409673,startTime=1650364164838,endTime=1650364232308,totalStats=io.airbyte.config.SyncStats@40804ea1[recordsEmitted=445,bytesEmitted=409673,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@7935d724[streamName=company_contract,stats=io.airbyte.config.SyncStats@30bad5a3[recordsEmitted=445,bytesEmitted=409673,stateMessagesEmitted=,recordsCommitted=]]]],normalizationSummary=,state=,outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@522baafd[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@6fe9b879[stream=io.airbyte.protocol.models.AirbyteStream@67b3d569[name=company_contract,jsonSchema={"type":"object","properties":{"currency":{"type":"string"},"company_id":{"type":"string"},"created_at":{"type":"string"},"deleted_at":{"type":"string"},"updated_at":{"type":"string"},"customer_id":{"type":"string"},"billing_cycle":{"type":"string"},"customer_name":{"type":"string"},"financeability":{"type":"string"},"source_file_id":{"type":"string"},"contract_end_date":{"type":"string"},"original_currency":{"type":"string"},"financing_problems":{"type":"array"},"company_contract_id":{"type":"string"},"contract_start_date":{"type":"string"},"current_gross_value":{"type":"number"},"latest_billing_date":{"type":"string"},"recap_contract_status":{"type":"string"},"company_contract_status":{"type":"string"},"company_contract_provided_id":{"type":"string"},"original_current_gross_value":{"type":"number"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[[company_contract_id]],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[[company_contract_id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@46dc5679[stream=io.airbyte.protocol.models.AirbyteStream@492f601d[name=company_invoice,jsonSchema={"type":"object","properties":{"currency":{"type":"string"},"created_at":{"type":"string"},"deleted_at":{"type":"string"},"updated_at":{"type":"string"},"invoice_date":{"type":"string"},"invoice_status":{"type":"string"},"source_file_id":{"type":"string"},"original_currency":{"type":"string"},"company_invoice_id":{"type":"string"},"company_contract_id":{"type":"string"},"invoice_gross_amount":{"type":"number"},"invoice_payment_date":{"type":"string"},"company_invoice_provided_id":{"type":"string"},"original_invoice_gross_amount":{"type":"number"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[[company_invoice_id]],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[[company_invoice_id]],additionalProperties={}]],additionalProperties={}],failures=[io.airbyte.config.FailureReason@6ba72331[failureOrigin=destination,failureType=,internalMessage=io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process message delivery failed,externalMessage=Something went wrong within the destination connector,metadata=io.airbyte.config.Metadata@12c6abb1[additionalProperties={attemptNumber=2, jobId=4}],stacktrace=java.util.concurrent.CompletionException: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process message delivery failed at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315) at java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:320) at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1807) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at java.base/java.lang.Thread.run(Thread.java:833) Caused by: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process message delivery failed at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:296) at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ... 3 more Caused by: java.io.IOException: Broken pipe at java.base/java.io.FileOutputStream.writeBytes(Native Method) at java.base/java.io.FileOutputStream.write(FileOutputStream.java:349) at java.base/java.io.BufferedOutputStream.write(BufferedOutputStream.java:123) at java.base/sun.nio.cs.StreamEncoder.writeBytes(StreamEncoder.java:234) at java.base/sun.nio.cs.StreamEncoder.implWrite(StreamEncoder.java:304) at java.base/sun.nio.cs.StreamEncoder.implWrite(StreamEncoder.java:282) at java.base/sun.nio.cs.StreamEncoder.write(StreamEncoder.java:132) at java.base/java.io.OutputStreamWriter.write(OutputStreamWriter.java:205) at java.base/java.io.BufferedWriter.flushBuffer(BufferedWriter.java:120) at java.base/java.io.BufferedWriter.write(BufferedWriter.java:233) at java.base/java.io.Writer.write(Writer.java:249) at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.accept(DefaultAirbyteDestination.java:90) at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:294) ... 4 more ,retryable=,timestamp=1650364172296], io.airbyte.config.FailureReason@360d580e[failureOrigin=destination,failureType=,internalMessage=io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1,externalMessage=Something went wrong within the destination connector,metadata=io.airbyte.config.Metadata@490e95a[additionalProperties={attemptNumber=2, jobId=4}],stacktrace=java.util.concurrent.CompletionException: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1 at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315) at java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:320) at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1807) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at java.base/java.lang.Thread.run(Thread.java:833) Caused by: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1 at io.airbyte.workers.DefaultReplicationWorker.lambda$getDestinationOutputRunnable$6(DefaultReplicationWorker.java:354) at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ... 3 more ,retryable=,timestamp=1650364172295]]] 2022-04-19 10:30:32 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating... 2022-04-19 10:30:32 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/4/2/logs.log 2022-04-19 10:30:32 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.36.0-alpha 2022-04-19 10:30:32 INFO i.a.w.DefaultNormalizationWorker(run):47 - Running normalization. 2022-04-19 10:30:32 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):122 - Running with normalization version: airbyte/normalization:0.1.75 2022-04-19 10:30:32 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/normalization:0.1.75 exists... 2022-04-19 10:30:32 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/normalization:0.1.75 was found locally. 2022-04-19 10:30:32 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 4 2022-04-19 10:30:32 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/4/2/normalize --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e AIRBYTE_VERSION=0.36.0-alpha airbyte/normalization:0.1.75 run --integration-type bigquery --config destination_config.json --catalog destination_catalog.json 2022-04-19 10:30:32 normalization > Running: transform-config --config destination_config.json --integration-type bigquery --out /data/4/2/normalize 2022-04-19 10:30:32 normalization > Namespace(config='destination_config.json', integration_type=, out='/data/4/2/normalize') 2022-04-19 10:30:32 normalization > transform_bigquery 2022-04-19 10:30:32 normalization > Running: transform-catalog --integration-type bigquery --profile-config-dir /data/4/2/normalize --catalog destination_catalog.json --out /data/4/2/normalize/models/generated/ --json-column _airbyte_data 2022-04-19 10:30:33 normalization > Processing destination_catalog.json... 2022-04-19 10:30:33 normalization > Generating airbyte_ctes/staging/company_contract_ab1.sql from company_contract 2022-04-19 10:30:33 normalization > Generating airbyte_ctes/staging/company_contract_ab2.sql from company_contract 2022-04-19 10:30:33 normalization > Generating airbyte_ctes/staging/company_contract_ab3.sql from company_contract 2022-04-19 10:30:33 normalization > Generating airbyte_incremental/staging/company_contract.sql from company_contract 2022-04-19 10:30:33 normalization > Generating airbyte_ctes/staging/company_invoice_ab1.sql from company_invoice 2022-04-19 10:30:33 normalization > Generating airbyte_ctes/staging/company_invoice_ab2.sql from company_invoice 2022-04-19 10:30:33 normalization > Generating airbyte_ctes/staging/company_invoice_ab3.sql from company_invoice 2022-04-19 10:30:33 normalization > Generating airbyte_incremental/staging/company_invoice.sql from company_invoice 2022-04-19 10:30:33 normalization > detected no config file for ssh, assuming ssh is off. 2022-04-19 10:30:35 normalization > [--event-buffer-size EVENT_BUFFER_SIZE] 2022-04-19 10:30:35 normalization > --event-buffer-size EVENT_BUFFER_SIZE 2022-04-19 10:30:35 normalization > 2022-04-19 10:30:35 normalization > DBT >=1.0.0 detected; using 10K event buffer size 2022-04-19 10:30:35 normalization > 2022-04-19 10:30:39 normalization > 10:30:39 Running with dbt=1.0.0 2022-04-19 10:30:39 normalization > 10:30:39 Partial parse save file not found. Starting full parse. 2022-04-19 10:30:40 normalization > 10:30:40 [WARNING]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources. 2022-04-19 10:30:40 normalization > There are 2 unused configuration paths: 2022-04-19 10:30:40 normalization > - models.airbyte_utils.generated.airbyte_views 2022-04-19 10:30:40 normalization > - models.airbyte_utils.generated.airbyte_tables 2022-04-19 10:30:40 normalization > 2022-04-19 10:30:40 normalization > 10:30:40 Found 8 models, 0 tests, 0 snapshots, 0 analyses, 537 macros, 0 operations, 0 seed files, 2 sources, 0 exposures, 0 metrics 2022-04-19 10:30:40 normalization > 10:30:40 2022-04-19 10:30:41 normalization > 10:30:41 Concurrency: 8 threads (target='prod') 2022-04-19 10:30:41 normalization > 10:30:41 2022-04-19 10:30:42 normalization > 10:30:42 1 of 2 START incremental model staging.company_invoice.................................................................. [RUN] 2022-04-19 10:30:42 normalization > 10:30:42 2 of 2 START incremental model staging.company_contract................................................................. [RUN] 2022-04-19 10:30:42 normalization > 10:30:42 10:30:42 + `recap-dev-347108`.staging.`company_contract`._airbyte_ab_id does not exist yet. The table will be created or rebuilt with dbt.full_refresh 2022-04-19 10:30:42 normalization > 10:30:42 10:30:42 + `recap-dev-347108`.staging.`company_invoice`._airbyte_ab_id does not exist yet. The table will be created or rebuilt with dbt.full_refresh 2022-04-19 10:30:43 normalization > 10:30:43 2 of 2 ERROR creating incremental model staging.company_contract........................................................ [ERROR in 0.66s] 2022-04-19 10:30:43 normalization > 10:30:43 1 of 2 ERROR creating incremental model staging.company_invoice......................................................... [ERROR in 0.77s] 2022-04-19 10:30:43 normalization > 10:30:43 2022-04-19 10:30:43 normalization > 10:30:43 Finished running 2 incremental models in 2.48s. 2022-04-19 10:30:43 normalization > 10:30:43 2022-04-19 10:30:43 normalization > 10:30:43 Completed with 2 errors and 0 warnings: 2022-04-19 10:30:43 normalization > 10:30:43 2022-04-19 10:30:43 normalization > 10:30:43 Runtime Error in model company_contract (models/generated/airbyte_incremental/staging/company_contract.sql) 2022-04-19 10:30:43 normalization > 10:30:43 404 Not found: Table recap-dev-347108:staging._airbyte_raw_company_contract was not found in location US 2022-04-19 10:30:43 normalization > 10:30:43 2022-04-19 10:30:43 normalization > 10:30:43 (job ID: 5dc9d01e-d810-41b3-b947-826127408bac) 2022-04-19 10:30:43 normalization > 10:30:43 2022-04-19 10:30:43 normalization > 10:30:43 Runtime Error in model company_invoice (models/generated/airbyte_incremental/staging/company_invoice.sql) 2022-04-19 10:30:43 normalization > 10:30:43 404 Not found: Table recap-dev-347108:staging._airbyte_raw_company_invoice was not found in location US 2022-04-19 10:30:43 normalization > 10:30:43 2022-04-19 10:30:43 normalization > 10:30:43 (job ID: 645098c9-9f9d-4237-935d-d5710cdaec14) 2022-04-19 10:30:43 normalization > 10:30:43 2022-04-19 10:30:43 normalization > 10:30:43 Done. PASS=0 WARN=0 ERROR=2 SKIP=0 TOTAL=2 2022-04-19 10:30:43 normalization > 2022-04-19 10:30:43 normalization > Diagnosing dbt debug to check if destination is available for dbt and well configured (1): 2022-04-19 10:30:43 normalization > 2022-04-19 10:30:46 normalization > 10:30:46 Running with dbt=1.0.0 2022-04-19 10:30:46 normalization > dbt version: 1.0.0 2022-04-19 10:30:46 normalization > python version: 3.9.9 2022-04-19 10:30:46 normalization > python path: /usr/local/bin/python 2022-04-19 10:30:46 normalization > os info: Linux-5.10.106-102.504.amzn2.x86_64-x86_64-with-glibc2.31 2022-04-19 10:30:46 normalization > Using profiles.yml file at /data/4/2/normalize/profiles.yml 2022-04-19 10:30:46 normalization > Using dbt_project.yml file at /data/4/2/normalize/dbt_project.yml 2022-04-19 10:30:46 normalization > 2022-04-19 10:30:46 normalization > Configuration: 2022-04-19 10:30:46 normalization > profiles.yml file [OK found and valid] 2022-04-19 10:30:46 normalization > dbt_project.yml file [OK found and valid] 2022-04-19 10:30:46 normalization > 2022-04-19 10:30:46 normalization > Required dependencies: 2022-04-19 10:30:46 normalization > - git [OK found] 2022-04-19 10:30:46 normalization > 2022-04-19 10:30:46 normalization > Connection: 2022-04-19 10:30:46 normalization > method: service-account-json 2022-04-19 10:30:46 normalization > database: recap-dev-347108 2022-04-19 10:30:46 normalization > schema: staging 2022-04-19 10:30:46 normalization > location: US 2022-04-19 10:30:46 normalization > priority: interactive 2022-04-19 10:30:46 normalization > timeout_seconds: 300 2022-04-19 10:30:46 normalization > maximum_bytes_billed: None 2022-04-19 10:30:46 normalization > execution_project: recap-dev-347108 2022-04-19 10:30:47 normalization > Connection test: [OK connection ok] 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > All checks passed! 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > Forward dbt output logs to diagnose/debug errors (0): 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > ============================== 2022-04-19 10:30:39.052057 | 2cae4ef0-3aa2-4ba4-be7a-3b07b8a33f2b ============================== 2022-04-19 10:30:47 normalization > 10:30:39.052057 [info ] [MainThread]: Running with dbt=1.0.0 2022-04-19 10:30:47 normalization > 10:30:39.052641 [debug] [MainThread]: running dbt with arguments Namespace(record_timing_info=None, debug=None, log_format=None, write_json=None, use_colors=None, printer_width=None, warn_error=None, version_check=None, partial_parse=None, single_threaded=False, use_experimental_parser=None, static_parser=None, profiles_dir='/data/4/2/normalize', send_anonymous_usage_stats=None, fail_fast=None, event_buffer_size='10000', project_dir='/data/4/2/normalize', profile=None, target=None, vars='{}', log_cache_events=False, threads=None, select=None, exclude=None, selector_name=None, state=None, defer=None, full_refresh=False, cls=, which='run', rpc_method='run') 2022-04-19 10:30:47 normalization > 10:30:39.052876 [debug] [MainThread]: Tracking: do not track 2022-04-19 10:30:47 normalization > 10:30:39.081215 [info ] [MainThread]: Partial parse save file not found. Starting full parse. 2022-04-19 10:30:47 normalization > 10:30:39.108354 [debug] [MainThread]: Parsing macros/get_custom_schema.sql 2022-04-19 10:30:47 normalization > 10:30:39.109509 [debug] [MainThread]: Parsing macros/incremental.sql 2022-04-19 10:30:47 normalization > 10:30:39.117942 [debug] [MainThread]: Parsing macros/should_full_refresh.sql 2022-04-19 10:30:47 normalization > 10:30:39.124405 [debug] [MainThread]: Parsing macros/star_intersect.sql 2022-04-19 10:30:47 normalization > 10:30:39.131845 [debug] [MainThread]: Parsing macros/cross_db_utils/array.sql 2022-04-19 10:30:47 normalization > 10:30:39.149373 [debug] [MainThread]: Parsing macros/cross_db_utils/concat.sql 2022-04-19 10:30:47 normalization > 10:30:39.152120 [debug] [MainThread]: Parsing macros/cross_db_utils/current_timestamp.sql 2022-04-19 10:30:47 normalization > 10:30:39.152936 [debug] [MainThread]: Parsing macros/cross_db_utils/datatypes.sql 2022-04-19 10:30:47 normalization > 10:30:39.166262 [debug] [MainThread]: Parsing macros/cross_db_utils/except.sql 2022-04-19 10:30:47 normalization > 10:30:39.167321 [debug] [MainThread]: Parsing macros/cross_db_utils/hash.sql 2022-04-19 10:30:47 normalization > 10:30:39.168098 [debug] [MainThread]: Parsing macros/cross_db_utils/json_operations.sql 2022-04-19 10:30:47 normalization > 10:30:39.210577 [debug] [MainThread]: Parsing macros/cross_db_utils/quote.sql 2022-04-19 10:30:47 normalization > 10:30:39.212691 [debug] [MainThread]: Parsing macros/cross_db_utils/surrogate_key.sql 2022-04-19 10:30:47 normalization > 10:30:39.215216 [debug] [MainThread]: Parsing macros/cross_db_utils/type_conversions.sql 2022-04-19 10:30:47 normalization > 10:30:39.223101 [debug] [MainThread]: Parsing macros/schema_tests/equal_rowcount.sql 2022-04-19 10:30:47 normalization > 10:30:39.224587 [debug] [MainThread]: Parsing macros/schema_tests/equality.sql 2022-04-19 10:30:47 normalization > 10:30:39.232863 [debug] [MainThread]: Parsing macros/adapters.sql 2022-04-19 10:30:47 normalization > 10:30:39.262751 [debug] [MainThread]: Parsing macros/catalog.sql 2022-04-19 10:30:47 normalization > 10:30:39.269844 [debug] [MainThread]: Parsing macros/etc.sql 2022-04-19 10:30:47 normalization > 10:30:39.272374 [debug] [MainThread]: Parsing macros/materializations/copy.sql 2022-04-19 10:30:47 normalization > 10:30:39.275907 [debug] [MainThread]: Parsing macros/materializations/incremental.sql 2022-04-19 10:30:47 normalization > 10:30:39.296502 [debug] [MainThread]: Parsing macros/materializations/seed.sql 2022-04-19 10:30:47 normalization > 10:30:39.299918 [debug] [MainThread]: Parsing macros/materializations/snapshot.sql 2022-04-19 10:30:47 normalization > 10:30:39.302144 [debug] [MainThread]: Parsing macros/materializations/table.sql 2022-04-19 10:30:47 normalization > 10:30:39.307352 [debug] [MainThread]: Parsing macros/materializations/view.sql 2022-04-19 10:30:47 normalization > 10:30:39.310760 [debug] [MainThread]: Parsing macros/adapters/columns.sql 2022-04-19 10:30:47 normalization > 10:30:39.323831 [debug] [MainThread]: Parsing macros/adapters/freshness.sql 2022-04-19 10:30:47 normalization > 10:30:39.327746 [debug] [MainThread]: Parsing macros/adapters/indexes.sql 2022-04-19 10:30:47 normalization > 10:30:39.331399 [debug] [MainThread]: Parsing macros/adapters/metadata.sql 2022-04-19 10:30:47 normalization > 10:30:39.340849 [debug] [MainThread]: Parsing macros/adapters/persist_docs.sql 2022-04-19 10:30:47 normalization > 10:30:39.346941 [debug] [MainThread]: Parsing macros/adapters/relation.sql 2022-04-19 10:30:47 normalization > 10:30:39.359593 [debug] [MainThread]: Parsing macros/adapters/schema.sql 2022-04-19 10:30:47 normalization > 10:30:39.362537 [debug] [MainThread]: Parsing macros/etc/datetime.sql 2022-04-19 10:30:47 normalization > 10:30:39.373619 [debug] [MainThread]: Parsing macros/etc/statement.sql 2022-04-19 10:30:47 normalization > 10:30:39.379553 [debug] [MainThread]: Parsing macros/generic_test_sql/accepted_values.sql 2022-04-19 10:30:47 normalization > 10:30:39.381374 [debug] [MainThread]: Parsing macros/generic_test_sql/not_null.sql 2022-04-19 10:30:47 normalization > 10:30:39.382109 [debug] [MainThread]: Parsing macros/generic_test_sql/relationships.sql 2022-04-19 10:30:47 normalization > 10:30:39.383289 [debug] [MainThread]: Parsing macros/generic_test_sql/unique.sql 2022-04-19 10:30:47 normalization > 10:30:39.384227 [debug] [MainThread]: Parsing macros/get_custom_name/get_custom_alias.sql 2022-04-19 10:30:47 normalization > 10:30:39.386203 [debug] [MainThread]: Parsing macros/get_custom_name/get_custom_database.sql 2022-04-19 10:30:47 normalization > 10:30:39.388315 [debug] [MainThread]: Parsing macros/get_custom_name/get_custom_schema.sql 2022-04-19 10:30:47 normalization > 10:30:39.391658 [debug] [MainThread]: Parsing macros/materializations/configs.sql 2022-04-19 10:30:47 normalization > 10:30:39.394997 [debug] [MainThread]: Parsing macros/materializations/hooks.sql 2022-04-19 10:30:47 normalization > 10:30:39.400270 [debug] [MainThread]: Parsing macros/materializations/models/incremental/column_helpers.sql 2022-04-19 10:30:47 normalization > 10:30:39.406747 [debug] [MainThread]: Parsing macros/materializations/models/incremental/incremental.sql 2022-04-19 10:30:47 normalization > 10:30:39.420180 [debug] [MainThread]: Parsing macros/materializations/models/incremental/is_incremental.sql 2022-04-19 10:30:47 normalization > 10:30:39.422164 [debug] [MainThread]: Parsing macros/materializations/models/incremental/merge.sql 2022-04-19 10:30:47 normalization > 10:30:39.436829 [debug] [MainThread]: Parsing macros/materializations/models/incremental/on_schema_change.sql 2022-04-19 10:30:47 normalization > 10:30:39.457054 [debug] [MainThread]: Parsing macros/materializations/models/table/create_table_as.sql 2022-04-19 10:30:47 normalization > 10:30:39.461036 [debug] [MainThread]: Parsing macros/materializations/models/table/table.sql 2022-04-19 10:30:47 normalization > 10:30:39.470428 [debug] [MainThread]: Parsing macros/materializations/models/view/create_or_replace_view.sql 2022-04-19 10:30:47 normalization > 10:30:39.473998 [debug] [MainThread]: Parsing macros/materializations/models/view/create_view_as.sql 2022-04-19 10:30:47 normalization > 10:30:39.477157 [debug] [MainThread]: Parsing macros/materializations/models/view/helpers.sql 2022-04-19 10:30:47 normalization > 10:30:39.478953 [debug] [MainThread]: Parsing macros/materializations/models/view/view.sql 2022-04-19 10:30:47 normalization > 10:30:39.488112 [debug] [MainThread]: Parsing macros/materializations/seeds/helpers.sql 2022-04-19 10:30:47 normalization > 10:30:39.509215 [debug] [MainThread]: Parsing macros/materializations/seeds/seed.sql 2022-04-19 10:30:47 normalization > 10:30:39.517786 [debug] [MainThread]: Parsing macros/materializations/snapshots/helpers.sql 2022-04-19 10:30:47 normalization > 10:30:39.532295 [debug] [MainThread]: Parsing macros/materializations/snapshots/snapshot.sql 2022-04-19 10:30:47 normalization > 10:30:39.547280 [debug] [MainThread]: Parsing macros/materializations/snapshots/snapshot_merge.sql 2022-04-19 10:30:47 normalization > 10:30:39.549463 [debug] [MainThread]: Parsing macros/materializations/snapshots/strategies.sql 2022-04-19 10:30:47 normalization > 10:30:39.571944 [debug] [MainThread]: Parsing macros/materializations/tests/helpers.sql 2022-04-19 10:30:47 normalization > 10:30:39.574309 [debug] [MainThread]: Parsing macros/materializations/tests/test.sql 2022-04-19 10:30:47 normalization > 10:30:39.580257 [debug] [MainThread]: Parsing macros/materializations/tests/where_subquery.sql 2022-04-19 10:30:47 normalization > 10:30:39.582678 [debug] [MainThread]: Parsing tests/generic/builtin.sql 2022-04-19 10:30:47 normalization > 10:30:39.586740 [debug] [MainThread]: Parsing macros/cross_db_utils/_is_ephemeral.sql 2022-04-19 10:30:47 normalization > 10:30:39.589280 [debug] [MainThread]: Parsing macros/cross_db_utils/_is_relation.sql 2022-04-19 10:30:47 normalization > 10:30:39.590781 [debug] [MainThread]: Parsing macros/cross_db_utils/any_value.sql 2022-04-19 10:30:47 normalization > 10:30:39.592556 [debug] [MainThread]: Parsing macros/cross_db_utils/bool_or.sql 2022-04-19 10:30:47 normalization > 10:30:39.594747 [debug] [MainThread]: Parsing macros/cross_db_utils/cast_bool_to_text.sql 2022-04-19 10:30:47 normalization > 10:30:39.596879 [debug] [MainThread]: Parsing macros/cross_db_utils/concat.sql 2022-04-19 10:30:47 normalization > 10:30:39.598221 [debug] [MainThread]: Parsing macros/cross_db_utils/current_timestamp.sql 2022-04-19 10:30:47 normalization > 10:30:39.602933 [debug] [MainThread]: Parsing macros/cross_db_utils/datatypes.sql 2022-04-19 10:30:47 normalization > 10:30:39.611421 [debug] [MainThread]: Parsing macros/cross_db_utils/date_trunc.sql 2022-04-19 10:30:47 normalization > 10:30:39.613447 [debug] [MainThread]: Parsing macros/cross_db_utils/dateadd.sql 2022-04-19 10:30:47 normalization > 10:30:39.617310 [debug] [MainThread]: Parsing macros/cross_db_utils/datediff.sql 2022-04-19 10:30:47 normalization > 10:30:39.630203 [debug] [MainThread]: Parsing macros/cross_db_utils/escape_single_quotes.sql 2022-04-19 10:30:47 normalization > 10:30:39.632750 [debug] [MainThread]: Parsing macros/cross_db_utils/except.sql 2022-04-19 10:30:47 normalization > 10:30:39.634191 [debug] [MainThread]: Parsing macros/cross_db_utils/hash.sql 2022-04-19 10:30:47 normalization > 10:30:39.636123 [debug] [MainThread]: Parsing macros/cross_db_utils/identifier.sql 2022-04-19 10:30:47 normalization > 10:30:39.638356 [debug] [MainThread]: Parsing macros/cross_db_utils/intersect.sql 2022-04-19 10:30:47 normalization > 10:30:39.639828 [debug] [MainThread]: Parsing macros/cross_db_utils/last_day.sql 2022-04-19 10:30:47 normalization > 10:30:39.644733 [debug] [MainThread]: Parsing macros/cross_db_utils/length.sql 2022-04-19 10:30:47 normalization > 10:30:39.646483 [debug] [MainThread]: Parsing macros/cross_db_utils/literal.sql 2022-04-19 10:30:47 normalization > 10:30:39.647796 [debug] [MainThread]: Parsing macros/cross_db_utils/position.sql 2022-04-19 10:30:47 normalization > 10:30:39.649899 [debug] [MainThread]: Parsing macros/cross_db_utils/replace.sql 2022-04-19 10:30:47 normalization > 10:30:39.651618 [debug] [MainThread]: Parsing macros/cross_db_utils/right.sql 2022-04-19 10:30:47 normalization > 10:30:39.654636 [debug] [MainThread]: Parsing macros/cross_db_utils/safe_cast.sql 2022-04-19 10:30:47 normalization > 10:30:39.657367 [debug] [MainThread]: Parsing macros/cross_db_utils/split_part.sql 2022-04-19 10:30:47 normalization > 10:30:39.659835 [debug] [MainThread]: Parsing macros/cross_db_utils/width_bucket.sql 2022-04-19 10:30:47 normalization > 10:30:39.666534 [debug] [MainThread]: Parsing macros/jinja_helpers/log_info.sql 2022-04-19 10:30:47 normalization > 10:30:39.668087 [debug] [MainThread]: Parsing macros/jinja_helpers/pretty_log_format.sql 2022-04-19 10:30:47 normalization > 10:30:39.669611 [debug] [MainThread]: Parsing macros/jinja_helpers/pretty_time.sql 2022-04-19 10:30:47 normalization > 10:30:39.671291 [debug] [MainThread]: Parsing macros/jinja_helpers/slugify.sql 2022-04-19 10:30:47 normalization > 10:30:39.672866 [debug] [MainThread]: Parsing macros/materializations/insert_by_period_materialization.sql 2022-04-19 10:30:47 normalization > 10:30:39.704224 [debug] [MainThread]: Parsing macros/schema_tests/accepted_range.sql 2022-04-19 10:30:47 normalization > 10:30:39.707498 [debug] [MainThread]: Parsing macros/schema_tests/at_least_one.sql 2022-04-19 10:30:47 normalization > 10:30:39.709200 [debug] [MainThread]: Parsing macros/schema_tests/cardinality_equality.sql 2022-04-19 10:30:47 normalization > 10:30:39.711852 [debug] [MainThread]: Parsing macros/schema_tests/equal_rowcount.sql 2022-04-19 10:30:47 normalization > 10:30:39.714046 [debug] [MainThread]: Parsing macros/schema_tests/equality.sql 2022-04-19 10:30:47 normalization > 10:30:39.718849 [debug] [MainThread]: Parsing macros/schema_tests/expression_is_true.sql 2022-04-19 10:30:47 normalization > 10:30:39.721289 [debug] [MainThread]: Parsing macros/schema_tests/fewer_rows_than.sql 2022-04-19 10:30:47 normalization > 10:30:39.723492 [debug] [MainThread]: Parsing macros/schema_tests/mutually_exclusive_ranges.sql 2022-04-19 10:30:47 normalization > 10:30:39.734683 [debug] [MainThread]: Parsing macros/schema_tests/not_accepted_values.sql 2022-04-19 10:30:47 normalization > 10:30:39.737495 [debug] [MainThread]: Parsing macros/schema_tests/not_constant.sql 2022-04-19 10:30:47 normalization > 10:30:39.739200 [debug] [MainThread]: Parsing macros/schema_tests/not_null_proportion.sql 2022-04-19 10:30:47 normalization > 10:30:39.742114 [debug] [MainThread]: Parsing macros/schema_tests/recency.sql 2022-04-19 10:30:47 normalization > 10:30:39.744472 [debug] [MainThread]: Parsing macros/schema_tests/relationships_where.sql 2022-04-19 10:30:47 normalization > 10:30:39.747387 [debug] [MainThread]: Parsing macros/schema_tests/sequential_values.sql 2022-04-19 10:30:47 normalization > 10:30:39.751146 [debug] [MainThread]: Parsing macros/schema_tests/test_not_null_where.sql 2022-04-19 10:30:47 normalization > 10:30:39.753058 [debug] [MainThread]: Parsing macros/schema_tests/test_unique_where.sql 2022-04-19 10:30:47 normalization > 10:30:39.754990 [debug] [MainThread]: Parsing macros/schema_tests/unique_combination_of_columns.sql 2022-04-19 10:30:47 normalization > 10:30:39.758887 [debug] [MainThread]: Parsing macros/sql/date_spine.sql 2022-04-19 10:30:47 normalization > 10:30:39.764475 [debug] [MainThread]: Parsing macros/sql/generate_series.sql 2022-04-19 10:30:47 normalization > 10:30:39.770157 [debug] [MainThread]: Parsing macros/sql/get_column_values.sql 2022-04-19 10:30:47 normalization > 10:30:39.776961 [debug] [MainThread]: Parsing macros/sql/get_query_results_as_dict.sql 2022-04-19 10:30:47 normalization > 10:30:39.780068 [debug] [MainThread]: Parsing macros/sql/get_relations_by_pattern.sql 2022-04-19 10:30:47 normalization > 10:30:39.784529 [debug] [MainThread]: Parsing macros/sql/get_relations_by_prefix.sql 2022-04-19 10:30:47 normalization > 10:30:39.789512 [debug] [MainThread]: Parsing macros/sql/get_table_types_sql.sql 2022-04-19 10:30:47 normalization > 10:30:39.791204 [debug] [MainThread]: Parsing macros/sql/get_tables_by_pattern_sql.sql 2022-04-19 10:30:47 normalization > 10:30:39.799363 [debug] [MainThread]: Parsing macros/sql/get_tables_by_prefix_sql.sql 2022-04-19 10:30:47 normalization > 10:30:39.801597 [debug] [MainThread]: Parsing macros/sql/groupby.sql 2022-04-19 10:30:47 normalization > 10:30:39.803427 [debug] [MainThread]: Parsing macros/sql/haversine_distance.sql 2022-04-19 10:30:47 normalization > 10:30:39.811340 [debug] [MainThread]: Parsing macros/sql/nullcheck.sql 2022-04-19 10:30:47 normalization > 10:30:39.813551 [debug] [MainThread]: Parsing macros/sql/nullcheck_table.sql 2022-04-19 10:30:47 normalization > 10:30:39.815769 [debug] [MainThread]: Parsing macros/sql/pivot.sql 2022-04-19 10:30:47 normalization > 10:30:39.821502 [debug] [MainThread]: Parsing macros/sql/safe_add.sql 2022-04-19 10:30:47 normalization > 10:30:39.823883 [debug] [MainThread]: Parsing macros/sql/star.sql 2022-04-19 10:30:47 normalization > 10:30:39.830124 [debug] [MainThread]: Parsing macros/sql/surrogate_key.sql 2022-04-19 10:30:47 normalization > 10:30:39.835123 [debug] [MainThread]: Parsing macros/sql/union.sql 2022-04-19 10:30:47 normalization > 10:30:39.849329 [debug] [MainThread]: Parsing macros/sql/unpivot.sql 2022-04-19 10:30:47 normalization > 10:30:39.859630 [debug] [MainThread]: Parsing macros/web/get_url_host.sql 2022-04-19 10:30:47 normalization > 10:30:39.862221 [debug] [MainThread]: Parsing macros/web/get_url_parameter.sql 2022-04-19 10:30:47 normalization > 10:30:39.864500 [debug] [MainThread]: Parsing macros/web/get_url_path.sql 2022-04-19 10:30:47 normalization > 10:30:40.432142 [debug] [MainThread]: 1603: static parser failed on generated/airbyte_ctes/staging/company_contract_ab1.sql 2022-04-19 10:30:47 normalization > 10:30:40.495316 [debug] [MainThread]: 1602: parser fallback to jinja rendering on generated/airbyte_ctes/staging/company_contract_ab1.sql 2022-04-19 10:30:47 normalization > 10:30:40.497288 [debug] [MainThread]: 1603: static parser failed on generated/airbyte_ctes/staging/company_contract_ab2.sql 2022-04-19 10:30:47 normalization > 10:30:40.520724 [debug] [MainThread]: 1602: parser fallback to jinja rendering on generated/airbyte_ctes/staging/company_contract_ab2.sql 2022-04-19 10:30:47 normalization > 10:30:40.522485 [debug] [MainThread]: 1603: static parser failed on generated/airbyte_ctes/staging/company_contract_ab3.sql 2022-04-19 10:30:47 normalization > 10:30:40.556816 [debug] [MainThread]: 1602: parser fallback to jinja rendering on generated/airbyte_ctes/staging/company_contract_ab3.sql 2022-04-19 10:30:47 normalization > 10:30:40.558792 [debug] [MainThread]: 1603: static parser failed on generated/airbyte_ctes/staging/company_invoice_ab1.sql 2022-04-19 10:30:47 normalization > 10:30:40.580687 [debug] [MainThread]: 1602: parser fallback to jinja rendering on generated/airbyte_ctes/staging/company_invoice_ab1.sql 2022-04-19 10:30:47 normalization > 10:30:40.582379 [debug] [MainThread]: 1603: static parser failed on generated/airbyte_ctes/staging/company_invoice_ab2.sql 2022-04-19 10:30:47 normalization > 10:30:40.596716 [debug] [MainThread]: 1602: parser fallback to jinja rendering on generated/airbyte_ctes/staging/company_invoice_ab2.sql 2022-04-19 10:30:47 normalization > 10:30:40.598256 [debug] [MainThread]: 1603: static parser failed on generated/airbyte_ctes/staging/company_invoice_ab3.sql 2022-04-19 10:30:47 normalization > 10:30:40.612844 [debug] [MainThread]: 1602: parser fallback to jinja rendering on generated/airbyte_ctes/staging/company_invoice_ab3.sql 2022-04-19 10:30:47 normalization > 10:30:40.614583 [debug] [MainThread]: 1603: static parser failed on generated/airbyte_incremental/staging/company_contract.sql 2022-04-19 10:30:47 normalization > 10:30:40.666948 [debug] [MainThread]: 1602: parser fallback to jinja rendering on generated/airbyte_incremental/staging/company_contract.sql 2022-04-19 10:30:47 normalization > 10:30:40.668691 [debug] [MainThread]: 1603: static parser failed on generated/airbyte_incremental/staging/company_invoice.sql 2022-04-19 10:30:47 normalization > 10:30:40.676934 [debug] [MainThread]: 1602: parser fallback to jinja rendering on generated/airbyte_incremental/staging/company_invoice.sql 2022-04-19 10:30:47 normalization > 10:30:40.758658 [warn ] [MainThread]: [WARNING]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources. 2022-04-19 10:30:47 normalization > There are 2 unused configuration paths: 2022-04-19 10:30:47 normalization > - models.airbyte_utils.generated.airbyte_views 2022-04-19 10:30:47 normalization > - models.airbyte_utils.generated.airbyte_tables 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > 10:30:40.778582 [info ] [MainThread]: Found 8 models, 0 tests, 0 snapshots, 0 analyses, 537 macros, 0 operations, 0 seed files, 2 sources, 0 exposures, 0 metrics 2022-04-19 10:30:47 normalization > 10:30:40.780418 [info ] [MainThread]: 2022-04-19 10:30:47 normalization > 10:30:40.781034 [debug] [MainThread]: Acquiring new bigquery connection "master" 2022-04-19 10:30:47 normalization > 10:30:40.782191 [debug] [ThreadPool]: Acquiring new bigquery connection "list_recap-dev-347108" 2022-04-19 10:30:47 normalization > 10:30:40.782463 [debug] [ThreadPool]: Opening a new connection, currently in state init 2022-04-19 10:30:47 normalization > 10:30:41.074562 [debug] [ThreadPool]: Acquiring new bigquery connection "list_recap-dev-347108_staging" 2022-04-19 10:30:47 normalization > 10:30:41.074910 [debug] [ThreadPool]: Opening a new connection, currently in state closed 2022-04-19 10:30:47 normalization > 10:30:41.318952 [info ] [MainThread]: Concurrency: 8 threads (target='prod') 2022-04-19 10:30:47 normalization > 10:30:41.319398 [info ] [MainThread]: 2022-04-19 10:30:47 normalization > 10:30:41.339003 [debug] [Thread-1 ]: Began running node model.airbyte_utils.company_contract_ab1 2022-04-19 10:30:47 normalization > 10:30:41.339259 [debug] [Thread-2 ]: Began running node model.airbyte_utils.company_invoice_ab1 2022-04-19 10:30:47 normalization > 10:30:41.339730 [debug] [Thread-1 ]: Acquiring new bigquery connection "model.airbyte_utils.company_contract_ab1" 2022-04-19 10:30:47 normalization > 10:30:41.340184 [debug] [Thread-2 ]: Acquiring new bigquery connection "model.airbyte_utils.company_invoice_ab1" 2022-04-19 10:30:47 normalization > 10:30:41.340410 [debug] [Thread-1 ]: Began compiling node model.airbyte_utils.company_contract_ab1 2022-04-19 10:30:47 normalization > 10:30:41.340607 [debug] [Thread-2 ]: Began compiling node model.airbyte_utils.company_invoice_ab1 2022-04-19 10:30:47 normalization > 10:30:41.340821 [debug] [Thread-1 ]: Compiling model.airbyte_utils.company_contract_ab1 2022-04-19 10:30:47 normalization > 10:30:41.341009 [debug] [Thread-2 ]: Compiling model.airbyte_utils.company_invoice_ab1 2022-04-19 10:30:47 normalization > 10:30:41.363677 [debug] [Thread-2 ]: On "model.airbyte_utils.company_invoice_ab1": cache miss for schema "{self.database}.{self.schema}", this is inefficient 2022-04-19 10:30:47 normalization > 10:30:41.364529 [debug] [Thread-2 ]: Opening a new connection, currently in state init 2022-04-19 10:30:47 normalization > 10:30:41.397721 [debug] [Thread-1 ]: On "model.airbyte_utils.company_contract_ab1": cache miss for schema "{self.database}.{self.schema}", this is inefficient 2022-04-19 10:30:47 normalization > 10:30:41.398117 [debug] [Thread-1 ]: Opening a new connection, currently in state closed 2022-04-19 10:30:47 normalization > 10:30:41.720246 [debug] [Thread-2 ]: Writing injected SQL for node "model.airbyte_utils.company_invoice_ab1" 2022-04-19 10:30:47 normalization > 10:30:41.720842 [debug] [Thread-2 ]: finished collecting timing info 2022-04-19 10:30:47 normalization > 10:30:41.721380 [debug] [Thread-2 ]: Finished running node model.airbyte_utils.company_invoice_ab1 2022-04-19 10:30:47 normalization > 10:30:41.721905 [debug] [Thread-4 ]: Began running node model.airbyte_utils.company_invoice_ab2 2022-04-19 10:30:47 normalization > 10:30:41.722354 [debug] [Thread-4 ]: Acquiring new bigquery connection "model.airbyte_utils.company_invoice_ab2" 2022-04-19 10:30:47 normalization > 10:30:41.722547 [debug] [Thread-4 ]: Began compiling node model.airbyte_utils.company_invoice_ab2 2022-04-19 10:30:47 normalization > 10:30:41.722730 [debug] [Thread-4 ]: Compiling model.airbyte_utils.company_invoice_ab2 2022-04-19 10:30:47 normalization > 10:30:41.737486 [debug] [Thread-4 ]: On "model.airbyte_utils.company_invoice_ab2": cache miss for schema "{self.database}.{self.schema}", this is inefficient 2022-04-19 10:30:47 normalization > 10:30:41.737916 [debug] [Thread-4 ]: Opening a new connection, currently in state init 2022-04-19 10:30:47 normalization > 10:30:41.738455 [debug] [Thread-1 ]: Writing injected SQL for node "model.airbyte_utils.company_contract_ab1" 2022-04-19 10:30:47 normalization > 10:30:41.738954 [debug] [Thread-1 ]: finished collecting timing info 2022-04-19 10:30:47 normalization > 10:30:41.739442 [debug] [Thread-1 ]: Finished running node model.airbyte_utils.company_contract_ab1 2022-04-19 10:30:47 normalization > 10:30:41.739865 [debug] [Thread-1 ]: Began running node model.airbyte_utils.company_contract_ab2 2022-04-19 10:30:47 normalization > 10:30:41.740269 [debug] [Thread-1 ]: Acquiring new bigquery connection "model.airbyte_utils.company_contract_ab2" 2022-04-19 10:30:47 normalization > 10:30:41.740440 [debug] [Thread-1 ]: Began compiling node model.airbyte_utils.company_contract_ab2 2022-04-19 10:30:47 normalization > 10:30:41.740601 [debug] [Thread-1 ]: Compiling model.airbyte_utils.company_contract_ab2 2022-04-19 10:30:47 normalization > 10:30:41.757760 [debug] [Thread-1 ]: On "model.airbyte_utils.company_contract_ab2": cache miss for schema "{self.database}.{self.schema}", this is inefficient 2022-04-19 10:30:47 normalization > 10:30:41.758492 [debug] [Thread-1 ]: Opening a new connection, currently in state closed 2022-04-19 10:30:47 normalization > 10:30:42.107353 [debug] [Thread-4 ]: Writing injected SQL for node "model.airbyte_utils.company_invoice_ab2" 2022-04-19 10:30:47 normalization > 10:30:42.107753 [debug] [Thread-4 ]: finished collecting timing info 2022-04-19 10:30:47 normalization > 10:30:42.108240 [debug] [Thread-4 ]: Finished running node model.airbyte_utils.company_invoice_ab2 2022-04-19 10:30:47 normalization > 10:30:42.108740 [debug] [Thread-8 ]: Began running node model.airbyte_utils.company_invoice_ab3 2022-04-19 10:30:47 normalization > 10:30:42.109186 [debug] [Thread-8 ]: Acquiring new bigquery connection "model.airbyte_utils.company_invoice_ab3" 2022-04-19 10:30:47 normalization > 10:30:42.109404 [debug] [Thread-8 ]: Began compiling node model.airbyte_utils.company_invoice_ab3 2022-04-19 10:30:47 normalization > 10:30:42.109596 [debug] [Thread-8 ]: Compiling model.airbyte_utils.company_invoice_ab3 2022-04-19 10:30:47 normalization > 10:30:42.124094 [debug] [Thread-8 ]: On "model.airbyte_utils.company_invoice_ab3": cache miss for schema "{self.database}.{self.schema}", this is inefficient 2022-04-19 10:30:47 normalization > 10:30:42.124925 [debug] [Thread-8 ]: Opening a new connection, currently in state init 2022-04-19 10:30:47 normalization > 10:30:42.149579 [debug] [Thread-1 ]: Writing injected SQL for node "model.airbyte_utils.company_contract_ab2" 2022-04-19 10:30:47 normalization > 10:30:42.150151 [debug] [Thread-1 ]: finished collecting timing info 2022-04-19 10:30:47 normalization > 10:30:42.150654 [debug] [Thread-1 ]: Finished running node model.airbyte_utils.company_contract_ab2 2022-04-19 10:30:47 normalization > 10:30:42.152627 [debug] [Thread-2 ]: Began running node model.airbyte_utils.company_contract_ab3 2022-04-19 10:30:47 normalization > 10:30:42.153043 [debug] [Thread-2 ]: Acquiring new bigquery connection "model.airbyte_utils.company_contract_ab3" 2022-04-19 10:30:47 normalization > 10:30:42.153277 [debug] [Thread-2 ]: Began compiling node model.airbyte_utils.company_contract_ab3 2022-04-19 10:30:47 normalization > 10:30:42.153468 [debug] [Thread-2 ]: Compiling model.airbyte_utils.company_contract_ab3 2022-04-19 10:30:47 normalization > 10:30:42.168935 [debug] [Thread-2 ]: On "model.airbyte_utils.company_contract_ab3": cache miss for schema "{self.database}.{self.schema}", this is inefficient 2022-04-19 10:30:47 normalization > 10:30:42.169385 [debug] [Thread-2 ]: Opening a new connection, currently in state closed 2022-04-19 10:30:47 normalization > 10:30:42.488925 [debug] [Thread-8 ]: Writing injected SQL for node "model.airbyte_utils.company_invoice_ab3" 2022-04-19 10:30:47 normalization > 10:30:42.489357 [debug] [Thread-8 ]: finished collecting timing info 2022-04-19 10:30:47 normalization > 10:30:42.489873 [debug] [Thread-8 ]: Finished running node model.airbyte_utils.company_invoice_ab3 2022-04-19 10:30:47 normalization > 10:30:42.491031 [debug] [Thread-7 ]: Began running node model.airbyte_utils.company_invoice 2022-04-19 10:30:47 normalization > 10:30:42.491554 [info ] [Thread-7 ]: 1 of 2 START incremental model staging.company_invoice.................................................................. [RUN] 2022-04-19 10:30:47 normalization > 10:30:42.492416 [debug] [Thread-7 ]: Acquiring new bigquery connection "model.airbyte_utils.company_invoice" 2022-04-19 10:30:47 normalization > 10:30:42.492600 [debug] [Thread-7 ]: Began compiling node model.airbyte_utils.company_invoice 2022-04-19 10:30:47 normalization > 10:30:42.492760 [debug] [Thread-7 ]: Compiling model.airbyte_utils.company_invoice 2022-04-19 10:30:47 normalization > 10:30:42.506795 [debug] [Thread-7 ]: Writing injected SQL for node "model.airbyte_utils.company_invoice" 2022-04-19 10:30:47 normalization > 10:30:42.543037 [debug] [Thread-2 ]: Writing injected SQL for node "model.airbyte_utils.company_contract_ab3" 2022-04-19 10:30:47 normalization > 10:30:42.543366 [debug] [Thread-7 ]: finished collecting timing info 2022-04-19 10:30:47 normalization > 10:30:42.543603 [debug] [Thread-7 ]: Began executing node model.airbyte_utils.company_invoice 2022-04-19 10:30:47 normalization > 10:30:42.565440 [debug] [Thread-2 ]: finished collecting timing info 2022-04-19 10:30:47 normalization > 10:30:42.576410 [debug] [Thread-2 ]: Finished running node model.airbyte_utils.company_contract_ab3 2022-04-19 10:30:47 normalization > 10:30:42.576784 [debug] [Thread-7 ]: Opening a new connection, currently in state init 2022-04-19 10:30:47 normalization > 10:30:42.577450 [debug] [Thread-4 ]: Began running node model.airbyte_utils.company_contract 2022-04-19 10:30:47 normalization > 10:30:42.577829 [info ] [Thread-4 ]: 2 of 2 START incremental model staging.company_contract................................................................. [RUN] 2022-04-19 10:30:47 normalization > 10:30:42.579005 [debug] [Thread-4 ]: Acquiring new bigquery connection "model.airbyte_utils.company_contract" 2022-04-19 10:30:47 normalization > 10:30:42.579187 [debug] [Thread-4 ]: Began compiling node model.airbyte_utils.company_contract 2022-04-19 10:30:47 normalization > 10:30:42.579352 [debug] [Thread-4 ]: Compiling model.airbyte_utils.company_contract 2022-04-19 10:30:47 normalization > 10:30:42.595164 [debug] [Thread-4 ]: Writing injected SQL for node "model.airbyte_utils.company_contract" 2022-04-19 10:30:47 normalization > 10:30:42.596405 [debug] [Thread-4 ]: finished collecting timing info 2022-04-19 10:30:47 normalization > 10:30:42.596609 [debug] [Thread-4 ]: Began executing node model.airbyte_utils.company_contract 2022-04-19 10:30:47 normalization > 10:30:42.599597 [debug] [Thread-4 ]: Opening a new connection, currently in state closed 2022-04-19 10:30:47 normalization > 10:30:42.847474 [debug] [Thread-4 ]: BigQuery adapter: get_columns_in_relation error: 404 GET https://bigquery.googleapis.com/bigquery/v2/projects/recap-dev-347108/datasets/staging/tables/company_contract?prettyPrint=false: Not found: Table recap-dev-347108:staging.company_contract 2022-04-19 10:30:47 normalization > 10:30:42.847818 [debug] [Thread-7 ]: BigQuery adapter: get_columns_in_relation error: 404 GET https://bigquery.googleapis.com/bigquery/v2/projects/recap-dev-347108/datasets/staging/tables/company_invoice?prettyPrint=false: Not found: Table recap-dev-347108:staging.company_invoice 2022-04-19 10:30:47 normalization > 10:30:42.860451 [info ] [Thread-4 ]: 10:30:42 + `recap-dev-347108`.staging.`company_contract`._airbyte_ab_id does not exist yet. The table will be created or rebuilt with dbt.full_refresh 2022-04-19 10:30:47 normalization > 10:30:42.861663 [info ] [Thread-7 ]: 10:30:42 + `recap-dev-347108`.staging.`company_invoice`._airbyte_ab_id does not exist yet. The table will be created or rebuilt with dbt.full_refresh 2022-04-19 10:30:47 normalization > 10:30:42.938990 [debug] [Thread-7 ]: Writing runtime SQL for node "model.airbyte_utils.company_invoice" 2022-04-19 10:30:47 normalization > 10:30:42.939817 [debug] [Thread-4 ]: Writing runtime SQL for node "model.airbyte_utils.company_contract" 2022-04-19 10:30:47 normalization > 10:30:42.940832 [debug] [Thread-4 ]: On model.airbyte_utils.company_contract: /* {"app": "dbt", "dbt_version": "1.0.0", "profile_name": "normalize", "target_name": "prod", "node_id": "model.airbyte_utils.company_contract"} */ 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > create or replace table `recap-dev-347108`.staging.`company_contract` 2022-04-19 10:30:47 normalization > partition by timestamp_trunc(_airbyte_emitted_at, day) 2022-04-19 10:30:47 normalization > cluster by _airbyte_emitted_at 2022-04-19 10:30:47 normalization > OPTIONS() 2022-04-19 10:30:47 normalization > as ( 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > with __dbt__cte__company_contract_ab1 as ( 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > -- SQL model to parse JSON blob stored in a single column and extract into separated field columns as described by the JSON Schema 2022-04-19 10:30:47 normalization > -- depends_on: `recap-dev-347108`.staging._airbyte_raw_company_contract 2022-04-19 10:30:47 normalization > select 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['currency']") as currency, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['company_id']") as company_id, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['created_at']") as created_at, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['deleted_at']") as deleted_at, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['updated_at']") as updated_at, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['customer_id']") as customer_id, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['billing_cycle']") as billing_cycle, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['customer_name']") as customer_name, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['financeability']") as financeability, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['source_file_id']") as source_file_id, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['contract_end_date']") as contract_end_date, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['original_currency']") as original_currency, 2022-04-19 10:30:47 normalization > json_extract_array(_airbyte_data, "$['financing_problems']") as financing_problems, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['company_contract_id']") as company_contract_id, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['contract_start_date']") as contract_start_date, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['current_gross_value']") as current_gross_value, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['latest_billing_date']") as latest_billing_date, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['recap_contract_status']") as recap_contract_status, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['company_contract_status']") as company_contract_status, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['company_contract_provided_id']") as company_contract_provided_id, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['original_current_gross_value']") as original_current_gross_value, 2022-04-19 10:30:47 normalization > _airbyte_ab_id, 2022-04-19 10:30:47 normalization > _airbyte_emitted_at, 2022-04-19 10:30:47 normalization > CURRENT_TIMESTAMP() as _airbyte_normalized_at 2022-04-19 10:30:47 normalization > from `recap-dev-347108`.staging._airbyte_raw_company_contract as table_alias 2022-04-19 10:30:47 normalization > -- company_contract 2022-04-19 10:30:47 normalization > where 1 = 1 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > ), __dbt__cte__company_contract_ab2 as ( 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > -- SQL model to cast each column to its adequate SQL type converted from the JSON schema type 2022-04-19 10:30:47 normalization > -- depends_on: __dbt__cte__company_contract_ab1 2022-04-19 10:30:47 normalization > select 2022-04-19 10:30:47 normalization > cast(currency as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as currency, 2022-04-19 10:30:47 normalization > cast(company_id as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as company_id, 2022-04-19 10:30:47 normalization > cast(created_at as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as created_at, 2022-04-19 10:30:47 normalization > cast(deleted_at as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as deleted_at, 2022-04-19 10:30:47 normalization > cast(updated_at as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as updated_at, 2022-04-19 10:30:47 normalization > cast(customer_id as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as customer_id, 2022-04-19 10:30:47 normalization > cast(billing_cycle as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as billing_cycle, 2022-04-19 10:30:47 normalization > cast(customer_name as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as customer_name, 2022-04-19 10:30:47 normalization > cast(financeability as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as financeability, 2022-04-19 10:30:47 normalization > cast(source_file_id as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as source_file_id, 2022-04-19 10:30:47 normalization > cast(contract_end_date as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as contract_end_date, 2022-04-19 10:30:47 normalization > cast(original_currency as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as original_currency, 2022-04-19 10:30:47 normalization > financing_problems, 2022-04-19 10:30:47 normalization > cast(company_contract_id as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as company_contract_id, 2022-04-19 10:30:47 normalization > cast(contract_start_date as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as contract_start_date, 2022-04-19 10:30:47 normalization > cast(current_gross_value as 2022-04-19 10:30:47 normalization > float64 2022-04-19 10:30:47 normalization > ) as current_gross_value, 2022-04-19 10:30:47 normalization > cast(latest_billing_date as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as latest_billing_date, 2022-04-19 10:30:47 normalization > cast(recap_contract_status as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as recap_contract_status, 2022-04-19 10:30:47 normalization > cast(company_contract_status as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as company_contract_status, 2022-04-19 10:30:47 normalization > cast(company_contract_provided_id as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as company_contract_provided_id, 2022-04-19 10:30:47 normalization > cast(original_current_gross_value as 2022-04-19 10:30:47 normalization > float64 2022-04-19 10:30:47 normalization > ) as original_current_gross_value, 2022-04-19 10:30:47 normalization > _airbyte_ab_id, 2022-04-19 10:30:47 normalization > _airbyte_emitted_at, 2022-04-19 10:30:47 normalization > CURRENT_TIMESTAMP() as _airbyte_normalized_at 2022-04-19 10:30:47 normalization > from __dbt__cte__company_contract_ab1 2022-04-19 10:30:47 normalization > -- company_contract 2022-04-19 10:30:47 normalization > where 1 = 1 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > ), __dbt__cte__company_contract_ab3 as ( 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > -- SQL model to build a hash column based on the values of this record 2022-04-19 10:30:47 normalization > -- depends_on: __dbt__cte__company_contract_ab2 2022-04-19 10:30:47 normalization > select 2022-04-19 10:30:47 normalization > to_hex(md5(cast(concat(coalesce(cast(currency as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(company_id as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(created_at as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(deleted_at as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(updated_at as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(customer_id as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(billing_cycle as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(customer_name as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(financeability as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(source_file_id as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(contract_end_date as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(original_currency as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(array_to_string(financing_problems, "|", "") as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(company_contract_id as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(contract_start_date as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(current_gross_value as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(latest_billing_date as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(recap_contract_status as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(company_contract_status as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(company_contract_provided_id as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(original_current_gross_value as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), '')) as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ))) as _airbyte_company_contract_hashid, 2022-04-19 10:30:47 normalization > tmp.* 2022-04-19 10:30:47 normalization > from __dbt__cte__company_contract_ab2 tmp 2022-04-19 10:30:47 normalization > -- company_contract 2022-04-19 10:30:47 normalization > where 1 = 1 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > )-- Final base SQL model 2022-04-19 10:30:47 normalization > -- depends_on: __dbt__cte__company_contract_ab3 2022-04-19 10:30:47 normalization > select 2022-04-19 10:30:47 normalization > currency, 2022-04-19 10:30:47 normalization > company_id, 2022-04-19 10:30:47 normalization > created_at, 2022-04-19 10:30:47 normalization > deleted_at, 2022-04-19 10:30:47 normalization > updated_at, 2022-04-19 10:30:47 normalization > customer_id, 2022-04-19 10:30:47 normalization > billing_cycle, 2022-04-19 10:30:47 normalization > customer_name, 2022-04-19 10:30:47 normalization > financeability, 2022-04-19 10:30:47 normalization > source_file_id, 2022-04-19 10:30:47 normalization > contract_end_date, 2022-04-19 10:30:47 normalization > original_currency, 2022-04-19 10:30:47 normalization > financing_problems, 2022-04-19 10:30:47 normalization > company_contract_id, 2022-04-19 10:30:47 normalization > contract_start_date, 2022-04-19 10:30:47 normalization > current_gross_value, 2022-04-19 10:30:47 normalization > latest_billing_date, 2022-04-19 10:30:47 normalization > recap_contract_status, 2022-04-19 10:30:47 normalization > company_contract_status, 2022-04-19 10:30:47 normalization > company_contract_provided_id, 2022-04-19 10:30:47 normalization > original_current_gross_value, 2022-04-19 10:30:47 normalization > _airbyte_ab_id, 2022-04-19 10:30:47 normalization > _airbyte_emitted_at, 2022-04-19 10:30:47 normalization > CURRENT_TIMESTAMP() as _airbyte_normalized_at, 2022-04-19 10:30:47 normalization > _airbyte_company_contract_hashid 2022-04-19 10:30:47 normalization > from __dbt__cte__company_contract_ab3 2022-04-19 10:30:47 normalization > -- company_contract from `recap-dev-347108`.staging._airbyte_raw_company_contract 2022-04-19 10:30:47 normalization > where 1 = 1 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > ); 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > 10:30:42.941082 [debug] [Thread-7 ]: On model.airbyte_utils.company_invoice: /* {"app": "dbt", "dbt_version": "1.0.0", "profile_name": "normalize", "target_name": "prod", "node_id": "model.airbyte_utils.company_invoice"} */ 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > create or replace table `recap-dev-347108`.staging.`company_invoice` 2022-04-19 10:30:47 normalization > partition by timestamp_trunc(_airbyte_emitted_at, day) 2022-04-19 10:30:47 normalization > cluster by _airbyte_emitted_at 2022-04-19 10:30:47 normalization > OPTIONS() 2022-04-19 10:30:47 normalization > as ( 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > with __dbt__cte__company_invoice_ab1 as ( 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > -- SQL model to parse JSON blob stored in a single column and extract into separated field columns as described by the JSON Schema 2022-04-19 10:30:47 normalization > -- depends_on: `recap-dev-347108`.staging._airbyte_raw_company_invoice 2022-04-19 10:30:47 normalization > select 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['currency']") as currency, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['created_at']") as created_at, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['deleted_at']") as deleted_at, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['updated_at']") as updated_at, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['invoice_date']") as invoice_date, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['invoice_status']") as invoice_status, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['source_file_id']") as source_file_id, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['original_currency']") as original_currency, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['company_invoice_id']") as company_invoice_id, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['company_contract_id']") as company_contract_id, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['invoice_gross_amount']") as invoice_gross_amount, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['invoice_payment_date']") as invoice_payment_date, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['company_invoice_provided_id']") as company_invoice_provided_id, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['original_invoice_gross_amount']") as original_invoice_gross_amount, 2022-04-19 10:30:47 normalization > _airbyte_ab_id, 2022-04-19 10:30:47 normalization > _airbyte_emitted_at, 2022-04-19 10:30:47 normalization > CURRENT_TIMESTAMP() as _airbyte_normalized_at 2022-04-19 10:30:47 normalization > from `recap-dev-347108`.staging._airbyte_raw_company_invoice as table_alias 2022-04-19 10:30:47 normalization > -- company_invoice 2022-04-19 10:30:47 normalization > where 1 = 1 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > ), __dbt__cte__company_invoice_ab2 as ( 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > -- SQL model to cast each column to its adequate SQL type converted from the JSON schema type 2022-04-19 10:30:47 normalization > -- depends_on: __dbt__cte__company_invoice_ab1 2022-04-19 10:30:47 normalization > select 2022-04-19 10:30:47 normalization > cast(currency as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as currency, 2022-04-19 10:30:47 normalization > cast(created_at as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as created_at, 2022-04-19 10:30:47 normalization > cast(deleted_at as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as deleted_at, 2022-04-19 10:30:47 normalization > cast(updated_at as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as updated_at, 2022-04-19 10:30:47 normalization > cast(invoice_date as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as invoice_date, 2022-04-19 10:30:47 normalization > cast(invoice_status as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as invoice_status, 2022-04-19 10:30:47 normalization > cast(source_file_id as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as source_file_id, 2022-04-19 10:30:47 normalization > cast(original_currency as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as original_currency, 2022-04-19 10:30:47 normalization > cast(company_invoice_id as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as company_invoice_id, 2022-04-19 10:30:47 normalization > cast(company_contract_id as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as company_contract_id, 2022-04-19 10:30:47 normalization > cast(invoice_gross_amount as 2022-04-19 10:30:47 normalization > float64 2022-04-19 10:30:47 normalization > ) as invoice_gross_amount, 2022-04-19 10:30:47 normalization > cast(invoice_payment_date as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as invoice_payment_date, 2022-04-19 10:30:47 normalization > cast(company_invoice_provided_id as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as company_invoice_provided_id, 2022-04-19 10:30:47 normalization > cast(original_invoice_gross_amount as 2022-04-19 10:30:47 normalization > float64 2022-04-19 10:30:47 normalization > ) as original_invoice_gross_amount, 2022-04-19 10:30:47 normalization > _airbyte_ab_id, 2022-04-19 10:30:47 normalization > _airbyte_emitted_at, 2022-04-19 10:30:47 normalization > CURRENT_TIMESTAMP() as _airbyte_normalized_at 2022-04-19 10:30:47 normalization > from __dbt__cte__company_invoice_ab1 2022-04-19 10:30:47 normalization > -- company_invoice 2022-04-19 10:30:47 normalization > where 1 = 1 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > ), __dbt__cte__company_invoice_ab3 as ( 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > -- SQL model to build a hash column based on the values of this record 2022-04-19 10:30:47 normalization > -- depends_on: __dbt__cte__company_invoice_ab2 2022-04-19 10:30:47 normalization > select 2022-04-19 10:30:47 normalization > to_hex(md5(cast(concat(coalesce(cast(currency as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(created_at as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(deleted_at as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(updated_at as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(invoice_date as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(invoice_status as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(source_file_id as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(original_currency as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(company_invoice_id as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(company_contract_id as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(invoice_gross_amount as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(invoice_payment_date as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(company_invoice_provided_id as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(original_invoice_gross_amount as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), '')) as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ))) as _airbyte_company_invoice_hashid, 2022-04-19 10:30:47 normalization > tmp.* 2022-04-19 10:30:47 normalization > from __dbt__cte__company_invoice_ab2 tmp 2022-04-19 10:30:47 normalization > -- company_invoice 2022-04-19 10:30:47 normalization > where 1 = 1 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > )-- Final base SQL model 2022-04-19 10:30:47 normalization > -- depends_on: __dbt__cte__company_invoice_ab3 2022-04-19 10:30:47 normalization > select 2022-04-19 10:30:47 normalization > currency, 2022-04-19 10:30:47 normalization > created_at, 2022-04-19 10:30:47 normalization > deleted_at, 2022-04-19 10:30:47 normalization > updated_at, 2022-04-19 10:30:47 normalization > invoice_date, 2022-04-19 10:30:47 normalization > invoice_status, 2022-04-19 10:30:47 normalization > source_file_id, 2022-04-19 10:30:47 normalization > original_currency, 2022-04-19 10:30:47 normalization > company_invoice_id, 2022-04-19 10:30:47 normalization > company_contract_id, 2022-04-19 10:30:47 normalization > invoice_gross_amount, 2022-04-19 10:30:47 normalization > invoice_payment_date, 2022-04-19 10:30:47 normalization > company_invoice_provided_id, 2022-04-19 10:30:47 normalization > original_invoice_gross_amount, 2022-04-19 10:30:47 normalization > _airbyte_ab_id, 2022-04-19 10:30:47 normalization > _airbyte_emitted_at, 2022-04-19 10:30:47 normalization > CURRENT_TIMESTAMP() as _airbyte_normalized_at, 2022-04-19 10:30:47 normalization > _airbyte_company_invoice_hashid 2022-04-19 10:30:47 normalization > from __dbt__cte__company_invoice_ab3 2022-04-19 10:30:47 normalization > -- company_invoice from `recap-dev-347108`.staging._airbyte_raw_company_invoice 2022-04-19 10:30:47 normalization > where 1 = 1 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > ); 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > 10:30:43.240097 [debug] [Thread-4 ]: BigQuery adapter: Unhandled error while running: 2022-04-19 10:30:47 normalization > /* {"app": "dbt", "dbt_version": "1.0.0", "profile_name": "normalize", "target_name": "prod", "node_id": "model.airbyte_utils.company_contract"} */ 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > create or replace table `recap-dev-347108`.staging.`company_contract` 2022-04-19 10:30:47 normalization > partition by timestamp_trunc(_airbyte_emitted_at, day) 2022-04-19 10:30:47 normalization > cluster by _airbyte_emitted_at 2022-04-19 10:30:47 normalization > OPTIONS() 2022-04-19 10:30:47 normalization > as ( 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > with __dbt__cte__company_contract_ab1 as ( 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > -- SQL model to parse JSON blob stored in a single column and extract into separated field columns as described by the JSON Schema 2022-04-19 10:30:47 normalization > -- depends_on: `recap-dev-347108`.staging._airbyte_raw_company_contract 2022-04-19 10:30:47 normalization > select 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['currency']") as currency, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['company_id']") as company_id, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['created_at']") as created_at, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['deleted_at']") as deleted_at, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['updated_at']") as updated_at, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['customer_id']") as customer_id, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['billing_cycle']") as billing_cycle, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['customer_name']") as customer_name, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['financeability']") as financeability, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['source_file_id']") as source_file_id, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['contract_end_date']") as contract_end_date, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['original_currency']") as original_currency, 2022-04-19 10:30:47 normalization > json_extract_array(_airbyte_data, "$['financing_problems']") as financing_problems, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['company_contract_id']") as company_contract_id, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['contract_start_date']") as contract_start_date, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['current_gross_value']") as current_gross_value, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['latest_billing_date']") as latest_billing_date, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['recap_contract_status']") as recap_contract_status, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['company_contract_status']") as company_contract_status, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['company_contract_provided_id']") as company_contract_provided_id, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['original_current_gross_value']") as original_current_gross_value, 2022-04-19 10:30:47 normalization > _airbyte_ab_id, 2022-04-19 10:30:47 normalization > _airbyte_emitted_at, 2022-04-19 10:30:47 normalization > CURRENT_TIMESTAMP() as _airbyte_normalized_at 2022-04-19 10:30:47 normalization > from `recap-dev-347108`.staging._airbyte_raw_company_contract as table_alias 2022-04-19 10:30:47 normalization > -- company_contract 2022-04-19 10:30:47 normalization > where 1 = 1 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > ), __dbt__cte__company_contract_ab2 as ( 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > -- SQL model to cast each column to its adequate SQL type converted from the JSON schema type 2022-04-19 10:30:47 normalization > -- depends_on: __dbt__cte__company_contract_ab1 2022-04-19 10:30:47 normalization > select 2022-04-19 10:30:47 normalization > cast(currency as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as currency, 2022-04-19 10:30:47 normalization > cast(company_id as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as company_id, 2022-04-19 10:30:47 normalization > cast(created_at as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as created_at, 2022-04-19 10:30:47 normalization > cast(deleted_at as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as deleted_at, 2022-04-19 10:30:47 normalization > cast(updated_at as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as updated_at, 2022-04-19 10:30:47 normalization > cast(customer_id as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as customer_id, 2022-04-19 10:30:47 normalization > cast(billing_cycle as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as billing_cycle, 2022-04-19 10:30:47 normalization > cast(customer_name as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as customer_name, 2022-04-19 10:30:47 normalization > cast(financeability as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as financeability, 2022-04-19 10:30:47 normalization > cast(source_file_id as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as source_file_id, 2022-04-19 10:30:47 normalization > cast(contract_end_date as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as contract_end_date, 2022-04-19 10:30:47 normalization > cast(original_currency as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as original_currency, 2022-04-19 10:30:47 normalization > financing_problems, 2022-04-19 10:30:47 normalization > cast(company_contract_id as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as company_contract_id, 2022-04-19 10:30:47 normalization > cast(contract_start_date as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as contract_start_date, 2022-04-19 10:30:47 normalization > cast(current_gross_value as 2022-04-19 10:30:47 normalization > float64 2022-04-19 10:30:47 normalization > ) as current_gross_value, 2022-04-19 10:30:47 normalization > cast(latest_billing_date as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as latest_billing_date, 2022-04-19 10:30:47 normalization > cast(recap_contract_status as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as recap_contract_status, 2022-04-19 10:30:47 normalization > cast(company_contract_status as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as company_contract_status, 2022-04-19 10:30:47 normalization > cast(company_contract_provided_id as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as company_contract_provided_id, 2022-04-19 10:30:47 normalization > cast(original_current_gross_value as 2022-04-19 10:30:47 normalization > float64 2022-04-19 10:30:47 normalization > ) as original_current_gross_value, 2022-04-19 10:30:47 normalization > _airbyte_ab_id, 2022-04-19 10:30:47 normalization > _airbyte_emitted_at, 2022-04-19 10:30:47 normalization > CURRENT_TIMESTAMP() as _airbyte_normalized_at 2022-04-19 10:30:47 normalization > from __dbt__cte__company_contract_ab1 2022-04-19 10:30:47 normalization > -- company_contract 2022-04-19 10:30:47 normalization > where 1 = 1 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > ), __dbt__cte__company_contract_ab3 as ( 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > -- SQL model to build a hash column based on the values of this record 2022-04-19 10:30:47 normalization > -- depends_on: __dbt__cte__company_contract_ab2 2022-04-19 10:30:47 normalization > select 2022-04-19 10:30:47 normalization > to_hex(md5(cast(concat(coalesce(cast(currency as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(company_id as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(created_at as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(deleted_at as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(updated_at as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(customer_id as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(billing_cycle as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(customer_name as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(financeability as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(source_file_id as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(contract_end_date as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(original_currency as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(array_to_string(financing_problems, "|", "") as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(company_contract_id as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(contract_start_date as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(current_gross_value as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(latest_billing_date as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(recap_contract_status as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(company_contract_status as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(company_contract_provided_id as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(original_current_gross_value as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), '')) as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ))) as _airbyte_company_contract_hashid, 2022-04-19 10:30:47 normalization > tmp.* 2022-04-19 10:30:47 normalization > from __dbt__cte__company_contract_ab2 tmp 2022-04-19 10:30:47 normalization > -- company_contract 2022-04-19 10:30:47 normalization > where 1 = 1 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > )-- Final base SQL model 2022-04-19 10:30:47 normalization > -- depends_on: __dbt__cte__company_contract_ab3 2022-04-19 10:30:47 normalization > select 2022-04-19 10:30:47 normalization > currency, 2022-04-19 10:30:47 normalization > company_id, 2022-04-19 10:30:47 normalization > created_at, 2022-04-19 10:30:47 normalization > deleted_at, 2022-04-19 10:30:47 normalization > updated_at, 2022-04-19 10:30:47 normalization > customer_id, 2022-04-19 10:30:47 normalization > billing_cycle, 2022-04-19 10:30:47 normalization > customer_name, 2022-04-19 10:30:47 normalization > financeability, 2022-04-19 10:30:47 normalization > source_file_id, 2022-04-19 10:30:47 normalization > contract_end_date, 2022-04-19 10:30:47 normalization > original_currency, 2022-04-19 10:30:47 normalization > financing_problems, 2022-04-19 10:30:47 normalization > company_contract_id, 2022-04-19 10:30:47 normalization > contract_start_date, 2022-04-19 10:30:47 normalization > current_gross_value, 2022-04-19 10:30:47 normalization > latest_billing_date, 2022-04-19 10:30:47 normalization > recap_contract_status, 2022-04-19 10:30:47 normalization > company_contract_status, 2022-04-19 10:30:47 normalization > company_contract_provided_id, 2022-04-19 10:30:47 normalization > original_current_gross_value, 2022-04-19 10:30:47 normalization > _airbyte_ab_id, 2022-04-19 10:30:47 normalization > _airbyte_emitted_at, 2022-04-19 10:30:47 normalization > CURRENT_TIMESTAMP() as _airbyte_normalized_at, 2022-04-19 10:30:47 normalization > _airbyte_company_contract_hashid 2022-04-19 10:30:47 normalization > from __dbt__cte__company_contract_ab3 2022-04-19 10:30:47 normalization > -- company_contract from `recap-dev-347108`.staging._airbyte_raw_company_contract 2022-04-19 10:30:47 normalization > where 1 = 1 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > ); 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > 10:30:43.240372 [debug] [Thread-4 ]: BigQuery adapter: 404 Not found: Table recap-dev-347108:staging._airbyte_raw_company_contract was not found in location US 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > (job ID: 5dc9d01e-d810-41b3-b947-826127408bac) 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > -----Query Job SQL Follows----- 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > | . | . | . | . | . | . | . | . | . | . | . | . | . | . | 2022-04-19 10:30:47 normalization > 1:/* {"app": "dbt", "dbt_version": "1.0.0", "profile_name": "normalize", "target_name": "prod", "node_id": "model.airbyte_utils.company_contract"} */ 2022-04-19 10:30:47 normalization > 2: 2022-04-19 10:30:47 normalization > 3: 2022-04-19 10:30:47 normalization > 4: create or replace table `recap-dev-347108`.staging.`company_contract` 2022-04-19 10:30:47 normalization > 5: partition by timestamp_trunc(_airbyte_emitted_at, day) 2022-04-19 10:30:47 normalization > 6: cluster by _airbyte_emitted_at 2022-04-19 10:30:47 normalization > 7: OPTIONS() 2022-04-19 10:30:47 normalization > 8: as ( 2022-04-19 10:30:47 normalization > 9: 2022-04-19 10:30:47 normalization > 10:with __dbt__cte__company_contract_ab1 as ( 2022-04-19 10:30:47 normalization > 11: 2022-04-19 10:30:47 normalization > 12:-- SQL model to parse JSON blob stored in a single column and extract into separated field columns as described by the JSON Schema 2022-04-19 10:30:47 normalization > 13:-- depends_on: `recap-dev-347108`.staging._airbyte_raw_company_contract 2022-04-19 10:30:47 normalization > 14:select 2022-04-19 10:30:47 normalization > 15: json_extract_scalar(_airbyte_data, "$['currency']") as currency, 2022-04-19 10:30:47 normalization > 16: json_extract_scalar(_airbyte_data, "$['company_id']") as company_id, 2022-04-19 10:30:47 normalization > 17: json_extract_scalar(_airbyte_data, "$['created_at']") as created_at, 2022-04-19 10:30:47 normalization > 18: json_extract_scalar(_airbyte_data, "$['deleted_at']") as deleted_at, 2022-04-19 10:30:47 normalization > 19: json_extract_scalar(_airbyte_data, "$['updated_at']") as updated_at, 2022-04-19 10:30:47 normalization > 20: json_extract_scalar(_airbyte_data, "$['customer_id']") as customer_id, 2022-04-19 10:30:47 normalization > 21: json_extract_scalar(_airbyte_data, "$['billing_cycle']") as billing_cycle, 2022-04-19 10:30:47 normalization > 22: json_extract_scalar(_airbyte_data, "$['customer_name']") as customer_name, 2022-04-19 10:30:47 normalization > 23: json_extract_scalar(_airbyte_data, "$['financeability']") as financeability, 2022-04-19 10:30:47 normalization > 24: json_extract_scalar(_airbyte_data, "$['source_file_id']") as source_file_id, 2022-04-19 10:30:47 normalization > 25: json_extract_scalar(_airbyte_data, "$['contract_end_date']") as contract_end_date, 2022-04-19 10:30:47 normalization > 26: json_extract_scalar(_airbyte_data, "$['original_currency']") as original_currency, 2022-04-19 10:30:47 normalization > 27: json_extract_array(_airbyte_data, "$['financing_problems']") as financing_problems, 2022-04-19 10:30:47 normalization > 28: json_extract_scalar(_airbyte_data, "$['company_contract_id']") as company_contract_id, 2022-04-19 10:30:47 normalization > 29: json_extract_scalar(_airbyte_data, "$['contract_start_date']") as contract_start_date, 2022-04-19 10:30:47 normalization > 30: json_extract_scalar(_airbyte_data, "$['current_gross_value']") as current_gross_value, 2022-04-19 10:30:47 normalization > 31: json_extract_scalar(_airbyte_data, "$['latest_billing_date']") as latest_billing_date, 2022-04-19 10:30:47 normalization > 32: json_extract_scalar(_airbyte_data, "$['recap_contract_status']") as recap_contract_status, 2022-04-19 10:30:47 normalization > 33: json_extract_scalar(_airbyte_data, "$['company_contract_status']") as company_contract_status, 2022-04-19 10:30:47 normalization > 34: json_extract_scalar(_airbyte_data, "$['company_contract_provided_id']") as company_contract_provided_id, 2022-04-19 10:30:47 normalization > 35: json_extract_scalar(_airbyte_data, "$['original_current_gross_value']") as original_current_gross_value, 2022-04-19 10:30:47 normalization > 36: _airbyte_ab_id, 2022-04-19 10:30:47 normalization > 37: _airbyte_emitted_at, 2022-04-19 10:30:47 normalization > 38: CURRENT_TIMESTAMP() as _airbyte_normalized_at 2022-04-19 10:30:47 normalization > 39:from `recap-dev-347108`.staging._airbyte_raw_company_contract as table_alias 2022-04-19 10:30:47 normalization > 40:-- company_contract 2022-04-19 10:30:47 normalization > 41:where 1 = 1 2022-04-19 10:30:47 normalization > 42: 2022-04-19 10:30:47 normalization > 43:), __dbt__cte__company_contract_ab2 as ( 2022-04-19 10:30:47 normalization > 44: 2022-04-19 10:30:47 normalization > 45:-- SQL model to cast each column to its adequate SQL type converted from the JSON schema type 2022-04-19 10:30:47 normalization > 46:-- depends_on: __dbt__cte__company_contract_ab1 2022-04-19 10:30:47 normalization > 47:select 2022-04-19 10:30:47 normalization > 48: cast(currency as 2022-04-19 10:30:47 normalization > 49: string 2022-04-19 10:30:47 normalization > 50:) as currency, 2022-04-19 10:30:47 normalization > 51: cast(company_id as 2022-04-19 10:30:47 normalization > 52: string 2022-04-19 10:30:47 normalization > 53:) as company_id, 2022-04-19 10:30:47 normalization > 54: cast(created_at as 2022-04-19 10:30:47 normalization > 55: string 2022-04-19 10:30:47 normalization > 56:) as created_at, 2022-04-19 10:30:47 normalization > 57: cast(deleted_at as 2022-04-19 10:30:47 normalization > 58: string 2022-04-19 10:30:47 normalization > 59:) as deleted_at, 2022-04-19 10:30:47 normalization > 60: cast(updated_at as 2022-04-19 10:30:47 normalization > 61: string 2022-04-19 10:30:47 normalization > 62:) as updated_at, 2022-04-19 10:30:47 normalization > 63: cast(customer_id as 2022-04-19 10:30:47 normalization > 64: string 2022-04-19 10:30:47 normalization > 65:) as customer_id, 2022-04-19 10:30:47 normalization > 66: cast(billing_cycle as 2022-04-19 10:30:47 normalization > 67: string 2022-04-19 10:30:47 normalization > 68:) as billing_cycle, 2022-04-19 10:30:47 normalization > 69: cast(customer_name as 2022-04-19 10:30:47 normalization > 70: string 2022-04-19 10:30:47 normalization > 71:) as customer_name, 2022-04-19 10:30:47 normalization > 72: cast(financeability as 2022-04-19 10:30:47 normalization > 73: string 2022-04-19 10:30:47 normalization > 74:) as financeability, 2022-04-19 10:30:47 normalization > 75: cast(source_file_id as 2022-04-19 10:30:47 normalization > 76: string 2022-04-19 10:30:47 normalization > 77:) as source_file_id, 2022-04-19 10:30:47 normalization > 78: cast(contract_end_date as 2022-04-19 10:30:47 normalization > 79: string 2022-04-19 10:30:47 normalization > 80:) as contract_end_date, 2022-04-19 10:30:47 normalization > 81: cast(original_currency as 2022-04-19 10:30:47 normalization > 82: string 2022-04-19 10:30:47 normalization > 83:) as original_currency, 2022-04-19 10:30:47 normalization > 84: financing_problems, 2022-04-19 10:30:47 normalization > 85: cast(company_contract_id as 2022-04-19 10:30:47 normalization > 86: string 2022-04-19 10:30:47 normalization > 87:) as company_contract_id, 2022-04-19 10:30:47 normalization > 88: cast(contract_start_date as 2022-04-19 10:30:47 normalization > 89: string 2022-04-19 10:30:47 normalization > 90:) as contract_start_date, 2022-04-19 10:30:47 normalization > 91: cast(current_gross_value as 2022-04-19 10:30:47 normalization > 92: float64 2022-04-19 10:30:47 normalization > 93:) as current_gross_value, 2022-04-19 10:30:47 normalization > 94: cast(latest_billing_date as 2022-04-19 10:30:47 normalization > 95: string 2022-04-19 10:30:47 normalization > 96:) as latest_billing_date, 2022-04-19 10:30:47 normalization > 97: cast(recap_contract_status as 2022-04-19 10:30:47 normalization > 98: string 2022-04-19 10:30:47 normalization > 99:) as recap_contract_status, 2022-04-19 10:30:47 normalization > 100: cast(company_contract_status as 2022-04-19 10:30:47 normalization > 101: string 2022-04-19 10:30:47 normalization > 102:) as company_contract_status, 2022-04-19 10:30:47 normalization > 103: cast(company_contract_provided_id as 2022-04-19 10:30:47 normalization > 104: string 2022-04-19 10:30:47 normalization > 105:) as company_contract_provided_id, 2022-04-19 10:30:47 normalization > 106: cast(original_current_gross_value as 2022-04-19 10:30:47 normalization > 107: float64 2022-04-19 10:30:47 normalization > 108:) as original_current_gross_value, 2022-04-19 10:30:47 normalization > 109: _airbyte_ab_id, 2022-04-19 10:30:47 normalization > 110: _airbyte_emitted_at, 2022-04-19 10:30:47 normalization > 111: CURRENT_TIMESTAMP() as _airbyte_normalized_at 2022-04-19 10:30:47 normalization > 112:from __dbt__cte__company_contract_ab1 2022-04-19 10:30:47 normalization > 113:-- company_contract 2022-04-19 10:30:47 normalization > 114:where 1 = 1 2022-04-19 10:30:47 normalization > 115: 2022-04-19 10:30:47 normalization > 116:), __dbt__cte__company_contract_ab3 as ( 2022-04-19 10:30:47 normalization > 117: 2022-04-19 10:30:47 normalization > 118:-- SQL model to build a hash column based on the values of this record 2022-04-19 10:30:47 normalization > 119:-- depends_on: __dbt__cte__company_contract_ab2 2022-04-19 10:30:47 normalization > 120:select 2022-04-19 10:30:47 normalization > 121: to_hex(md5(cast(concat(coalesce(cast(currency as 2022-04-19 10:30:47 normalization > 122: string 2022-04-19 10:30:47 normalization > 123:), ''), '-', coalesce(cast(company_id as 2022-04-19 10:30:47 normalization > 124: string 2022-04-19 10:30:47 normalization > 125:), ''), '-', coalesce(cast(created_at as 2022-04-19 10:30:47 normalization > 126: string 2022-04-19 10:30:47 normalization > 127:), ''), '-', coalesce(cast(deleted_at as 2022-04-19 10:30:47 normalization > 128: string 2022-04-19 10:30:47 normalization > 129:), ''), '-', coalesce(cast(updated_at as 2022-04-19 10:30:47 normalization > 130: string 2022-04-19 10:30:47 normalization > 131:), ''), '-', coalesce(cast(customer_id as 2022-04-19 10:30:47 normalization > 132: string 2022-04-19 10:30:47 normalization > 133:), ''), '-', coalesce(cast(billing_cycle as 2022-04-19 10:30:47 normalization > 134: string 2022-04-19 10:30:47 normalization > 135:), ''), '-', coalesce(cast(customer_name as 2022-04-19 10:30:47 normalization > 136: string 2022-04-19 10:30:47 normalization > 137:), ''), '-', coalesce(cast(financeability as 2022-04-19 10:30:47 normalization > 138: string 2022-04-19 10:30:47 normalization > 139:), ''), '-', coalesce(cast(source_file_id as 2022-04-19 10:30:47 normalization > 140: string 2022-04-19 10:30:47 normalization > 141:), ''), '-', coalesce(cast(contract_end_date as 2022-04-19 10:30:47 normalization > 142: string 2022-04-19 10:30:47 normalization > 143:), ''), '-', coalesce(cast(original_currency as 2022-04-19 10:30:47 normalization > 144: string 2022-04-19 10:30:47 normalization > 145:), ''), '-', coalesce(cast(array_to_string(financing_problems, "|", "") as 2022-04-19 10:30:47 normalization > 146: string 2022-04-19 10:30:47 normalization > 147:), ''), '-', coalesce(cast(company_contract_id as 2022-04-19 10:30:47 normalization > 148: string 2022-04-19 10:30:47 normalization > 149:), ''), '-', coalesce(cast(contract_start_date as 2022-04-19 10:30:47 normalization > 150: string 2022-04-19 10:30:47 normalization > 151:), ''), '-', coalesce(cast(current_gross_value as 2022-04-19 10:30:47 normalization > 152: string 2022-04-19 10:30:47 normalization > 153:), ''), '-', coalesce(cast(latest_billing_date as 2022-04-19 10:30:47 normalization > 154: string 2022-04-19 10:30:47 normalization > 155:), ''), '-', coalesce(cast(recap_contract_status as 2022-04-19 10:30:47 normalization > 156: string 2022-04-19 10:30:47 normalization > 157:), ''), '-', coalesce(cast(company_contract_status as 2022-04-19 10:30:47 normalization > 158: string 2022-04-19 10:30:47 normalization > 159:), ''), '-', coalesce(cast(company_contract_provided_id as 2022-04-19 10:30:47 normalization > 160: string 2022-04-19 10:30:47 normalization > 161:), ''), '-', coalesce(cast(original_current_gross_value as 2022-04-19 10:30:47 normalization > 162: string 2022-04-19 10:30:47 normalization > 163:), '')) as 2022-04-19 10:30:47 normalization > 164: string 2022-04-19 10:30:47 normalization > 165:))) as _airbyte_company_contract_hashid, 2022-04-19 10:30:47 normalization > 166: tmp.* 2022-04-19 10:30:47 normalization > 167:from __dbt__cte__company_contract_ab2 tmp 2022-04-19 10:30:47 normalization > 168:-- company_contract 2022-04-19 10:30:47 normalization > 169:where 1 = 1 2022-04-19 10:30:47 normalization > 170: 2022-04-19 10:30:47 normalization > 171:)-- Final base SQL model 2022-04-19 10:30:47 normalization > 172:-- depends_on: __dbt__cte__company_contract_ab3 2022-04-19 10:30:47 normalization > 173:select 2022-04-19 10:30:47 normalization > 174: currency, 2022-04-19 10:30:47 normalization > 175: company_id, 2022-04-19 10:30:47 normalization > 176: created_at, 2022-04-19 10:30:47 normalization > 177: deleted_at, 2022-04-19 10:30:47 normalization > 178: updated_at, 2022-04-19 10:30:47 normalization > 179: customer_id, 2022-04-19 10:30:47 normalization > 180: billing_cycle, 2022-04-19 10:30:47 normalization > 181: customer_name, 2022-04-19 10:30:47 normalization > 182: financeability, 2022-04-19 10:30:47 normalization > 183: source_file_id, 2022-04-19 10:30:47 normalization > 184: contract_end_date, 2022-04-19 10:30:47 normalization > 185: original_currency, 2022-04-19 10:30:47 normalization > 186: financing_problems, 2022-04-19 10:30:47 normalization > 187: company_contract_id, 2022-04-19 10:30:47 normalization > 188: contract_start_date, 2022-04-19 10:30:47 normalization > 189: current_gross_value, 2022-04-19 10:30:47 normalization > 190: latest_billing_date, 2022-04-19 10:30:47 normalization > 191: recap_contract_status, 2022-04-19 10:30:47 normalization > 192: company_contract_status, 2022-04-19 10:30:47 normalization > 193: company_contract_provided_id, 2022-04-19 10:30:47 normalization > 194: original_current_gross_value, 2022-04-19 10:30:47 normalization > 195: _airbyte_ab_id, 2022-04-19 10:30:47 normalization > 196: _airbyte_emitted_at, 2022-04-19 10:30:47 normalization > 197: CURRENT_TIMESTAMP() as _airbyte_normalized_at, 2022-04-19 10:30:47 normalization > 198: _airbyte_company_contract_hashid 2022-04-19 10:30:47 normalization > 199:from __dbt__cte__company_contract_ab3 2022-04-19 10:30:47 normalization > 200:-- company_contract from `recap-dev-347108`.staging._airbyte_raw_company_contract 2022-04-19 10:30:47 normalization > 201:where 1 = 1 2022-04-19 10:30:47 normalization > 202: 2022-04-19 10:30:47 normalization > 203: ); 2022-04-19 10:30:47 normalization > 204: 2022-04-19 10:30:47 normalization > | . | . | . | . | . | . | . | . | . | . | . | . | . | . | 2022-04-19 10:30:47 normalization > 10:30:43.240658 [debug] [Thread-4 ]: finished collecting timing info 2022-04-19 10:30:47 normalization > 10:30:43.241111 [debug] [Thread-4 ]: Runtime Error in model company_contract (models/generated/airbyte_incremental/staging/company_contract.sql) 2022-04-19 10:30:47 normalization > 404 Not found: Table recap-dev-347108:staging._airbyte_raw_company_contract was not found in location US 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > (job ID: 5dc9d01e-d810-41b3-b947-826127408bac) 2022-04-19 10:30:47 normalization > 10:30:43.241542 [error] [Thread-4 ]: 2 of 2 ERROR creating incremental model staging.company_contract........................................................ [ERROR in 0.66s] 2022-04-19 10:30:47 normalization > 10:30:43.243712 [debug] [Thread-4 ]: Finished running node model.airbyte_utils.company_contract 2022-04-19 10:30:47 normalization > 10:30:43.260011 [debug] [Thread-7 ]: BigQuery adapter: Unhandled error while running: 2022-04-19 10:30:47 normalization > /* {"app": "dbt", "dbt_version": "1.0.0", "profile_name": "normalize", "target_name": "prod", "node_id": "model.airbyte_utils.company_invoice"} */ 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > create or replace table `recap-dev-347108`.staging.`company_invoice` 2022-04-19 10:30:47 normalization > partition by timestamp_trunc(_airbyte_emitted_at, day) 2022-04-19 10:30:47 normalization > cluster by _airbyte_emitted_at 2022-04-19 10:30:47 normalization > OPTIONS() 2022-04-19 10:30:47 normalization > as ( 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > with __dbt__cte__company_invoice_ab1 as ( 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > -- SQL model to parse JSON blob stored in a single column and extract into separated field columns as described by the JSON Schema 2022-04-19 10:30:47 normalization > -- depends_on: `recap-dev-347108`.staging._airbyte_raw_company_invoice 2022-04-19 10:30:47 normalization > select 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['currency']") as currency, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['created_at']") as created_at, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['deleted_at']") as deleted_at, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['updated_at']") as updated_at, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['invoice_date']") as invoice_date, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['invoice_status']") as invoice_status, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['source_file_id']") as source_file_id, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['original_currency']") as original_currency, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['company_invoice_id']") as company_invoice_id, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['company_contract_id']") as company_contract_id, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['invoice_gross_amount']") as invoice_gross_amount, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['invoice_payment_date']") as invoice_payment_date, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['company_invoice_provided_id']") as company_invoice_provided_id, 2022-04-19 10:30:47 normalization > json_extract_scalar(_airbyte_data, "$['original_invoice_gross_amount']") as original_invoice_gross_amount, 2022-04-19 10:30:47 normalization > _airbyte_ab_id, 2022-04-19 10:30:47 normalization > _airbyte_emitted_at, 2022-04-19 10:30:47 normalization > CURRENT_TIMESTAMP() as _airbyte_normalized_at 2022-04-19 10:30:47 normalization > from `recap-dev-347108`.staging._airbyte_raw_company_invoice as table_alias 2022-04-19 10:30:47 normalization > -- company_invoice 2022-04-19 10:30:47 normalization > where 1 = 1 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > ), __dbt__cte__company_invoice_ab2 as ( 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > -- SQL model to cast each column to its adequate SQL type converted from the JSON schema type 2022-04-19 10:30:47 normalization > -- depends_on: __dbt__cte__company_invoice_ab1 2022-04-19 10:30:47 normalization > select 2022-04-19 10:30:47 normalization > cast(currency as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as currency, 2022-04-19 10:30:47 normalization > cast(created_at as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as created_at, 2022-04-19 10:30:47 normalization > cast(deleted_at as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as deleted_at, 2022-04-19 10:30:47 normalization > cast(updated_at as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as updated_at, 2022-04-19 10:30:47 normalization > cast(invoice_date as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as invoice_date, 2022-04-19 10:30:47 normalization > cast(invoice_status as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as invoice_status, 2022-04-19 10:30:47 normalization > cast(source_file_id as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as source_file_id, 2022-04-19 10:30:47 normalization > cast(original_currency as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as original_currency, 2022-04-19 10:30:47 normalization > cast(company_invoice_id as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as company_invoice_id, 2022-04-19 10:30:47 normalization > cast(company_contract_id as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as company_contract_id, 2022-04-19 10:30:47 normalization > cast(invoice_gross_amount as 2022-04-19 10:30:47 normalization > float64 2022-04-19 10:30:47 normalization > ) as invoice_gross_amount, 2022-04-19 10:30:47 normalization > cast(invoice_payment_date as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as invoice_payment_date, 2022-04-19 10:30:47 normalization > cast(company_invoice_provided_id as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ) as company_invoice_provided_id, 2022-04-19 10:30:47 normalization > cast(original_invoice_gross_amount as 2022-04-19 10:30:47 normalization > float64 2022-04-19 10:30:47 normalization > ) as original_invoice_gross_amount, 2022-04-19 10:30:47 normalization > _airbyte_ab_id, 2022-04-19 10:30:47 normalization > _airbyte_emitted_at, 2022-04-19 10:30:47 normalization > CURRENT_TIMESTAMP() as _airbyte_normalized_at 2022-04-19 10:30:47 normalization > from __dbt__cte__company_invoice_ab1 2022-04-19 10:30:47 normalization > -- company_invoice 2022-04-19 10:30:47 normalization > where 1 = 1 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > ), __dbt__cte__company_invoice_ab3 as ( 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > -- SQL model to build a hash column based on the values of this record 2022-04-19 10:30:47 normalization > -- depends_on: __dbt__cte__company_invoice_ab2 2022-04-19 10:30:47 normalization > select 2022-04-19 10:30:47 normalization > to_hex(md5(cast(concat(coalesce(cast(currency as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(created_at as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(deleted_at as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(updated_at as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(invoice_date as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(invoice_status as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(source_file_id as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(original_currency as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(company_invoice_id as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(company_contract_id as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(invoice_gross_amount as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(invoice_payment_date as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(company_invoice_provided_id as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), ''), '-', coalesce(cast(original_invoice_gross_amount as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ), '')) as 2022-04-19 10:30:47 normalization > string 2022-04-19 10:30:47 normalization > ))) as _airbyte_company_invoice_hashid, 2022-04-19 10:30:47 normalization > tmp.* 2022-04-19 10:30:47 normalization > from __dbt__cte__company_invoice_ab2 tmp 2022-04-19 10:30:47 normalization > -- company_invoice 2022-04-19 10:30:47 normalization > where 1 = 1 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > )-- Final base SQL model 2022-04-19 10:30:47 normalization > -- depends_on: __dbt__cte__company_invoice_ab3 2022-04-19 10:30:47 normalization > select 2022-04-19 10:30:47 normalization > currency, 2022-04-19 10:30:47 normalization > created_at, 2022-04-19 10:30:47 normalization > deleted_at, 2022-04-19 10:30:47 normalization > updated_at, 2022-04-19 10:30:47 normalization > invoice_date, 2022-04-19 10:30:47 normalization > invoice_status, 2022-04-19 10:30:47 normalization > source_file_id, 2022-04-19 10:30:47 normalization > original_currency, 2022-04-19 10:30:47 normalization > company_invoice_id, 2022-04-19 10:30:47 normalization > company_contract_id, 2022-04-19 10:30:47 normalization > invoice_gross_amount, 2022-04-19 10:30:47 normalization > invoice_payment_date, 2022-04-19 10:30:47 normalization > company_invoice_provided_id, 2022-04-19 10:30:47 normalization > original_invoice_gross_amount, 2022-04-19 10:30:47 normalization > _airbyte_ab_id, 2022-04-19 10:30:47 normalization > _airbyte_emitted_at, 2022-04-19 10:30:47 normalization > CURRENT_TIMESTAMP() as _airbyte_normalized_at, 2022-04-19 10:30:47 normalization > _airbyte_company_invoice_hashid 2022-04-19 10:30:47 normalization > from __dbt__cte__company_invoice_ab3 2022-04-19 10:30:47 normalization > -- company_invoice from `recap-dev-347108`.staging._airbyte_raw_company_invoice 2022-04-19 10:30:47 normalization > where 1 = 1 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > ); 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > 10:30:43.260214 [debug] [Thread-7 ]: BigQuery adapter: 404 Not found: Table recap-dev-347108:staging._airbyte_raw_company_invoice was not found in location US 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > (job ID: 645098c9-9f9d-4237-935d-d5710cdaec14) 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > -----Query Job SQL Follows----- 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > | . | . | . | . | . | . | . | . | . | . | . | . | . | . | 2022-04-19 10:30:47 normalization > 1:/* {"app": "dbt", "dbt_version": "1.0.0", "profile_name": "normalize", "target_name": "prod", "node_id": "model.airbyte_utils.company_invoice"} */ 2022-04-19 10:30:47 normalization > 2: 2022-04-19 10:30:47 normalization > 3: 2022-04-19 10:30:47 normalization > 4: create or replace table `recap-dev-347108`.staging.`company_invoice` 2022-04-19 10:30:47 normalization > 5: partition by timestamp_trunc(_airbyte_emitted_at, day) 2022-04-19 10:30:47 normalization > 6: cluster by _airbyte_emitted_at 2022-04-19 10:30:47 normalization > 7: OPTIONS() 2022-04-19 10:30:47 normalization > 8: as ( 2022-04-19 10:30:47 normalization > 9: 2022-04-19 10:30:47 normalization > 10:with __dbt__cte__company_invoice_ab1 as ( 2022-04-19 10:30:47 normalization > 11: 2022-04-19 10:30:47 normalization > 12:-- SQL model to parse JSON blob stored in a single column and extract into separated field columns as described by the JSON Schema 2022-04-19 10:30:47 normalization > 13:-- depends_on: `recap-dev-347108`.staging._airbyte_raw_company_invoice 2022-04-19 10:30:47 normalization > 14:select 2022-04-19 10:30:47 normalization > 15: json_extract_scalar(_airbyte_data, "$['currency']") as currency, 2022-04-19 10:30:47 normalization > 16: json_extract_scalar(_airbyte_data, "$['created_at']") as created_at, 2022-04-19 10:30:47 normalization > 17: json_extract_scalar(_airbyte_data, "$['deleted_at']") as deleted_at, 2022-04-19 10:30:47 normalization > 18: json_extract_scalar(_airbyte_data, "$['updated_at']") as updated_at, 2022-04-19 10:30:47 normalization > 19: json_extract_scalar(_airbyte_data, "$['invoice_date']") as invoice_date, 2022-04-19 10:30:47 normalization > 20: json_extract_scalar(_airbyte_data, "$['invoice_status']") as invoice_status, 2022-04-19 10:30:47 normalization > 21: json_extract_scalar(_airbyte_data, "$['source_file_id']") as source_file_id, 2022-04-19 10:30:47 normalization > 22: json_extract_scalar(_airbyte_data, "$['original_currency']") as original_currency, 2022-04-19 10:30:47 normalization > 23: json_extract_scalar(_airbyte_data, "$['company_invoice_id']") as company_invoice_id, 2022-04-19 10:30:47 normalization > 24: json_extract_scalar(_airbyte_data, "$['company_contract_id']") as company_contract_id, 2022-04-19 10:30:47 normalization > 25: json_extract_scalar(_airbyte_data, "$['invoice_gross_amount']") as invoice_gross_amount, 2022-04-19 10:30:47 normalization > 26: json_extract_scalar(_airbyte_data, "$['invoice_payment_date']") as invoice_payment_date, 2022-04-19 10:30:47 normalization > 27: json_extract_scalar(_airbyte_data, "$['company_invoice_provided_id']") as company_invoice_provided_id, 2022-04-19 10:30:47 INFO i.a.w.t.TemporalAttemptExecution(lambda$getWorkerThread$2):158 - Completing future exceptionally... io.airbyte.workers.WorkerException: Normalization Failed. at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:61) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:19) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at java.lang.Thread.run(Thread.java:833) [?:?] Caused by: io.airbyte.workers.WorkerException: Normalization Failed. at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:58) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] ... 3 more Suppressed: io.airbyte.workers.WorkerException: Normalization process wasn't successful at io.airbyte.workers.normalization.DefaultNormalizationRunner.close(DefaultNormalizationRunner.java:160) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:46) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:19) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at java.lang.Thread.run(Thread.java:833) [?:?] 2022-04-19 10:30:47 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2022-04-19 10:30:47 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating... 2022-04-19 10:30:47 WARN i.t.i.a.POJOActivityTaskHandler(activityFailureToResult):307 - Activity failure. ActivityId=c5e00705-21c1-3325-ad5f-bcbe7fbd85d7, activityType=Normalize, attempt=1 java.lang.RuntimeException: io.temporal.serviceclient.CheckedExceptionWrapper: java.util.concurrent.ExecutionException: io.airbyte.workers.WorkerException: Normalization Failed. at io.airbyte.workers.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:233) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at io.airbyte.workers.temporal.sync.NormalizationActivityImpl.normalize(NormalizationActivityImpl.java:72) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:?] at jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77) ~[?:?] at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?] at java.lang.reflect.Method.invoke(Method.java:568) ~[?:?] at io.temporal.internal.activity.POJOActivityTaskHandler$POJOActivityInboundCallsInterceptor.execute(POJOActivityTaskHandler.java:214) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.activity.POJOActivityTaskHandler$POJOActivityImplementation.execute(POJOActivityTaskHandler.java:180) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.activity.POJOActivityTaskHandler.handle(POJOActivityTaskHandler.java:120) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:204) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:164) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:93) ~[temporal-sdk-1.8.1.jar:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) [?:?] at java.lang.Thread.run(Thread.java:833) [?:?] Caused by: io.temporal.serviceclient.CheckedExceptionWrapper: java.util.concurrent.ExecutionException: io.airbyte.workers.WorkerException: Normalization Failed. at io.temporal.serviceclient.CheckedExceptionWrapper.wrap(CheckedExceptionWrapper.java:56) ~[temporal-serviceclient-1.8.1.jar:?] at io.temporal.internal.sync.WorkflowInternal.wrap(WorkflowInternal.java:448) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.activity.Activity.wrap(Activity.java:51) ~[temporal-sdk-1.8.1.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.get(TemporalAttemptExecution.java:135) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at io.airbyte.workers.temporal.sync.NormalizationActivityImpl.lambda$normalize$1(NormalizationActivityImpl.java:98) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at io.airbyte.workers.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:228) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] ... 14 more Caused by: java.util.concurrent.ExecutionException: io.airbyte.workers.WorkerException: Normalization Failed. at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) ~[?:?] at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) ~[?:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.get(TemporalAttemptExecution.java:129) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at io.airbyte.workers.temporal.sync.NormalizationActivityImpl.lambda$normalize$1(NormalizationActivityImpl.java:98) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at io.airbyte.workers.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:228) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] ... 14 more Caused by: io.airbyte.workers.WorkerException: Normalization Failed. at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:61) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:19) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] ... 1 more Caused by: io.airbyte.workers.WorkerException: Normalization Failed. at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:58) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:19) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] ... 1 more Suppressed: io.airbyte.workers.WorkerException: Normalization process wasn't successful at io.airbyte.workers.normalization.DefaultNormalizationRunner.close(DefaultNormalizationRunner.java:160) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:46) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:19) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at java.lang.Thread.run(Thread.java:833) [?:?] 2022-04-19 10:30:47 normalization > 28: json_extract_scalar(_airbyte_data, "$['original_invoice_gross_amount']") as original_invoice_gross_amount, 2022-04-19 10:30:47 normalization > 29: _airbyte_ab_id, 2022-04-19 10:30:47 normalization > 30: _airbyte_emitted_at, 2022-04-19 10:30:47 normalization > 31: CURRENT_TIMESTAMP() as _airbyte_normalized_at 2022-04-19 10:30:47 normalization > 32:from `recap-dev-347108`.staging._airbyte_raw_company_invoice as table_alias 2022-04-19 10:30:47 normalization > 33:-- company_invoice 2022-04-19 10:30:47 normalization > 34:where 1 = 1 2022-04-19 10:30:47 normalization > 35: 2022-04-19 10:30:47 normalization > 36:), __dbt__cte__company_invoice_ab2 as ( 2022-04-19 10:30:47 normalization > 37: 2022-04-19 10:30:47 normalization > 38:-- SQL model to cast each column to its adequate SQL type converted from the JSON schema type 2022-04-19 10:30:47 normalization > 39:-- depends_on: __dbt__cte__company_invoice_ab1 2022-04-19 10:30:47 normalization > 40:select 2022-04-19 10:30:47 normalization > 41: cast(currency as 2022-04-19 10:30:47 normalization > 42: string 2022-04-19 10:30:47 normalization > 43:) as currency, 2022-04-19 10:30:47 normalization > 44: cast(created_at as 2022-04-19 10:30:47 normalization > 45: string 2022-04-19 10:30:47 normalization > 46:) as created_at, 2022-04-19 10:30:47 normalization > 47: cast(deleted_at as 2022-04-19 10:30:47 normalization > 48: string 2022-04-19 10:30:47 normalization > 49:) as deleted_at, 2022-04-19 10:30:47 normalization > 50: cast(updated_at as 2022-04-19 10:30:47 normalization > 51: string 2022-04-19 10:30:47 normalization > 52:) as updated_at, 2022-04-19 10:30:47 normalization > 53: cast(invoice_date as 2022-04-19 10:30:47 normalization > 54: string 2022-04-19 10:30:47 normalization > 55:) as invoice_date, 2022-04-19 10:30:47 normalization > 56: cast(invoice_status as 2022-04-19 10:30:47 normalization > 57: string 2022-04-19 10:30:47 normalization > 58:) as invoice_status, 2022-04-19 10:30:47 normalization > 59: cast(source_file_id as 2022-04-19 10:30:47 normalization > 60: string 2022-04-19 10:30:47 normalization > 61:) as source_file_id, 2022-04-19 10:30:47 normalization > 62: cast(original_currency as 2022-04-19 10:30:47 normalization > 63: string 2022-04-19 10:30:47 normalization > 64:) as original_currency, 2022-04-19 10:30:47 normalization > 65: cast(company_invoice_id as 2022-04-19 10:30:47 normalization > 66: string 2022-04-19 10:30:47 normalization > 67:) as company_invoice_id, 2022-04-19 10:30:47 normalization > 68: cast(company_contract_id as 2022-04-19 10:30:47 normalization > 69: string 2022-04-19 10:30:47 normalization > 70:) as company_contract_id, 2022-04-19 10:30:47 normalization > 71: cast(invoice_gross_amount as 2022-04-19 10:30:47 normalization > 72: float64 2022-04-19 10:30:47 normalization > 73:) as invoice_gross_amount, 2022-04-19 10:30:47 normalization > 74: cast(invoice_payment_date as 2022-04-19 10:30:47 normalization > 75: string 2022-04-19 10:30:47 normalization > 76:) as invoice_payment_date, 2022-04-19 10:30:47 normalization > 77: cast(company_invoice_provided_id as 2022-04-19 10:30:47 normalization > 78: string 2022-04-19 10:30:47 normalization > 79:) as company_invoice_provided_id, 2022-04-19 10:30:47 normalization > 80: cast(original_invoice_gross_amount as 2022-04-19 10:30:47 normalization > 81: float64 2022-04-19 10:30:47 normalization > 82:) as original_invoice_gross_amount, 2022-04-19 10:30:47 normalization > 83: _airbyte_ab_id, 2022-04-19 10:30:47 normalization > 84: _airbyte_emitted_at, 2022-04-19 10:30:47 normalization > 85: CURRENT_TIMESTAMP() as _airbyte_normalized_at 2022-04-19 10:30:47 normalization > 86:from __dbt__cte__company_invoice_ab1 2022-04-19 10:30:47 normalization > 87:-- company_invoice 2022-04-19 10:30:47 normalization > 88:where 1 = 1 2022-04-19 10:30:47 normalization > 89: 2022-04-19 10:30:47 normalization > 90:), __dbt__cte__company_invoice_ab3 as ( 2022-04-19 10:30:47 normalization > 91: 2022-04-19 10:30:47 normalization > 92:-- SQL model to build a hash column based on the values of this record 2022-04-19 10:30:47 normalization > 93:-- depends_on: __dbt__cte__company_invoice_ab2 2022-04-19 10:30:47 normalization > 94:select 2022-04-19 10:30:47 normalization > 95: to_hex(md5(cast(concat(coalesce(cast(currency as 2022-04-19 10:30:47 normalization > 96: string 2022-04-19 10:30:47 normalization > 97:), ''), '-', coalesce(cast(created_at as 2022-04-19 10:30:47 normalization > 98: string 2022-04-19 10:30:47 normalization > 99:), ''), '-', coalesce(cast(deleted_at as 2022-04-19 10:30:47 normalization > 100: string 2022-04-19 10:30:47 normalization > 101:), ''), '-', coalesce(cast(updated_at as 2022-04-19 10:30:47 normalization > 102: string 2022-04-19 10:30:47 normalization > 103:), ''), '-', coalesce(cast(invoice_date as 2022-04-19 10:30:47 normalization > 104: string 2022-04-19 10:30:47 normalization > 105:), ''), '-', coalesce(cast(invoice_status as 2022-04-19 10:30:47 normalization > 106: string 2022-04-19 10:30:47 normalization > 107:), ''), '-', coalesce(cast(source_file_id as 2022-04-19 10:30:47 normalization > 108: string 2022-04-19 10:30:47 normalization > 109:), ''), '-', coalesce(cast(original_currency as 2022-04-19 10:30:47 normalization > 110: string 2022-04-19 10:30:47 normalization > 111:), ''), '-', coalesce(cast(company_invoice_id as 2022-04-19 10:30:47 normalization > 112: string 2022-04-19 10:30:47 normalization > 113:), ''), '-', coalesce(cast(company_contract_id as 2022-04-19 10:30:47 normalization > 114: string 2022-04-19 10:30:47 normalization > 115:), ''), '-', coalesce(cast(invoice_gross_amount as 2022-04-19 10:30:47 normalization > 116: string 2022-04-19 10:30:47 normalization > 117:), ''), '-', coalesce(cast(invoice_payment_date as 2022-04-19 10:30:47 normalization > 118: string 2022-04-19 10:30:47 normalization > 119:), ''), '-', coalesce(cast(company_invoice_provided_id as 2022-04-19 10:30:47 normalization > 120: string 2022-04-19 10:30:47 normalization > 121:), ''), '-', coalesce(cast(original_invoice_gross_amount as 2022-04-19 10:30:47 normalization > 122: string 2022-04-19 10:30:47 normalization > 123:), '')) as 2022-04-19 10:30:47 normalization > 124: string 2022-04-19 10:30:47 normalization > 125:))) as _airbyte_company_invoice_hashid, 2022-04-19 10:30:47 normalization > 126: tmp.* 2022-04-19 10:30:47 normalization > 127:from __dbt__cte__company_invoice_ab2 tmp 2022-04-19 10:30:47 normalization > 128:-- company_invoice 2022-04-19 10:30:47 normalization > 129:where 1 = 1 2022-04-19 10:30:47 normalization > 130: 2022-04-19 10:30:47 normalization > 131:)-- Final base SQL model 2022-04-19 10:30:47 normalization > 132:-- depends_on: __dbt__cte__company_invoice_ab3 2022-04-19 10:30:47 normalization > 133:select 2022-04-19 10:30:47 normalization > 134: currency, 2022-04-19 10:30:47 normalization > 135: created_at, 2022-04-19 10:30:47 normalization > 136: deleted_at, 2022-04-19 10:30:47 normalization > 137: updated_at, 2022-04-19 10:30:47 normalization > 138: invoice_date, 2022-04-19 10:30:47 normalization > 139: invoice_status, 2022-04-19 10:30:47 normalization > 140: source_file_id, 2022-04-19 10:30:47 normalization > 141: original_currency, 2022-04-19 10:30:47 normalization > 142: company_invoice_id, 2022-04-19 10:30:47 normalization > 143: company_contract_id, 2022-04-19 10:30:47 normalization > 144: invoice_gross_amount, 2022-04-19 10:30:47 normalization > 145: invoice_payment_date, 2022-04-19 10:30:47 normalization > 146: company_invoice_provided_id, 2022-04-19 10:30:47 normalization > 147: original_invoice_gross_amount, 2022-04-19 10:30:47 normalization > 148: _airbyte_ab_id, 2022-04-19 10:30:47 normalization > 149: _airbyte_emitted_at, 2022-04-19 10:30:47 normalization > 150: CURRENT_TIMESTAMP() as _airbyte_normalized_at, 2022-04-19 10:30:47 normalization > 151: _airbyte_company_invoice_hashid 2022-04-19 10:30:47 normalization > 152:from __dbt__cte__company_invoice_ab3 2022-04-19 10:30:47 normalization > 153:-- company_invoice from `recap-dev-347108`.staging._airbyte_raw_company_invoice 2022-04-19 10:30:47 normalization > 154:where 1 = 1 2022-04-19 10:30:47 normalization > 155: 2022-04-19 10:30:47 normalization > 156: ); 2022-04-19 10:30:47 normalization > 157: 2022-04-19 10:30:47 normalization > | . | . | . | . | . | . | . | . | . | . | . | . | . | . | 2022-04-19 10:30:47 normalization > 10:30:43.260461 [debug] [Thread-7 ]: finished collecting timing info 2022-04-19 10:30:47 normalization > 10:30:43.260837 [debug] [Thread-7 ]: Runtime Error in model company_invoice (models/generated/airbyte_incremental/staging/company_invoice.sql) 2022-04-19 10:30:47 normalization > 404 Not found: Table recap-dev-347108:staging._airbyte_raw_company_invoice was not found in location US 2022-04-19 10:30:47 normalization > 2022-04-19 10:30:47 normalization > (job ID: 645098c9-9f9d-4237-935d-d5710cdaec14) 2022-04-19 10:30:47 normalization > 10:30:43.261194 [error] [Thread-7 ]: 1 of 2 ERROR creating incremental model staging.company_invoice......................................................... [ERROR in 0.77s] 2022-04-19 10:30:47 normalization > 10:30:43.261600 [debug] [Thread-7 ]: Finished running node model.airbyte_utils.company_invoice 2022-04-19 10:30:47 normalization > 10:30:43.263553 [debug] [MainThread]: Acquiring new bigquery connection "master" 2022-04-19 10:30:47 normalization > 10:30:43.263976 [info ] [MainThread]: 2022-04-19 10:30:47 normalization > 10:30:43.264265 [info ] [MainThread]: Finished running 2 incremental models in 2.48s. 2022-04-19 10:30:47 normalization > 10:30:43.264702 [debug] [MainThread]: Connection 'master' was properly closed. 2022-04-19 10:30:47 normalization > 10:30:43.264899 [debug] [MainThread]: Connection 'model.airbyte_utils.company_contract_ab2' was properly closed. 2022-04-19 10:30:47 normalization > 10:30:43.265089 [debug] [MainThread]: Connection 'model.airbyte_utils.company_contract_ab3' was properly closed. 2022-04-19 10:30:47 normalization > 10:30:43.265225 [debug] [MainThread]: Connection 'model.airbyte_utils.company_contract' was properly closed. 2022-04-19 10:30:47 normalization > 10:30:43.265350 [debug] [MainThread]: Connection 'model.airbyte_utils.company_invoice_ab3' was properly closed. 2022-04-19 10:30:47 normalization > 10:30:43.265473 [debug] [MainThread]: Connection 'model.airbyte_utils.company_invoice' was properly closed. 2022-04-19 10:30:47 normalization > 10:30:43.278804 [info ] [MainThread]: 2022-04-19 10:30:47 normalization > 10:30:43.279176 [info ] [MainThread]: Completed with 2 errors and 0 warnings: 2022-04-19 10:30:47 normalization > 10:30:43.279636 [info ] [MainThread]: 2022-04-19 10:30:47 normalization > 10:30:43.280004 [error] [MainThread]: Runtime Error in model company_contract (models/generated/airbyte_incremental/staging/company_contract.sql) 2022-04-19 10:30:47 normalization > 10:30:43.280437 [error] [MainThread]: 404 Not found: Table recap-dev-347108:staging._airbyte_raw_company_contract was not found in location US 2022-04-19 10:30:47 normalization > 10:30:43.280793 [error] [MainThread]: 2022-04-19 10:30:47 normalization > 10:30:43.281135 [error] [MainThread]: (job ID: 5dc9d01e-d810-41b3-b947-826127408bac) 2022-04-19 10:30:47 normalization > 10:30:43.281488 [info ] [MainThread]: 2022-04-19 10:30:47 normalization > 10:30:43.281821 [error] [MainThread]: Runtime Error in model company_invoice (models/generated/airbyte_incremental/staging/company_invoice.sql) 2022-04-19 10:30:47 normalization > 10:30:43.282241 [error] [MainThread]: 404 Not found: Table recap-dev-347108:staging._airbyte_raw_company_invoice was not found in location US 2022-04-19 10:30:47 normalization > 10:30:43.282606 [error] [MainThread]: 2022-04-19 10:30:47 normalization > 10:30:43.282908 [error] [MainThread]: (job ID: 645098c9-9f9d-4237-935d-d5710cdaec14) 2022-04-19 10:30:47 normalization > 10:30:43.283240 [info ] [MainThread]: 2022-04-19 10:30:47 normalization > 10:30:43.283555 [info ] [MainThread]: Done. PASS=0 WARN=0 ERROR=2 SKIP=0 TOTAL=2 2022-04-19 10:30:47 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. errors: $.credential: is not defined in the schema and the schema does not allow additional properties, $.part_size_mb: is not defined in the schema and the schema does not allow additional properties, $.gcs_bucket_name: is not defined in the schema and the schema does not allow additional properties, $.gcs_bucket_path: is not defined in the schema and the schema does not allow additional properties, $.keep_files_in_gcs-bucket: is not defined in the schema and the schema does not allow additional properties, $.method: must be a constant value Standard