2022-05-13 15:49:38 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.35.51-alpha 2022-05-13 15:49:39 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/379/0/logs.log 2022-05-13 15:49:39 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.51-alpha 2022-05-13 15:49:39 INFO i.a.w.DefaultReplicationWorker(run):103 - start sync worker. job id: 379 attempt id: 0 2022-05-13 15:49:39 INFO i.a.w.DefaultReplicationWorker(run):115 - configured sync modes: {null.BB_FB=full_refresh - overwrite, null.GG_MXCO=full_refresh - overwrite, null.GG_CL=full_refresh - overwrite} 2022-05-13 15:49:39 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination... 2022-05-13 15:49:39 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-redshift:0.3.28 exists... 2022-05-13 15:49:39 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-redshift:0.3.28 was found locally. 2022-05-13 15:49:39 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 379 2022-05-13 15:49:39 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/379/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_CONNECTOR_IMAGE=airbyte/destination-redshift:0.3.28 -e WORKER_JOB_ATTEMPT=0 -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e AIRBYTE_VERSION=0.35.51-alpha -e WORKER_JOB_ID=379 airbyte/destination-redshift:0.3.28 write --config destination_config.json --catalog destination_catalog.json 2022-05-13 15:49:39 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-google-sheets:0.2.9 exists... 2022-05-13 15:49:39 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-google-sheets:0.2.9 was found locally. 2022-05-13 15:49:39 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 379 2022-05-13 15:49:39 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/379/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_CONNECTOR_IMAGE=airbyte/source-google-sheets:0.2.9 -e WORKER_JOB_ATTEMPT=0 -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e AIRBYTE_VERSION=0.35.51-alpha -e WORKER_JOB_ID=379 airbyte/source-google-sheets:0.2.9 read --config source_config.json --catalog source_catalog.json --state input_state.json 2022-05-13 15:49:39 INFO i.a.w.DefaultReplicationWorker(run):157 - Waiting for source and destination threads to complete. 2022-05-13 15:49:39 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):338 - Destination output thread started. 2022-05-13 15:49:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):278 - Replication thread started. 2022-05-13 15:49:40 destination > SLF4J: Class path contains multiple SLF4J bindings. 2022-05-13 15:49:40 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-05-13 15:49:40 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-05-13 15:49:40 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-05-13 15:49:40 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-05-13 15:49:41 source > Starting syncing spreadsheet 1pw6KVU3nw1WqWGRxqgvH13ItoHqaoZQKwkkjKJXVMnc 2022-05-13 15:49:41 destination > 2022-05-13 15:49:41 INFO i.a.i.d.r.RedshiftDestination(main):77 - starting destination: class io.airbyte.integrations.destination.redshift.RedshiftDestination 2022-05-13 15:49:42 destination > 2022-05-13 15:49:42 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json} 2022-05-13 15:49:42 destination > 2022-05-13 15:49:42 INFO i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.destination.redshift.RedshiftDestination 2022-05-13 15:49:42 destination > 2022-05-13 15:49:42 INFO i.a.i.b.IntegrationRunner(runInternal):122 - Command: WRITE 2022-05-13 15:49:42 destination > 2022-05-13 15:49:42 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'} 2022-05-13 15:49:42 destination > 2022-05-13 15:49:42 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-05-13 15:49:42 destination > 2022-05-13 15:49:42 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-05-13 15:49:42 destination > 2022-05-13 15:49:42 INFO i.a.i.d.j.c.SwitchingDestination(getConsumer):65 - Using destination type: INSERT 2022-05-13 15:49:42 destination > 2022-05-13 15:49:42 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=BB_FB, namespace=airbyte_gspread, outputSchemaName=airbyte_gspread, tmpTableName=_airbyte_tmp_rik_bb_fb, outputTableName=_airbyte_raw_bb_fb, syncMode=overwrite} 2022-05-13 15:49:42 destination > 2022-05-13 15:49:42 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=GG_CL, namespace=airbyte_gspread, outputSchemaName=airbyte_gspread, tmpTableName=_airbyte_tmp_izj_gg_cl, outputTableName=_airbyte_raw_gg_cl, syncMode=overwrite} 2022-05-13 15:49:42 destination > 2022-05-13 15:49:42 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=GG_MXCO, namespace=airbyte_gspread, outputSchemaName=airbyte_gspread, tmpTableName=_airbyte_tmp_lpg_gg_mxco, outputTableName=_airbyte_raw_gg_mxco, syncMode=overwrite} 2022-05-13 15:49:42 destination > 2022-05-13 15:49:42 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):141 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started. 2022-05-13 15:49:42 destination > 2022-05-13 15:49:42 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):121 - Preparing tmp tables in destination started for 3 streams 2022-05-13 15:49:42 destination > 2022-05-13 15:49:42 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream BB_FB. schema: airbyte_gspread, tmp table name: _airbyte_tmp_rik_bb_fb 2022-05-13 15:49:43 source > available_sheets: ['CL - PPTO', 'CO - PPTO', 'MX - PPTO', 'REG - PPTO FEB', 'dolar', 'glosa', 'GG_MXCO', 'GG_CL', 'BB_FB', 'GA', 'BB_FB2', 'Hoja 48', 'Ajercicio', 'SupermetricsQueries', 'Weekly', 'Inversión Mar'] 2022-05-13 15:49:43 source > Row counts: {'CL - PPTO': 390, 'CO - PPTO': 314, 'MX - PPTO': 434, 'REG - PPTO FEB': 1033, 'dolar': 101, 'glosa': 1050, 'GG_MXCO': 12000, 'GG_CL': 4080, 'BB_FB': 15395, 'GA': 32719, 'BB_FB2': 1000, 'Hoja 48': 3002, 'Ajercicio': 1000, 'SupermetricsQueries': 996, 'Weekly': 1002, 'Inversión Mar': 1002} 2022-05-13 15:49:43 source > Syncing sheet BB_FB 2022-05-13 15:49:43 source > Fetching range BB_FB!2:202 2022-05-13 15:49:43 destination > 2022-05-13 15:49:43 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream GG_CL. schema: airbyte_gspread, tmp table name: _airbyte_tmp_izj_gg_cl 2022-05-13 15:49:43 source > Fetching range BB_FB!203:403 2022-05-13 15:49:43 destination > 2022-05-13 15:49:43 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream GG_MXCO. schema: airbyte_gspread, tmp table name: _airbyte_tmp_lpg_gg_mxco 2022-05-13 15:49:44 source > Fetching range BB_FB!404:604 2022-05-13 15:49:44 destination > 2022-05-13 15:49:44 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):131 - Preparing tables in destination completed. 2022-05-13 15:49:44 source > Fetching range BB_FB!605:805 2022-05-13 15:49:44 source > Fetching range BB_FB!806:1006 2022-05-13 15:49:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 1000 2022-05-13 15:49:44 source > Fetching range BB_FB!1007:1207 2022-05-13 15:49:45 source > Fetching range BB_FB!1208:1408 2022-05-13 15:49:45 source > Fetching range BB_FB!1409:1609 2022-05-13 15:49:45 source > Fetching range BB_FB!1610:1810 2022-05-13 15:49:46 source > Fetching range BB_FB!1811:2011 2022-05-13 15:49:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 2000 2022-05-13 15:49:46 source > Fetching range BB_FB!2012:2212 2022-05-13 15:49:46 source > Fetching range BB_FB!2213:2413 2022-05-13 15:49:46 source > Fetching range BB_FB!2414:2614 2022-05-13 15:49:47 source > Fetching range BB_FB!2615:2815 2022-05-13 15:49:47 source > Fetching range BB_FB!2816:3016 2022-05-13 15:49:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 3000 2022-05-13 15:49:47 source > Fetching range BB_FB!3017:3217 2022-05-13 15:49:48 source > Fetching range BB_FB!3218:3418 2022-05-13 15:49:48 source > Fetching range BB_FB!3419:3619 2022-05-13 15:49:48 source > Fetching range BB_FB!3620:3820 2022-05-13 15:49:49 source > Fetching range BB_FB!3821:4021 2022-05-13 15:49:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 4000 2022-05-13 15:49:49 source > Fetching range BB_FB!4022:4222 2022-05-13 15:49:49 source > Fetching range BB_FB!4223:4423 2022-05-13 15:49:49 source > Fetching range BB_FB!4424:4624 2022-05-13 15:49:50 source > Fetching range BB_FB!4625:4825 2022-05-13 15:49:50 source > Fetching range BB_FB!4826:5026 2022-05-13 15:49:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 5000 2022-05-13 15:49:50 source > Fetching range BB_FB!5027:5227 2022-05-13 15:49:50 source > Fetching range BB_FB!5228:5428 2022-05-13 15:49:51 source > Fetching range BB_FB!5429:5629 2022-05-13 15:49:51 source > Fetching range BB_FB!5630:5830 2022-05-13 15:49:51 source > Fetching range BB_FB!5831:6031 2022-05-13 15:49:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 6000 2022-05-13 15:49:52 source > Fetching range BB_FB!6032:6232 2022-05-13 15:49:52 source > Fetching range BB_FB!6233:6433 2022-05-13 15:49:52 source > Fetching range BB_FB!6434:6634 2022-05-13 15:49:52 source > Fetching range BB_FB!6635:6835 2022-05-13 15:49:53 source > Fetching range BB_FB!6836:7036 2022-05-13 15:49:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 7000 2022-05-13 15:49:53 source > Fetching range BB_FB!7037:7237 2022-05-13 15:49:53 source > Fetching range BB_FB!7238:7438 2022-05-13 15:49:54 source > Fetching range BB_FB!7439:7639 2022-05-13 15:49:54 source > Fetching range BB_FB!7640:7840 2022-05-13 15:49:54 source > Fetching range BB_FB!7841:8041 2022-05-13 15:49:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 8000 2022-05-13 15:49:54 source > Fetching range BB_FB!8042:8242 2022-05-13 15:49:55 source > Fetching range BB_FB!8243:8443 2022-05-13 15:49:55 source > Fetching range BB_FB!8444:8644 2022-05-13 15:49:55 source > Fetching range BB_FB!8645:8845 2022-05-13 15:49:56 source > Fetching range BB_FB!8846:9046 2022-05-13 15:49:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 9000 2022-05-13 15:49:56 source > Fetching range BB_FB!9047:9247 2022-05-13 15:49:56 source > Fetching range BB_FB!9248:9448 2022-05-13 15:49:56 source > Fetching range BB_FB!9449:9649 2022-05-13 15:49:56 source > Fetching range BB_FB!9650:9850 2022-05-13 15:49:57 source > Fetching range BB_FB!9851:10051 2022-05-13 15:49:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 10000 2022-05-13 15:49:57 source > Fetching range BB_FB!10052:10252 2022-05-13 15:49:57 source > Fetching range BB_FB!10253:10453 2022-05-13 15:49:57 source > Fetching range BB_FB!10454:10654 2022-05-13 15:49:58 source > Fetching range BB_FB!10655:10855 2022-05-13 15:49:58 source > Fetching range BB_FB!10856:11056 2022-05-13 15:49:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 11000 2022-05-13 15:49:58 source > Fetching range BB_FB!11057:11257 2022-05-13 15:49:59 source > Fetching range BB_FB!11258:11458 2022-05-13 15:49:59 source > Fetching range BB_FB!11459:11659 2022-05-13 15:49:59 source > Fetching range BB_FB!11660:11860 2022-05-13 15:49:59 source > Fetching range BB_FB!11861:12061 2022-05-13 15:50:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 12000 2022-05-13 15:50:00 source > Fetching range BB_FB!12062:12262 2022-05-13 15:50:00 source > Fetching range BB_FB!12263:12463 2022-05-13 15:50:00 source > Fetching range BB_FB!12464:12664 2022-05-13 15:50:00 source > Fetching range BB_FB!12665:12865 2022-05-13 15:50:00 source > Backing off get_values(...) for 0.9s (googleapiclient.errors.HttpError: ) 2022-05-13 15:50:01 source > Backing off get_values(...) for 1.5s (googleapiclient.errors.HttpError: ) 2022-05-13 15:50:03 source > Backing off get_values(...) for 1.6s (googleapiclient.errors.HttpError: ) 2022-05-13 15:50:04 source > Backing off get_values(...) for 5.6s (googleapiclient.errors.HttpError: ) 2022-05-13 15:50:10 source > Backing off get_values(...) for 6.7s (googleapiclient.errors.HttpError: ) 2022-05-13 15:50:17 source > Backing off get_values(...) for 7.1s (googleapiclient.errors.HttpError: ) 2022-05-13 15:50:24 source > Backing off get_values(...) for 51.9s (googleapiclient.errors.HttpError: ) 2022-05-13 15:51:16 source > Backing off get_values(...) for 44.2s (googleapiclient.errors.HttpError: ) 2022-05-13 15:52:01 source > Fetching range BB_FB!12866:13066 2022-05-13 15:52:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 13000 2022-05-13 15:52:01 source > Fetching range BB_FB!13067:13267 2022-05-13 15:52:01 source > Fetching range BB_FB!13268:13468 2022-05-13 15:52:02 source > Fetching range BB_FB!13469:13669 2022-05-13 15:52:02 source > Fetching range BB_FB!13670:13870 2022-05-13 15:52:02 source > Fetching range BB_FB!13871:14071 2022-05-13 15:52:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 14000 2022-05-13 15:52:02 source > Fetching range BB_FB!14072:14272 2022-05-13 15:52:03 source > Fetching range BB_FB!14273:14473 2022-05-13 15:52:03 source > Fetching range BB_FB!14474:14674 2022-05-13 15:52:03 source > Fetching range BB_FB!14675:14875 2022-05-13 15:52:03 source > Fetching range BB_FB!14876:15076 2022-05-13 15:52:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 15000 2022-05-13 15:52:04 source > Fetching range BB_FB!15077:15277 2022-05-13 15:52:04 source > Fetching range BB_FB!15278:15478 2022-05-13 15:52:04 source > Syncing sheet GG_CL 2022-05-13 15:52:04 source > Fetching range GG_CL!2:202 2022-05-13 15:52:05 source > Fetching range GG_CL!203:403 2022-05-13 15:52:05 source > Fetching range GG_CL!404:604 2022-05-13 15:52:05 source > Fetching range GG_CL!605:805 2022-05-13 15:52:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 16000 2022-05-13 15:52:05 source > Fetching range GG_CL!806:1006 2022-05-13 15:52:06 source > Fetching range GG_CL!1007:1207 2022-05-13 15:52:06 source > Fetching range GG_CL!1208:1408 2022-05-13 15:52:06 source > Fetching range GG_CL!1409:1609 2022-05-13 15:52:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 17000 2022-05-13 15:52:07 source > Fetching range GG_CL!1610:1810 2022-05-13 15:52:07 source > Fetching range GG_CL!1811:2011 2022-05-13 15:52:07 source > Fetching range GG_CL!2012:2212 2022-05-13 15:52:07 source > Fetching range GG_CL!2213:2413 2022-05-13 15:52:08 source > Fetching range GG_CL!2414:2614 2022-05-13 15:52:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 18000 2022-05-13 15:52:08 source > Fetching range GG_CL!2615:2815 2022-05-13 15:52:08 source > Fetching range GG_CL!2816:3016 2022-05-13 15:52:08 source > Fetching range GG_CL!3017:3217 2022-05-13 15:52:09 source > Syncing sheet GG_MXCO 2022-05-13 15:52:09 source > Fetching range GG_MXCO!2:202 2022-05-13 15:52:09 source > Fetching range GG_MXCO!203:403 2022-05-13 15:52:09 source > Fetching range GG_MXCO!404:604 2022-05-13 15:52:09 source > Fetching range GG_MXCO!605:805 2022-05-13 15:52:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 19000 2022-05-13 15:52:10 source > Fetching range GG_MXCO!806:1006 2022-05-13 15:52:10 source > Fetching range GG_MXCO!1007:1207 2022-05-13 15:52:10 source > Fetching range GG_MXCO!1208:1408 2022-05-13 15:52:10 source > Fetching range GG_MXCO!1409:1609 2022-05-13 15:52:11 source > Fetching range GG_MXCO!1610:1810 2022-05-13 15:52:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 20000 2022-05-13 15:52:11 source > Fetching range GG_MXCO!1811:2011 2022-05-13 15:52:11 source > Fetching range GG_MXCO!2012:2212 2022-05-13 15:52:11 source > Fetching range GG_MXCO!2213:2413 2022-05-13 15:52:12 source > Fetching range GG_MXCO!2414:2614 2022-05-13 15:52:12 source > Fetching range GG_MXCO!2615:2815 2022-05-13 15:52:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 21000 2022-05-13 15:52:12 source > Fetching range GG_MXCO!2816:3016 2022-05-13 15:52:12 source > Fetching range GG_MXCO!3017:3217 2022-05-13 15:52:13 source > Fetching range GG_MXCO!3218:3418 2022-05-13 15:52:13 source > Fetching range GG_MXCO!3419:3619 2022-05-13 15:52:13 source > Fetching range GG_MXCO!3620:3820 2022-05-13 15:52:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 22000 2022-05-13 15:52:14 source > Fetching range GG_MXCO!3821:4021 2022-05-13 15:52:14 source > Fetching range GG_MXCO!4022:4222 2022-05-13 15:52:14 source > Fetching range GG_MXCO!4223:4423 2022-05-13 15:52:14 source > Fetching range GG_MXCO!4424:4624 2022-05-13 15:52:15 source > Fetching range GG_MXCO!4625:4825 2022-05-13 15:52:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 23000 2022-05-13 15:52:15 source > Fetching range GG_MXCO!4826:5026 2022-05-13 15:52:15 source > Fetching range GG_MXCO!5027:5227 2022-05-13 15:52:15 source > Fetching range GG_MXCO!5228:5428 2022-05-13 15:52:16 source > Fetching range GG_MXCO!5429:5629 2022-05-13 15:52:16 source > Fetching range GG_MXCO!5630:5830 2022-05-13 15:52:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 24000 2022-05-13 15:52:16 source > Fetching range GG_MXCO!5831:6031 2022-05-13 15:52:16 source > Fetching range GG_MXCO!6032:6232 2022-05-13 15:52:17 source > Fetching range GG_MXCO!6233:6433 2022-05-13 15:52:17 source > Fetching range GG_MXCO!6434:6634 2022-05-13 15:52:17 source > Fetching range GG_MXCO!6635:6835 2022-05-13 15:52:17 source > Finished syncing spreadsheet 1pw6KVU3nw1WqWGRxqgvH13ItoHqaoZQKwkkjKJXVMnc 2022-05-13 15:52:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):304 - Total records read: 24893 2022-05-13 15:52:18 INFO i.a.w.DefaultReplicationWorker(run):162 - One of source or destination thread complete. Waiting on the other. 2022-05-13 15:52:18 destination > 2022-05-13 15:52:18 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded. 2022-05-13 15:52:18 destination > 2022-05-13 15:52:18 INFO i.a.i.d.b.BufferedStreamConsumer(close):217 - executing on success close procedure. 2022-05-13 15:52:18 destination > 2022-05-13 15:52:18 INFO i.a.i.d.b.BufferedStreamConsumer(flushQueueToDestination):181 - Flushing buffer: 24977726 bytes 2022-05-13 15:52:18 destination > 2022-05-13 15:52:18 INFO i.a.i.d.b.BufferedStreamConsumer(lambda$flushQueueToDestination$1):185 - Flushing BB_FB: 15394 records 2022-05-13 15:52:18 destination > 2022-05-13 15:52:18 INFO i.a.i.d.r.RedshiftSqlOperations(insertRecordsInternal):43 - actual size of batch: 15394 2022-05-13 15:52:23 destination > 2022-05-13 15:52:23 INFO i.a.i.d.b.BufferedStreamConsumer(lambda$flushQueueToDestination$1):185 - Flushing GG_CL: 2894 records 2022-05-13 15:52:23 destination > 2022-05-13 15:52:23 INFO i.a.i.d.r.RedshiftSqlOperations(insertRecordsInternal):43 - actual size of batch: 2894 2022-05-13 15:52:24 destination > 2022-05-13 15:52:24 INFO i.a.i.d.b.BufferedStreamConsumer(lambda$flushQueueToDestination$1):185 - Flushing GG_MXCO: 6605 records 2022-05-13 15:52:24 destination > 2022-05-13 15:52:24 INFO i.a.i.d.r.RedshiftSqlOperations(insertRecordsInternal):43 - actual size of batch: 6605 2022-05-13 15:52:26 destination > 2022-05-13 15:52:26 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):160 - Finalizing tables in destination started for 3 streams 2022-05-13 15:52:26 destination > 2022-05-13 15:52:26 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream BB_FB. schema airbyte_gspread, tmp table _airbyte_tmp_rik_bb_fb, final table _airbyte_raw_bb_fb 2022-05-13 15:52:27 destination > 2022-05-13 15:52:27 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream GG_CL. schema airbyte_gspread, tmp table _airbyte_tmp_izj_gg_cl, final table _airbyte_raw_gg_cl 2022-05-13 15:52:27 destination > 2022-05-13 15:52:27 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream GG_MXCO. schema airbyte_gspread, tmp table _airbyte_tmp_lpg_gg_mxco, final table _airbyte_raw_gg_mxco 2022-05-13 15:52:27 destination > 2022-05-13 15:52:27 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):178 - Executing finalization of tables. 2022-05-13 15:52:27 destination > 2022-05-13 15:52:27 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):180 - Finalizing tables in destination completed. 2022-05-13 15:52:27 destination > 2022-05-13 15:52:27 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):183 - Cleaning tmp tables in destination started for 3 streams 2022-05-13 15:52:27 destination > 2022-05-13 15:52:27 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream BB_FB. schema airbyte_gspread, tmp table name: _airbyte_tmp_rik_bb_fb 2022-05-13 15:52:27 destination > 2022-05-13 15:52:27 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream GG_CL. schema airbyte_gspread, tmp table name: _airbyte_tmp_izj_gg_cl 2022-05-13 15:52:27 destination > 2022-05-13 15:52:27 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream GG_MXCO. schema airbyte_gspread, tmp table name: _airbyte_tmp_lpg_gg_mxco 2022-05-13 15:52:27 destination > 2022-05-13 15:52:27 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):192 - Cleaning tmp tables in destination completed. 2022-05-13 15:52:27 destination > 2022-05-13 15:52:27 INFO i.a.i.b.IntegrationRunner(runInternal):169 - Completed integration: io.airbyte.integrations.destination.redshift.RedshiftDestination 2022-05-13 15:52:27 destination > 2022-05-13 15:52:27 INFO i.a.i.d.r.RedshiftDestination(main):79 - completed destination: class io.airbyte.integrations.destination.redshift.RedshiftDestination 2022-05-13 15:52:28 INFO i.a.w.DefaultReplicationWorker(run):164 - Source and destination threads complete. 2022-05-13 15:52:28 INFO i.a.w.DefaultReplicationWorker(run):227 - sync summary: io.airbyte.config.ReplicationAttemptSummary@50caac2b[status=completed,recordsSynced=24893,bytesSynced=6258279,startTime=1652456979054,endTime=1652457148323,totalStats=io.airbyte.config.SyncStats@5c443dba[recordsEmitted=24893,bytesEmitted=6258279,stateMessagesEmitted=0,recordsCommitted=24893],streamStats=[io.airbyte.config.StreamSyncStats@144752a8[streamName=GG_CL,stats=io.airbyte.config.SyncStats@5a000e43[recordsEmitted=2894,bytesEmitted=1001483,stateMessagesEmitted=,recordsCommitted=2894]], io.airbyte.config.StreamSyncStats@5f2e5adc[streamName=GG_MXCO,stats=io.airbyte.config.SyncStats@22fa056e[recordsEmitted=6605,bytesEmitted=2173676,stateMessagesEmitted=,recordsCommitted=6605]], io.airbyte.config.StreamSyncStats@c86d18b[streamName=BB_FB,stats=io.airbyte.config.SyncStats@56aeb44e[recordsEmitted=15394,bytesEmitted=3083120,stateMessagesEmitted=,recordsCommitted=15394]]]] 2022-05-13 15:52:28 INFO i.a.w.DefaultReplicationWorker(run):249 - Source did not output any state messages 2022-05-13 15:52:28 WARN i.a.w.DefaultReplicationWorker(run):257 - State capture: No new state, falling back on input state: io.airbyte.config.State@7bfbfcfd[state={}] 2022-05-13 15:52:28 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2022-05-13 15:52:28 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$1):147 - sync summary: io.airbyte.config.StandardSyncOutput@5d4a0b87[standardSyncSummary=io.airbyte.config.StandardSyncSummary@43d69b[status=completed,recordsSynced=24893,bytesSynced=6258279,startTime=1652456979054,endTime=1652457148323,totalStats=io.airbyte.config.SyncStats@5c443dba[recordsEmitted=24893,bytesEmitted=6258279,stateMessagesEmitted=0,recordsCommitted=24893],streamStats=[io.airbyte.config.StreamSyncStats@144752a8[streamName=GG_CL,stats=io.airbyte.config.SyncStats@5a000e43[recordsEmitted=2894,bytesEmitted=1001483,stateMessagesEmitted=,recordsCommitted=2894]], io.airbyte.config.StreamSyncStats@5f2e5adc[streamName=GG_MXCO,stats=io.airbyte.config.SyncStats@22fa056e[recordsEmitted=6605,bytesEmitted=2173676,stateMessagesEmitted=,recordsCommitted=6605]], io.airbyte.config.StreamSyncStats@c86d18b[streamName=BB_FB,stats=io.airbyte.config.SyncStats@56aeb44e[recordsEmitted=15394,bytesEmitted=3083120,stateMessagesEmitted=,recordsCommitted=15394]]]],state=io.airbyte.config.State@7bfbfcfd[state={}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@25db23b4[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@51175f53[stream=io.airbyte.protocol.models.AirbyteStream@5c8c60c5[name=BB_FB,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"Cost":{"type":"string"},"Date":{"type":"string"},"Impressions":{"type":"string"},"Link clicks":{"type":"string"},"Campaign name":{"type":"string"},"Ad set end time":{"type":"string"},"Ad set start time":{"type":"string"},"Ad set daily budget":{"type":"string"},"Ad set lifetime budget":{"type":"string"}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=airbyte_gspread,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@42e592c1[stream=io.airbyte.protocol.models.AirbyteStream@3edfcfaa[name=GG_CL,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"Cost":{"type":"string"},"Date":{"type":"string"},"Clicks":{"type":"string"},"End date":{"type":"string"},"Start date":{"type":"string"},"Impressions":{"type":"string"},"Daily budget":{"type":"string"},"Campaign name":{"type":"string"},"Impression share":{"type":"string"},"Search rank lost top impression share":{"type":"string"},"Search budget lost top impression share":{"type":"string"}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=airbyte_gspread,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@5559e2e5[stream=io.airbyte.protocol.models.AirbyteStream@6aec2ac3[name=GG_MXCO,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"Cost":{"type":"string"},"Date":{"type":"string"},"Clicks":{"type":"string"},"End date":{"type":"string"},"Start date":{"type":"string"},"Impressions":{"type":"string"},"Daily budget":{"type":"string"},"Campaign name":{"type":"string"},"Impression share":{"type":"string"},"Search rank lost top impression share":{"type":"string"},"Search budget lost top impression share":{"type":"string"}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=airbyte_gspread,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}]],additionalProperties={}],failures=[]] 2022-05-13 15:52:28 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating... 2022-05-13 15:52:28 INFO i.a.c.p.ConfigRepository(updateConnectionState):594 - Updating connection 9c14bb98-018a-424f-8833-d93e00d7aefd state: io.airbyte.config.State@5ec76fd3[state={}] 2022-05-13 15:52:28 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/379/0/logs.log 2022-05-13 15:52:28 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.51-alpha 2022-05-13 15:52:28 INFO i.a.w.DefaultNormalizationWorker(run):46 - Running normalization. 2022-05-13 15:52:28 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):122 - Running with normalization version: airbyte/normalization:0.1.69 2022-05-13 15:52:28 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/normalization:0.1.69 exists... 2022-05-13 15:52:28 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/normalization:0.1.69 was found locally. 2022-05-13 15:52:28 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 379 2022-05-13 15:52:28 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/379/0/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.35.51-alpha airbyte/normalization:0.1.69 run --integration-type redshift --config destination_config.json --catalog destination_catalog.json 2022-05-13 15:52:28 normalization > Running: transform-config --config destination_config.json --integration-type redshift --out /data/379/0/normalize 2022-05-13 15:52:29 normalization > Namespace(config='destination_config.json', integration_type=, out='/data/379/0/normalize') 2022-05-13 15:52:29 normalization > transform_redshift 2022-05-13 15:52:29 normalization > Running: transform-catalog --integration-type redshift --profile-config-dir /data/379/0/normalize --catalog destination_catalog.json --out /data/379/0/normalize/models/generated/ --json-column _airbyte_data 2022-05-13 15:52:29 normalization > Processing destination_catalog.json... 2022-05-13 15:52:29 normalization > Generating airbyte_ctes/airbyte_gspread/bb_fb_ab1.sql from BB_FB 2022-05-13 15:52:29 normalization > Generating airbyte_ctes/airbyte_gspread/bb_fb_ab2.sql from BB_FB 2022-05-13 15:52:29 normalization > Generating airbyte_ctes/airbyte_gspread/bb_fb_ab3.sql from BB_FB 2022-05-13 15:52:29 normalization > Generating airbyte_tables/airbyte_gspread/bb_fb.sql from BB_FB 2022-05-13 15:52:29 normalization > Generating airbyte_ctes/airbyte_gspread/gg_cl_ab1.sql from GG_CL 2022-05-13 15:52:29 normalization > Generating airbyte_ctes/airbyte_gspread/gg_cl_ab2.sql from GG_CL 2022-05-13 15:52:29 normalization > Generating airbyte_ctes/airbyte_gspread/gg_cl_ab3.sql from GG_CL 2022-05-13 15:52:29 normalization > Generating airbyte_tables/airbyte_gspread/gg_cl.sql from GG_CL 2022-05-13 15:52:29 normalization > Generating airbyte_ctes/airbyte_gspread/gg_mxco_ab1.sql from GG_MXCO 2022-05-13 15:52:29 normalization > Generating airbyte_ctes/airbyte_gspread/gg_mxco_ab2.sql from GG_MXCO 2022-05-13 15:52:29 normalization > Generating airbyte_ctes/airbyte_gspread/gg_mxco_ab3.sql from GG_MXCO 2022-05-13 15:52:29 normalization > Generating airbyte_tables/airbyte_gspread/gg_mxco.sql from GG_MXCO 2022-05-13 15:52:29 normalization > detected no config file for ssh, assuming ssh is off. 2022-05-13 15:52:31 normalization > Running with dbt=0.21.1 2022-05-13 15:52:31 normalization > Unable to do partial parsing because ../build/partial_parse.msgpack not found 2022-05-13 15:52:32 normalization > [WARNING]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources. 2022-05-13 15:52:32 normalization > There are 2 unused configuration paths: 2022-05-13 15:52:32 normalization > - models.airbyte_utils.generated.airbyte_views 2022-05-13 15:52:32 normalization > - models.airbyte_utils.generated.airbyte_incremental 2022-05-13 15:52:32 normalization > 2022-05-13 15:52:32 normalization > Found 12 models, 0 tests, 0 snapshots, 0 analyses, 520 macros, 0 operations, 0 seed files, 3 sources, 0 exposures 2022-05-13 15:52:32 normalization > 2022-05-13 15:52:33 normalization > 15:52:33 | Concurrency: 4 threads (target='prod') 2022-05-13 15:52:33 normalization > 15:52:33 | 2022-05-13 15:52:33 normalization > 15:52:33 | 1 of 3 START table model airbyte_gspread.bb_fb............................................................... [RUN] 2022-05-13 15:52:33 normalization > 15:52:33 | 2 of 3 START table model airbyte_gspread.gg_cl............................................................... [RUN] 2022-05-13 15:52:33 normalization > 15:52:33 | 3 of 3 START table model airbyte_gspread.gg_mxco............................................................. [RUN] 2022-05-13 15:52:34 normalization > 15:52:34 | 1 of 3 ERROR creating table model airbyte_gspread.bb_fb...................................................... [ERROR in 0.20s] 2022-05-13 15:52:34 normalization > 15:52:34 | 2 of 3 ERROR creating table model airbyte_gspread.gg_cl...................................................... [ERROR in 0.25s] 2022-05-13 15:52:34 normalization > 15:52:34 | 3 of 3 ERROR creating table model airbyte_gspread.gg_mxco.................................................... [ERROR in 0.36s] 2022-05-13 15:52:34 normalization > 15:52:34 | 2022-05-13 15:52:34 normalization > 15:52:34 | Finished running 3 table models in 1.46s. 2022-05-13 15:52:34 normalization > 2022-05-13 15:52:34 normalization > Completed with 3 errors and 0 warnings: 2022-05-13 15:52:34 normalization > 2022-05-13 15:52:34 normalization > Database Error in model bb_fb (models/generated/airbyte_tables/airbyte_gspread/bb_fb.sql) 2022-05-13 15:52:34 normalization > function json_extract_path_text(super, "unknown", boolean) does not exist 2022-05-13 15:52:34 normalization > HINT: No function matches the given name and argument types. You may need to add explicit type casts. 2022-05-13 15:52:34 normalization > compiled SQL at ../build/run/airbyte_utils/models/generated/airbyte_tables/airbyte_gspread/bb_fb.sql 2022-05-13 15:52:34 normalization > 2022-05-13 15:52:34 normalization > Database Error in model gg_cl (models/generated/airbyte_tables/airbyte_gspread/gg_cl.sql) 2022-05-13 15:52:34 normalization > function json_extract_path_text(super, "unknown", boolean) does not exist 2022-05-13 15:52:34 normalization > HINT: No function matches the given name and argument types. You may need to add explicit type casts. 2022-05-13 15:52:34 normalization > compiled SQL at ../build/run/airbyte_utils/models/generated/airbyte_tables/airbyte_gspread/gg_cl.sql 2022-05-13 15:52:34 normalization > 2022-05-13 15:52:34 normalization > Database Error in model gg_mxco (models/generated/airbyte_tables/airbyte_gspread/gg_mxco.sql) 2022-05-13 15:52:34 normalization > function json_extract_path_text(super, "unknown", boolean) does not exist 2022-05-13 15:52:34 normalization > HINT: No function matches the given name and argument types. You may need to add explicit type casts. 2022-05-13 15:52:34 normalization > compiled SQL at ../build/run/airbyte_utils/models/generated/airbyte_tables/airbyte_gspread/gg_mxco.sql 2022-05-13 15:52:34 normalization > 2022-05-13 15:52:34 normalization > Done. PASS=0 WARN=0 ERROR=3 SKIP=0 TOTAL=3 2022-05-13 15:52:34 normalization > 2022-05-13 15:52:34 normalization > Diagnosing dbt debug to check if destination is available for dbt and well configured (1): 2022-05-13 15:52:34 normalization > 2022-05-13 15:52:36 normalization > Running with dbt=0.21.1 2022-05-13 15:52:36 normalization > dbt version: 0.21.1 2022-05-13 15:52:36 normalization > python version: 3.8.12 2022-05-13 15:52:36 normalization > python path: /usr/local/bin/python 2022-05-13 15:52:36 normalization > os info: Linux-5.11.0-1022-aws-x86_64-with-glibc2.2.5 2022-05-13 15:52:36 normalization > Using profiles.yml file at /data/379/0/normalize/profiles.yml 2022-05-13 15:52:36 normalization > Using dbt_project.yml file at /data/379/0/normalize/dbt_project.yml 2022-05-13 15:52:36 normalization > 2022-05-13 15:52:36 normalization > Configuration: 2022-05-13 15:52:36 normalization > profiles.yml file [OK found and valid] 2022-05-13 15:52:36 normalization > dbt_project.yml file [OK found and valid] 2022-05-13 15:52:36 normalization > 2022-05-13 15:52:36 normalization > Required dependencies: 2022-05-13 15:52:36 normalization > - git [OK found] 2022-05-13 15:52:36 normalization > 2022-05-13 15:52:36 normalization > Connection: 2022-05-13 15:52:36 normalization > host: houm-dw.cy3ew1fkrkqj.us-east-1.redshift.amazonaws.com 2022-05-13 15:52:36 normalization > port: 5439 2022-05-13 15:52:36 normalization > user: houm-airflow-root 2022-05-13 15:52:36 normalization > database: houmdw_prod 2022-05-13 15:52:36 normalization > schema: nps_raw_stage 2022-05-13 15:52:36 normalization > search_path: None 2022-05-13 15:52:36 normalization > keepalives_idle: 240 2022-05-13 15:52:36 normalization > sslmode: None 2022-05-13 15:52:36 normalization > method: database 2022-05-13 15:52:36 normalization > cluster_id: None 2022-05-13 15:52:36 normalization > iam_profile: None 2022-05-13 15:52:36 normalization > iam_duration_seconds: 900 2022-05-13 15:52:36 normalization > Connection test: [OK connection ok] 2022-05-13 15:52:36 normalization > 2022-05-13 15:52:36 normalization > All checks passed! 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:37 normalization > Forward dbt output logs to diagnose/debug errors (0): 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.214188 (MainThread): Running with dbt=0.21.1 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.485401 (MainThread): running dbt with arguments Namespace(cls=, debug=False, defer=None, exclude=None, fail_fast=False, full_refresh=False, log_cache_events=False, log_format='default', partial_parse=None, profile=None, profiles_dir='/data/379/0/normalize', project_dir='/data/379/0/normalize', record_timing_info=None, rpc_method='run', select=None, selector_name=None, single_threaded=False, state=None, strict=False, target=None, test_new_parser=False, threads=None, use_cache=True, use_colors=None, use_experimental_parser=False, vars='{}', version_check=True, warn_error=False, which='run', write_json=True) 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.485992 (MainThread): Tracking: do not track 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.510563 (MainThread): Unable to do partial parsing because ../build/partial_parse.msgpack not found 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.533647 (MainThread): Parsing macros/incremental.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.541195 (MainThread): Parsing macros/get_custom_schema.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.541949 (MainThread): Parsing macros/star_intersect.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.548325 (MainThread): Parsing macros/should_full_refresh.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.554557 (MainThread): Parsing macros/schema_tests/equality.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.561701 (MainThread): Parsing macros/schema_tests/equal_rowcount.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.563073 (MainThread): Parsing macros/cross_db_utils/json_operations.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.618870 (MainThread): Parsing macros/cross_db_utils/concat.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.621163 (MainThread): Parsing macros/cross_db_utils/type_conversions.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.626961 (MainThread): Parsing macros/cross_db_utils/hash.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.627651 (MainThread): Parsing macros/cross_db_utils/current_timestamp.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.628469 (MainThread): Parsing macros/cross_db_utils/surrogate_key.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.630579 (MainThread): Parsing macros/cross_db_utils/array.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.645228 (MainThread): Parsing macros/cross_db_utils/except.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.646216 (MainThread): Parsing macros/cross_db_utils/quote.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.647897 (MainThread): Parsing macros/cross_db_utils/datatypes.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.658247 (MainThread): Parsing macros/relations.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.658901 (MainThread): Parsing macros/catalog.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.672012 (MainThread): Parsing macros/adapters.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.701577 (MainThread): Parsing macros/materializations/snapshot_merge.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.702433 (MainThread): Parsing macros/relations.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.703832 (MainThread): Parsing macros/catalog.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.706140 (MainThread): Parsing macros/adapters.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.729890 (MainThread): Parsing macros/materializations/snapshot_merge.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.731876 (MainThread): Parsing macros/core.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.735905 (MainThread): Parsing macros/materializations/helpers.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.746573 (MainThread): Parsing macros/materializations/test.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.754554 (MainThread): Parsing macros/materializations/common/merge.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.769428 (MainThread): Parsing macros/materializations/snapshot/snapshot_merge.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.771352 (MainThread): Parsing macros/materializations/snapshot/snapshot.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.804482 (MainThread): Parsing macros/materializations/snapshot/strategies.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.823172 (MainThread): Parsing macros/materializations/view/view.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.830843 (MainThread): Parsing macros/materializations/view/create_or_replace_view.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.835125 (MainThread): Parsing macros/materializations/incremental/incremental.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.847130 (MainThread): Parsing macros/materializations/incremental/on_schema_change.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.867902 (MainThread): Parsing macros/materializations/incremental/helpers.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.869930 (MainThread): Parsing macros/materializations/table/table.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.877726 (MainThread): Parsing macros/materializations/seed/seed.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.902230 (MainThread): Parsing macros/schema_tests/accepted_values.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.904886 (MainThread): Parsing macros/schema_tests/relationships.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.906765 (MainThread): Parsing macros/schema_tests/unique.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.908317 (MainThread): Parsing macros/schema_tests/not_null.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.909545 (MainThread): Parsing macros/etc/get_custom_alias.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.911180 (MainThread): Parsing macros/etc/get_custom_schema.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.913814 (MainThread): Parsing macros/etc/datetime.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.923401 (MainThread): Parsing macros/etc/get_custom_database.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.925147 (MainThread): Parsing macros/etc/where_subquery.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.927156 (MainThread): Parsing macros/etc/is_incremental.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.928781 (MainThread): Parsing macros/etc/query.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.929812 (MainThread): Parsing macros/adapters/common.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:31.988195 (MainThread): Parsing macros/materializations/insert_by_period_materialization.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.014888 (MainThread): Parsing macros/jinja_helpers/log_info.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.016318 (MainThread): Parsing macros/jinja_helpers/pretty_log_format.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.017544 (MainThread): Parsing macros/jinja_helpers/pretty_time.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.018885 (MainThread): Parsing macros/jinja_helpers/slugify.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.020175 (MainThread): Parsing macros/schema_tests/fewer_rows_than.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.021949 (MainThread): Parsing macros/schema_tests/relationships_where.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.024354 (MainThread): Parsing macros/schema_tests/sequential_values.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.027233 (MainThread): Parsing macros/schema_tests/expression_is_true.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.029198 (MainThread): Parsing macros/schema_tests/unique_combination_of_columns.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.032310 (MainThread): Parsing macros/schema_tests/test_unique_where.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.033918 (MainThread): Parsing macros/schema_tests/test_not_null_where.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.035547 (MainThread): Parsing macros/schema_tests/cardinality_equality.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.038013 (MainThread): Parsing macros/schema_tests/equality.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.042531 (MainThread): Parsing macros/schema_tests/recency.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.044552 (MainThread): Parsing macros/schema_tests/at_least_one.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.045964 (MainThread): Parsing macros/schema_tests/accepted_range.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.048755 (MainThread): Parsing macros/schema_tests/not_null_proportion.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.051230 (MainThread): Parsing macros/schema_tests/equal_rowcount.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.053106 (MainThread): Parsing macros/schema_tests/mutually_exclusive_ranges.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.062748 (MainThread): Parsing macros/schema_tests/not_constant.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.064155 (MainThread): Parsing macros/schema_tests/not_accepted_values.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.066497 (MainThread): Parsing macros/sql/pivot.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.070890 (MainThread): Parsing macros/sql/star.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.074905 (MainThread): Parsing macros/sql/get_relations_by_prefix.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.078600 (MainThread): Parsing macros/sql/get_column_values.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.083694 (MainThread): Parsing macros/sql/union.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.092965 (MainThread): Parsing macros/sql/date_spine.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.097958 (MainThread): Parsing macros/sql/surrogate_key.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.101730 (MainThread): Parsing macros/sql/groupby.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.103214 (MainThread): Parsing macros/sql/nullcheck.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.105045 (MainThread): Parsing macros/sql/haversine_distance.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.111462 (MainThread): Parsing macros/sql/nullcheck_table.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.113236 (MainThread): Parsing macros/sql/get_tables_by_prefix_sql.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.115118 (MainThread): Parsing macros/sql/get_relations_by_pattern.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.119055 (MainThread): Parsing macros/sql/unpivot.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.128017 (MainThread): Parsing macros/sql/get_query_results_as_dict.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.130765 (MainThread): Parsing macros/sql/generate_series.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.135593 (MainThread): Parsing macros/sql/safe_add.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.137424 (MainThread): Parsing macros/sql/get_tables_by_pattern_sql.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.144334 (MainThread): Parsing macros/web/get_url_parameter.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.146155 (MainThread): Parsing macros/web/get_url_host.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.148112 (MainThread): Parsing macros/web/get_url_path.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.151092 (MainThread): Parsing macros/cross_db_utils/cast_bool_to_text.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.152614 (MainThread): Parsing macros/cross_db_utils/width_bucket.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.158147 (MainThread): Parsing macros/cross_db_utils/concat.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.159227 (MainThread): Parsing macros/cross_db_utils/right.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.161609 (MainThread): Parsing macros/cross_db_utils/safe_cast.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.163646 (MainThread): Parsing macros/cross_db_utils/date_trunc.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.165227 (MainThread): Parsing macros/cross_db_utils/intersect.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.166418 (MainThread): Parsing macros/cross_db_utils/hash.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.168081 (MainThread): Parsing macros/cross_db_utils/current_timestamp.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.171696 (MainThread): Parsing macros/cross_db_utils/split_part.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.173654 (MainThread): Parsing macros/cross_db_utils/position.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.175371 (MainThread): Parsing macros/cross_db_utils/literal.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.176393 (MainThread): Parsing macros/cross_db_utils/except.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.177498 (MainThread): Parsing macros/cross_db_utils/replace.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.179032 (MainThread): Parsing macros/cross_db_utils/_is_relation.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.180246 (MainThread): Parsing macros/cross_db_utils/last_day.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.184016 (MainThread): Parsing macros/cross_db_utils/datediff.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.194689 (MainThread): Parsing macros/cross_db_utils/identifier.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.196501 (MainThread): Parsing macros/cross_db_utils/dateadd.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.199934 (MainThread): Parsing macros/cross_db_utils/length.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.201314 (MainThread): Parsing macros/cross_db_utils/datatypes.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.207699 (MainThread): Parsing macros/cross_db_utils/_is_ephemeral.sql 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.658839 (MainThread): Acquiring new redshift connection "model.airbyte_utils.bb_fb_ab1". 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.689656 (MainThread): 'soft_unicode' has been renamed to 'soft_str'. The old name will be removed in MarkupSafe 2.1. 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.695175 (MainThread): Acquiring new redshift connection "model.airbyte_utils.gg_mxco_ab2". 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.710793 (MainThread): 'soft_unicode' has been renamed to 'soft_str'. The old name will be removed in MarkupSafe 2.1. 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.713511 (MainThread): Acquiring new redshift connection "model.airbyte_utils.gg_mxco_ab1". 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.730985 (MainThread): 'soft_unicode' has been renamed to 'soft_str'. The old name will be removed in MarkupSafe 2.1. 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.732611 (MainThread): Acquiring new redshift connection "model.airbyte_utils.bb_fb_ab2". 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.745391 (MainThread): 'soft_unicode' has been renamed to 'soft_str'. The old name will be removed in MarkupSafe 2.1. 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.747037 (MainThread): Acquiring new redshift connection "model.airbyte_utils.gg_cl_ab3". 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.770212 (MainThread): 'soft_unicode' has been renamed to 'soft_str'. The old name will be removed in MarkupSafe 2.1. 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.771826 (MainThread): Acquiring new redshift connection "model.airbyte_utils.gg_cl_ab2". 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.785533 (MainThread): 'soft_unicode' has been renamed to 'soft_str'. The old name will be removed in MarkupSafe 2.1. 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.787160 (MainThread): Acquiring new redshift connection "model.airbyte_utils.bb_fb_ab3". 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.797417 (MainThread): 'soft_unicode' has been renamed to 'soft_str'. The old name will be removed in MarkupSafe 2.1. 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.799032 (MainThread): Acquiring new redshift connection "model.airbyte_utils.gg_mxco_ab3". 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.809033 (MainThread): 'soft_unicode' has been renamed to 'soft_str'. The old name will be removed in MarkupSafe 2.1. 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.810599 (MainThread): Acquiring new redshift connection "model.airbyte_utils.gg_cl_ab1". 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.827548 (MainThread): 'soft_unicode' has been renamed to 'soft_str'. The old name will be removed in MarkupSafe 2.1. 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.829155 (MainThread): Acquiring new redshift connection "model.airbyte_utils.gg_mxco". 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.837397 (MainThread): 'soft_unicode' has been renamed to 'soft_str'. The old name will be removed in MarkupSafe 2.1. 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.839020 (MainThread): Acquiring new redshift connection "model.airbyte_utils.gg_cl". 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.847791 (MainThread): 'soft_unicode' has been renamed to 'soft_str'. The old name will be removed in MarkupSafe 2.1. 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.849471 (MainThread): Acquiring new redshift connection "model.airbyte_utils.bb_fb". 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.858325 (MainThread): 'soft_unicode' has been renamed to 'soft_str'. The old name will be removed in MarkupSafe 2.1. 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.932766 (MainThread): [WARNING]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources. 2022-05-13 15:52:37 normalization > There are 2 unused configuration paths: 2022-05-13 15:52:37 normalization > - models.airbyte_utils.generated.airbyte_views 2022-05-13 15:52:37 normalization > - models.airbyte_utils.generated.airbyte_incremental 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.952192 (MainThread): write_gpickle is deprecated and will be removed in 3.0.Use ``pickle.dump(G, path, protocol)`` 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.952718 (MainThread): Found 12 models, 0 tests, 0 snapshots, 0 analyses, 520 macros, 0 operations, 0 seed files, 3 sources, 0 exposures 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.955236 (MainThread): 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.955950 (MainThread): Acquiring new redshift connection "master". 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.957111 (ThreadPoolExecutor-0_0): Acquiring new redshift connection "list_houmdw_prod". 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.969236 (ThreadPoolExecutor-0_0): Using redshift connection "list_houmdw_prod". 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.969424 (ThreadPoolExecutor-0_0): On list_houmdw_prod: /* {"app": "dbt", "dbt_version": "0.21.1", "profile_name": "normalize", "target_name": "prod", "connection_name": "list_houmdw_prod"} */ 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:37 normalization > select distinct nspname from pg_namespace 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.969531 (ThreadPoolExecutor-0_0): Opening a new connection, currently in state init 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:32.969614 (ThreadPoolExecutor-0_0): Connecting to Redshift using 'database' credentials 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.064601 (ThreadPoolExecutor-0_0): SQL status: SELECT in 0.10 seconds 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.067028 (ThreadPoolExecutor-0_0): On list_houmdw_prod: Close 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.068675 (ThreadPoolExecutor-1_0): Acquiring new redshift connection "list_houmdw_prod_airbyte_gspread". 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.077424 (ThreadPoolExecutor-1_0): Using redshift connection "list_houmdw_prod_airbyte_gspread". 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.077621 (ThreadPoolExecutor-1_0): On list_houmdw_prod_airbyte_gspread: BEGIN 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.077732 (ThreadPoolExecutor-1_0): Opening a new connection, currently in state closed 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.077832 (ThreadPoolExecutor-1_0): Connecting to Redshift using 'database' credentials 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.229596 (ThreadPoolExecutor-1_0): SQL status: BEGIN in 0.15 seconds 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.229861 (ThreadPoolExecutor-1_0): Using redshift connection "list_houmdw_prod_airbyte_gspread". 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.229966 (ThreadPoolExecutor-1_0): On list_houmdw_prod_airbyte_gspread: /* {"app": "dbt", "dbt_version": "0.21.1", "profile_name": "normalize", "target_name": "prod", "connection_name": "list_houmdw_prod_airbyte_gspread"} */ 2022-05-13 15:52:37 normalization > select 2022-05-13 15:52:37 normalization > 'houmdw_prod' as database, 2022-05-13 15:52:37 normalization > tablename as name, 2022-05-13 15:52:37 normalization > schemaname as schema, 2022-05-13 15:52:37 normalization > 'table' as type 2022-05-13 15:52:37 normalization > from pg_tables 2022-05-13 15:52:37 normalization > where schemaname ilike 'airbyte_gspread' 2022-05-13 15:52:37 normalization > union all 2022-05-13 15:52:37 normalization > select 2022-05-13 15:52:37 normalization > 'houmdw_prod' as database, 2022-05-13 15:52:37 normalization > viewname as name, 2022-05-13 15:52:37 normalization > schemaname as schema, 2022-05-13 15:52:37 normalization > 'view' as type 2022-05-13 15:52:37 normalization > from pg_views 2022-05-13 15:52:37 normalization > where schemaname ilike 'airbyte_gspread' 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.280470 (ThreadPoolExecutor-1_0): SQL status: SELECT in 0.05 seconds 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.284274 (ThreadPoolExecutor-1_0): On list_houmdw_prod_airbyte_gspread: ROLLBACK 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.286808 (ThreadPoolExecutor-1_0): On list_houmdw_prod_airbyte_gspread: Close 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.293829 (MainThread): Using redshift connection "master". 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.294006 (MainThread): On master: BEGIN 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.294152 (MainThread): Opening a new connection, currently in state init 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.294245 (MainThread): Connecting to Redshift using 'database' credentials 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.434771 (MainThread): SQL status: BEGIN in 0.14 seconds 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.435022 (MainThread): Using redshift connection "master". 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.435121 (MainThread): On master: /* {"app": "dbt", "dbt_version": "0.21.1", "profile_name": "normalize", "target_name": "prod", "connection_name": "master"} */ 2022-05-13 15:52:37 normalization > with relation as ( 2022-05-13 15:52:37 normalization > select 2022-05-13 15:52:37 normalization > pg_rewrite.ev_class as class, 2022-05-13 15:52:37 normalization > pg_rewrite.oid as id 2022-05-13 15:52:37 normalization > from pg_rewrite 2022-05-13 15:52:37 normalization > ), 2022-05-13 15:52:37 normalization > class as ( 2022-05-13 15:52:37 normalization > select 2022-05-13 15:52:37 normalization > oid as id, 2022-05-13 15:52:37 normalization > relname as name, 2022-05-13 15:52:37 normalization > relnamespace as schema, 2022-05-13 15:52:37 normalization > relkind as kind 2022-05-13 15:52:37 normalization > from pg_class 2022-05-13 15:52:37 normalization > ), 2022-05-13 15:52:37 normalization > dependency as ( 2022-05-13 15:52:37 normalization > select 2022-05-13 15:52:37 normalization > pg_depend.objid as id, 2022-05-13 15:52:37 normalization > pg_depend.refobjid as ref 2022-05-13 15:52:37 normalization > from pg_depend 2022-05-13 15:52:37 normalization > ), 2022-05-13 15:52:37 normalization > schema as ( 2022-05-13 15:52:37 normalization > select 2022-05-13 15:52:37 normalization > pg_namespace.oid as id, 2022-05-13 15:52:37 normalization > pg_namespace.nspname as name 2022-05-13 15:52:37 normalization > from pg_namespace 2022-05-13 15:52:37 normalization > where nspname != 'information_schema' and nspname not like 'pg\_%' 2022-05-13 15:52:37 normalization > ), 2022-05-13 15:52:37 normalization > referenced as ( 2022-05-13 15:52:37 normalization > select 2022-05-13 15:52:37 normalization > relation.id AS id, 2022-05-13 15:52:37 normalization > referenced_class.name , 2022-05-13 15:52:37 normalization > referenced_class.schema , 2022-05-13 15:52:37 normalization > referenced_class.kind 2022-05-13 15:52:37 normalization > from relation 2022-05-13 15:52:37 normalization > join class as referenced_class on relation.class=referenced_class.id 2022-05-13 15:52:37 normalization > where referenced_class.kind in ('r', 'v') 2022-05-13 15:52:37 normalization > ), 2022-05-13 15:52:37 normalization > relationships as ( 2022-05-13 15:52:37 normalization > select 2022-05-13 15:52:37 normalization > referenced.name as referenced_name, 2022-05-13 15:52:37 normalization > referenced.schema as referenced_schema_id, 2022-05-13 15:52:37 normalization > dependent_class.name as dependent_name, 2022-05-13 15:52:37 normalization > dependent_class.schema as dependent_schema_id, 2022-05-13 15:52:37 normalization > referenced.kind as kind 2022-05-13 15:52:37 normalization > from referenced 2022-05-13 15:52:37 normalization > join dependency on referenced.id=dependency.id 2022-05-13 15:52:37 normalization > join class as dependent_class on dependency.ref=dependent_class.id 2022-05-13 15:52:37 normalization > where 2022-05-13 15:52:37 normalization > (referenced.name != dependent_class.name or 2022-05-13 15:52:37 normalization > referenced.schema != dependent_class.schema) 2022-05-13 15:52:37 normalization > ) 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:37 normalization > select 2022-05-13 15:52:37 normalization > referenced_schema.name as referenced_schema, 2022-05-13 15:52:37 normalization > relationships.referenced_name as referenced_name, 2022-05-13 15:52:37 normalization > dependent_schema.name as dependent_schema, 2022-05-13 15:52:37 normalization > relationships.dependent_name as dependent_name 2022-05-13 15:52:37 normalization > from relationships 2022-05-13 15:52:37 normalization > join schema as dependent_schema on relationships.dependent_schema_id=dependent_schema.id 2022-05-13 15:52:37 normalization > join schema as referenced_schema on relationships.referenced_schema_id=referenced_schema.id 2022-05-13 15:52:37 normalization > group by referenced_schema, referenced_name, dependent_schema, dependent_name 2022-05-13 15:52:37 normalization > order by referenced_schema, referenced_name, dependent_schema, dependent_name; 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.560954 (MainThread): SQL status: SELECT in 0.13 seconds 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.569855 (MainThread): On master: ROLLBACK 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.572406 (MainThread): Using redshift connection "master". 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.572595 (MainThread): On master: BEGIN 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.577127 (MainThread): SQL status: BEGIN in 0.00 seconds 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.577318 (MainThread): On master: COMMIT 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.577422 (MainThread): Using redshift connection "master". 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.577509 (MainThread): On master: COMMIT 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.579676 (MainThread): SQL status: COMMIT in 0.00 seconds 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.579860 (MainThread): On master: Close 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.580467 (MainThread): 15:52:33 | Concurrency: 4 threads (target='prod') 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.580845 (MainThread): 15:52:33 | 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.589565 (Thread-1): Began running node model.airbyte_utils.bb_fb_ab1 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.590043 (Thread-1): Acquiring new redshift connection "model.airbyte_utils.bb_fb_ab1". 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.590635 (Thread-1): Compiling model.airbyte_utils.bb_fb_ab1 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.590272 (Thread-2): Began running node model.airbyte_utils.gg_cl_ab1 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.590430 (Thread-3): Began running node model.airbyte_utils.gg_mxco_ab1 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.601885 (Thread-2): Acquiring new redshift connection "model.airbyte_utils.gg_cl_ab1". 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.606734 (Thread-2): Compiling model.airbyte_utils.gg_cl_ab1 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.606564 (Thread-3): Acquiring new redshift connection "model.airbyte_utils.gg_mxco_ab1". 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.606144 (Thread-1): Writing injected SQL for node "model.airbyte_utils.bb_fb_ab1" 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.620399 (Thread-3): Compiling model.airbyte_utils.gg_mxco_ab1 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.624585 (Thread-2): Writing injected SQL for node "model.airbyte_utils.gg_cl_ab1" 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.701747 (Thread-3): Writing injected SQL for node "model.airbyte_utils.gg_mxco_ab1" 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.702394 (Thread-1): finished collecting timing info 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.702930 (Thread-1): Finished running node model.airbyte_utils.bb_fb_ab1 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.703399 (Thread-4): Began running node model.airbyte_utils.bb_fb_ab2 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.703800 (Thread-4): Acquiring new redshift connection "model.airbyte_utils.bb_fb_ab2". 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.703937 (Thread-4): Compiling model.airbyte_utils.bb_fb_ab2 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.726771 (Thread-3): finished collecting timing info 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.730266 (Thread-4): Writing injected SQL for node "model.airbyte_utils.bb_fb_ab2" 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.730823 (Thread-3): Finished running node model.airbyte_utils.gg_mxco_ab1 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.731285 (Thread-2): finished collecting timing info 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.731932 (Thread-1): Began running node model.airbyte_utils.gg_mxco_ab2 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.732960 (Thread-2): Finished running node model.airbyte_utils.gg_cl_ab1 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.733389 (Thread-1): Acquiring new redshift connection "model.airbyte_utils.gg_mxco_ab2". 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.734225 (Thread-1): Compiling model.airbyte_utils.gg_mxco_ab2 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.734007 (Thread-3): Began running node model.airbyte_utils.gg_cl_ab2 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.733600 (Thread-4): finished collecting timing info 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.745217 (Thread-3): Acquiring new redshift connection "model.airbyte_utils.gg_cl_ab2". 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.755455 (Thread-4): Finished running node model.airbyte_utils.bb_fb_ab2 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.755736 (Thread-3): Compiling model.airbyte_utils.gg_cl_ab2 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.758639 (Thread-1): Writing injected SQL for node "model.airbyte_utils.gg_mxco_ab2" 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.759219 (Thread-2): Began running node model.airbyte_utils.bb_fb_ab3 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.780395 (Thread-2): Acquiring new redshift connection "model.airbyte_utils.bb_fb_ab3". 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.782559 (Thread-3): Writing injected SQL for node "model.airbyte_utils.gg_cl_ab2" 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.782778 (Thread-2): Compiling model.airbyte_utils.bb_fb_ab3 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.788318 (Thread-1): finished collecting timing info 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.788847 (Thread-1): Finished running node model.airbyte_utils.gg_mxco_ab2 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.799575 (Thread-4): Began running node model.airbyte_utils.gg_mxco_ab3 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.807282 (Thread-4): Acquiring new redshift connection "model.airbyte_utils.gg_mxco_ab3". 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.806825 (Thread-2): Writing injected SQL for node "model.airbyte_utils.bb_fb_ab3" 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.807484 (Thread-4): Compiling model.airbyte_utils.gg_mxco_ab3 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.799876 (Thread-3): finished collecting timing info 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.813187 (Thread-3): Finished running node model.airbyte_utils.gg_cl_ab2 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.818949 (Thread-1): Began running node model.airbyte_utils.gg_cl_ab3 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.819403 (Thread-1): Acquiring new redshift connection "model.airbyte_utils.gg_cl_ab3". 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.824701 (Thread-1): Compiling model.airbyte_utils.gg_cl_ab3 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.838673 (Thread-4): Writing injected SQL for node "model.airbyte_utils.gg_mxco_ab3" 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.838965 (Thread-2): finished collecting timing info 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.849965 (Thread-2): Finished running node model.airbyte_utils.bb_fb_ab3 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.855721 (Thread-3): Began running node model.airbyte_utils.bb_fb 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.859936 (Thread-1): Writing injected SQL for node "model.airbyte_utils.gg_cl_ab3" 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.860318 (Thread-3): 15:52:33 | 1 of 3 START table model airbyte_gspread.bb_fb............................................................... [RUN] 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.861147 (Thread-1): finished collecting timing info 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.862443 (Thread-1): Finished running node model.airbyte_utils.gg_cl_ab3 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.861982 (Thread-3): Acquiring new redshift connection "model.airbyte_utils.bb_fb". 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.861536 (Thread-4): finished collecting timing info 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.862852 (Thread-2): Began running node model.airbyte_utils.gg_cl 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.863757 (Thread-2): 15:52:33 | 2 of 3 START table model airbyte_gspread.gg_cl............................................................... [RUN] 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.863464 (Thread-4): Finished running node model.airbyte_utils.gg_mxco_ab3 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.864790 (Thread-2): Acquiring new redshift connection "model.airbyte_utils.gg_cl". 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.863089 (Thread-3): Compiling model.airbyte_utils.bb_fb 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.864978 (Thread-1): Began running node model.airbyte_utils.gg_mxco 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.865167 (Thread-2): Compiling model.airbyte_utils.gg_cl 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.875701 (Thread-1): 15:52:33 | 3 of 3 START table model airbyte_gspread.gg_mxco............................................................. [RUN] 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.876985 (Thread-3): Writing injected SQL for node "model.airbyte_utils.bb_fb" 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.890338 (Thread-2): Writing injected SQL for node "model.airbyte_utils.gg_cl" 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.890810 (Thread-1): Acquiring new redshift connection "model.airbyte_utils.gg_mxco". 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.891276 (Thread-1): Compiling model.airbyte_utils.gg_mxco 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.896950 (Thread-3): finished collecting timing info 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.897196 (Thread-2): finished collecting timing info 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.912591 (Thread-1): Writing injected SQL for node "model.airbyte_utils.gg_mxco" 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.933690 (Thread-1): finished collecting timing info 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.980866 (Thread-1): Writing runtime SQL for node "model.airbyte_utils.gg_mxco" 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.982509 (Thread-3): Writing runtime SQL for node "model.airbyte_utils.bb_fb" 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.984280 (Thread-3): Using redshift connection "model.airbyte_utils.bb_fb". 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.984482 (Thread-3): On model.airbyte_utils.bb_fb: BEGIN 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.984662 (Thread-3): Opening a new connection, currently in state init 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.984804 (Thread-3): Connecting to Redshift using 'database' credentials 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.983492 (Thread-2): Writing runtime SQL for node "model.airbyte_utils.gg_cl" 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.985519 (Thread-2): Using redshift connection "model.airbyte_utils.gg_cl". 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.985700 (Thread-2): On model.airbyte_utils.gg_cl: BEGIN 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.985898 (Thread-2): Opening a new connection, currently in state init 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.986075 (Thread-2): Connecting to Redshift using 'database' credentials 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.986269 (Thread-1): Using redshift connection "model.airbyte_utils.gg_mxco". 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.987087 (Thread-1): On model.airbyte_utils.gg_mxco: BEGIN 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.987237 (Thread-1): Opening a new connection, currently in state closed 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:33.987327 (Thread-1): Connecting to Redshift using 'database' credentials 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:34.038988 (Thread-3): SQL status: BEGIN in 0.05 seconds 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:34.039250 (Thread-3): Using redshift connection "model.airbyte_utils.bb_fb". 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:34.039350 (Thread-3): On model.airbyte_utils.bb_fb: /* {"app": "dbt", "dbt_version": "0.21.1", "profile_name": "normalize", "target_name": "prod", "node_id": "model.airbyte_utils.bb_fb"} */ 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:37 normalization > create table 2022-05-13 15:52:37 normalization > "houmdw_prod".airbyte_gspread."bb_fb__dbt_tmp" 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:37 normalization > compound sortkey(_airbyte_emitted_at) 2022-05-13 15:52:37 normalization > as ( 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:37 normalization > with __dbt__cte__bb_fb_ab1 as ( 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:37 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-05-13 15:52:37 normalization > -- depends_on: "houmdw_prod".airbyte_gspread._airbyte_raw_bb_fb 2022-05-13 15:52:37 normalization > select 2022-05-13 15:52:37 normalization > case when json_extract_path_text(_airbyte_data, 'Cost', true) != '' then json_extract_path_text(_airbyte_data, 'Cost', true) end as cost, 2022-05-13 15:52:37 normalization > case when json_extract_path_text(_airbyte_data, 'Date', true) != '' then json_extract_path_text(_airbyte_data, 'Date', true) end as date, 2022-05-13 15:52:37 normalization > case when json_extract_path_text(_airbyte_data, 'Impressions', true) != '' then json_extract_path_text(_airbyte_data, 'Impressions', true) end as impressions, 2022-05-13 15:52:37 normalization > case when json_extract_path_text(_airbyte_data, 'Link clicks', true) != '' then json_extract_path_text(_airbyte_data, 'Link clicks', true) end as "link clicks", 2022-05-13 15:52:37 normalization > case when json_extract_path_text(_airbyte_data, 'Campaign name', true) != '' then json_extract_path_text(_airbyte_data, 'Campaign name', true) end as "campaign name", 2022-05-13 15:52:37 normalization > case when json_extract_path_text(_airbyte_data, 'Ad set end time', true) != '' then json_extract_path_text(_airbyte_data, 'Ad set end time', true) end as "ad set end time", 2022-05-13 15:52:37 normalization > case when json_extract_path_text(_airbyte_data, 'Ad set start time', true) != '' then json_extract_path_text(_airbyte_data, 'Ad set start time', true) end as "ad set start time", 2022-05-13 15:52:37 normalization > case when json_extract_path_text(_airbyte_data, 'Ad set daily budget', true) != '' then json_extract_path_text(_airbyte_data, 'Ad set daily budget', true) end as "ad set daily budget", 2022-05-13 15:52:37 normalization > case when json_extract_path_text(_airbyte_data, 'Ad set lifetime budget', true) != '' then json_extract_path_text(_airbyte_data, 'Ad set lifetime budget', true) end as "ad set lifetime budget", 2022-05-13 15:52:37 normalization > _airbyte_ab_id, 2022-05-13 15:52:37 normalization > _airbyte_emitted_at, 2022-05-13 15:52:37 normalization > getdate() as _airbyte_normalized_at 2022-05-13 15:52:37 normalization > from "houmdw_prod".airbyte_gspread._airbyte_raw_bb_fb as table_alias 2022-05-13 15:52:37 normalization > -- bb_fb 2022-05-13 15:52:37 normalization > where 1 = 1 2022-05-13 15:52:37 normalization > ), __dbt__cte__bb_fb_ab2 as ( 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:37 normalization > -- SQL model to cast each column to its adequate SQL type converted from the JSON schema type 2022-05-13 15:52:37 normalization > -- depends_on: __dbt__cte__bb_fb_ab1 2022-05-13 15:52:37 normalization > select 2022-05-13 15:52:37 normalization > cast(cost as varchar) as cost, 2022-05-13 15:52:37 normalization > cast(date as varchar) as date, 2022-05-13 15:52:37 normalization > cast(impressions as varchar) as impressions, 2022-05-13 15:52:37 normalization > cast("link clicks" as varchar) as "link clicks", 2022-05-13 15:52:37 normalization > cast("campaign name" as varchar) as "campaign name", 2022-05-13 15:52:37 normalization > cast("ad set end time" as varchar) as "ad set end time", 2022-05-13 15:52:37 normalization > cast("ad set start time" as varchar) as "ad set start time", 2022-05-13 15:52:37 normalization > cast("ad set daily budget" as varchar) as "ad set daily budget", 2022-05-13 15:52:37 normalization > cast("ad set lifetime budget" as varchar) as "ad set lifetime budget", 2022-05-13 15:52:37 normalization > _airbyte_ab_id, 2022-05-13 15:52:37 normalization > _airbyte_emitted_at, 2022-05-13 15:52:37 normalization > getdate() as _airbyte_normalized_at 2022-05-13 15:52:37 normalization > from __dbt__cte__bb_fb_ab1 2022-05-13 15:52:37 normalization > -- bb_fb 2022-05-13 15:52:37 normalization > where 1 = 1 2022-05-13 15:52:37 normalization > ), __dbt__cte__bb_fb_ab3 as ( 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:37 normalization > -- SQL model to build a hash column based on the values of this record 2022-05-13 15:52:37 normalization > -- depends_on: __dbt__cte__bb_fb_ab2 2022-05-13 15:52:37 normalization > select 2022-05-13 15:52:37 normalization > md5(cast(coalesce(cast(cost as varchar), '') || '-' || coalesce(cast(date as varchar), '') || '-' || coalesce(cast(impressions as varchar), '') || '-' || coalesce(cast("link clicks" as varchar), '') || '-' || coalesce(cast("campaign name" as varchar), '') || '-' || coalesce(cast("ad set end time" as varchar), '') || '-' || coalesce(cast("ad set start time" as varchar), '') || '-' || coalesce(cast("ad set daily budget" as varchar), '') || '-' || coalesce(cast("ad set lifetime budget" as varchar), '') as varchar)) as _airbyte_bb_fb_hashid, 2022-05-13 15:52:37 normalization > tmp.* 2022-05-13 15:52:37 normalization > from __dbt__cte__bb_fb_ab2 tmp 2022-05-13 15:52:37 normalization > -- bb_fb 2022-05-13 15:52:37 normalization > where 1 = 1 2022-05-13 15:52:37 normalization > )-- Final base SQL model 2022-05-13 15:52:37 normalization > -- depends_on: __dbt__cte__bb_fb_ab3 2022-05-13 15:52:37 normalization > select 2022-05-13 15:52:37 normalization > cost, 2022-05-13 15:52:37 normalization > date, 2022-05-13 15:52:37 normalization > impressions, 2022-05-13 15:52:37 normalization > "link clicks", 2022-05-13 15:52:37 normalization > "campaign name", 2022-05-13 15:52:37 normalization > "ad set end time", 2022-05-13 15:52:37 normalization > "ad set start time", 2022-05-13 15:52:37 normalization > "ad set daily budget", 2022-05-13 15:52:37 normalization > "ad set lifetime budget", 2022-05-13 15:52:37 normalization > _airbyte_ab_id, 2022-05-13 15:52:37 normalization > _airbyte_emitted_at, 2022-05-13 15:52:37 normalization > getdate() as _airbyte_normalized_at, 2022-05-13 15:52:37 normalization > _airbyte_bb_fb_hashid 2022-05-13 15:52:37 normalization > from __dbt__cte__bb_fb_ab3 2022-05-13 15:52:37 normalization > -- bb_fb from "houmdw_prod".airbyte_gspread._airbyte_raw_bb_fb 2022-05-13 15:52:37 normalization > where 1 = 1 2022-05-13 15:52:37 normalization > ); 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:34.056562 (Thread-3): Postgres error: function json_extract_path_text(super, "unknown", boolean) does not exist 2022-05-13 15:52:37 normalization > HINT: No function matches the given name and argument types. You may need to add explicit type casts. 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:34.056850 (Thread-3): On model.airbyte_utils.bb_fb: ROLLBACK 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:34.060709 (Thread-3): finished collecting timing info 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:34.060942 (Thread-3): On model.airbyte_utils.bb_fb: Close 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:34.062531 (Thread-2): SQL status: BEGIN in 0.08 seconds 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:34.062679 (Thread-2): Using redshift connection "model.airbyte_utils.gg_cl". 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:34.062773 (Thread-2): On model.airbyte_utils.gg_cl: /* {"app": "dbt", "dbt_version": "0.21.1", "profile_name": "normalize", "target_name": "prod", "node_id": "model.airbyte_utils.gg_cl"} */ 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:37 normalization > create table 2022-05-13 15:52:37 normalization > "houmdw_prod".airbyte_gspread."gg_cl__dbt_tmp" 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:37 normalization > compound sortkey(_airbyte_emitted_at) 2022-05-13 15:52:37 normalization > as ( 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:37 normalization > with __dbt__cte__gg_cl_ab1 as ( 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:37 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-05-13 15:52:37 normalization > -- depends_on: "houmdw_prod".airbyte_gspread._airbyte_raw_gg_cl 2022-05-13 15:52:37 normalization > select 2022-05-13 15:52:37 normalization > case when json_extract_path_text(_airbyte_data, 'Cost', true) != '' then json_extract_path_text(_airbyte_data, 'Cost', true) end as cost, 2022-05-13 15:52:37 normalization > case when json_extract_path_text(_airbyte_data, 'Date', true) != '' then json_extract_path_text(_airbyte_data, 'Date', true) end as date, 2022-05-13 15:52:37 normalization > case when json_extract_path_text(_airbyte_data, 'Clicks', true) != '' then json_extract_path_text(_airbyte_data, 'Clicks', true) end as clicks, 2022-05-13 15:52:37 normalization > case when json_extract_path_text(_airbyte_data, 'End date', true) != '' then json_extract_path_text(_airbyte_data, 'End date', true) end as "end date", 2022-05-13 15:52:37 normalization > case when json_extract_path_text(_airbyte_data, 'Start date', true) != '' then json_extract_path_text(_airbyte_data, 'Start date', true) end as "start date", 2022-05-13 15:52:37 normalization > case when json_extract_path_text(_airbyte_data, 'Impressions', true) != '' then json_extract_path_text(_airbyte_data, 'Impressions', true) end as impressions, 2022-05-13 15:52:37 normalization > case when json_extract_path_text(_airbyte_data, 'Daily budget', true) != '' then json_extract_path_text(_airbyte_data, 'Daily budget', true) end as "daily budget", 2022-05-13 15:52:37 normalization > case when json_extract_path_text(_airbyte_data, 'Campaign name', true) != '' then json_extract_path_text(_airbyte_data, 'Campaign name', true) end as "campaign name", 2022-05-13 15:52:37 normalization > case when json_extract_path_text(_airbyte_data, 'Impression share', true) != '' then json_extract_path_text(_airbyte_data, 'Impression share', true) end as "impression share", 2022-05-13 15:52:37 normalization > case when json_extract_path_text(_airbyte_data, 'Search rank lost top impression share', true) != '' then json_extract_path_text(_airbyte_data, 'Search rank lost top impression share', true) end as "search rank lost top impression share", 2022-05-13 15:52:37 normalization > case when json_extract_path_text(_airbyte_data, 'Search budget lost top impression share', true) != '' then json_extract_path_text(_airbyte_data, 'Search budget lost top impression share', true) end as "search budget lost top impression share", 2022-05-13 15:52:37 normalization > _airbyte_ab_id, 2022-05-13 15:52:37 normalization > _airbyte_emitted_at, 2022-05-13 15:52:37 normalization > getdate() as _airbyte_normalized_at 2022-05-13 15:52:37 normalization > from "houmdw_prod".airbyte_gspread._airbyte_raw_gg_cl as table_alias 2022-05-13 15:52:37 normalization > -- gg_cl 2022-05-13 15:52:37 normalization > where 1 = 1 2022-05-13 15:52:37 normalization > ), __dbt__cte__gg_cl_ab2 as ( 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:37 normalization > -- SQL model to cast each column to its adequate SQL type converted from the JSON schema type 2022-05-13 15:52:37 normalization > -- depends_on: __dbt__cte__gg_cl_ab1 2022-05-13 15:52:37 normalization > select 2022-05-13 15:52:37 normalization > cast(cost as varchar) as cost, 2022-05-13 15:52:37 normalization > cast(date as varchar) as date, 2022-05-13 15:52:37 normalization > cast(clicks as varchar) as clicks, 2022-05-13 15:52:37 normalization > cast("end date" as varchar) as "end date", 2022-05-13 15:52:37 normalization > cast("start date" as varchar) as "start date", 2022-05-13 15:52:37 normalization > cast(impressions as varchar) as impressions, 2022-05-13 15:52:37 normalization > cast("daily budget" as varchar) as "daily budget", 2022-05-13 15:52:37 normalization > cast("campaign name" as varchar) as "campaign name", 2022-05-13 15:52:37 normalization > cast("impression share" as varchar) as "impression share", 2022-05-13 15:52:37 normalization > cast("search rank lost top impression share" as varchar) as "search rank lost top impression share", 2022-05-13 15:52:37 normalization > cast("search budget lost top impression share" as varchar) as "search budget lost top impression share", 2022-05-13 15:52:37 normalization > _airbyte_ab_id, 2022-05-13 15:52:37 normalization > _airbyte_emitted_at, 2022-05-13 15:52:37 normalization > getdate() as _airbyte_normalized_at 2022-05-13 15:52:37 normalization > from __dbt__cte__gg_cl_ab1 2022-05-13 15:52:37 normalization > -- gg_cl 2022-05-13 15:52:37 normalization > where 1 = 1 2022-05-13 15:52:37 normalization > ), __dbt__cte__gg_cl_ab3 as ( 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:37 normalization > -- SQL model to build a hash column based on the values of this record 2022-05-13 15:52:37 normalization > -- depends_on: __dbt__cte__gg_cl_ab2 2022-05-13 15:52:37 normalization > select 2022-05-13 15:52:37 normalization > md5(cast(coalesce(cast(cost as varchar), '') || '-' || coalesce(cast(date as varchar), '') || '-' || coalesce(cast(clicks as varchar), '') || '-' || coalesce(cast("end date" as varchar), '') || '-' || coalesce(cast("start date" as varchar), '') || '-' || coalesce(cast(impressions as varchar), '') || '-' || coalesce(cast("daily budget" as varchar), '') || '-' || coalesce(cast("campaign name" as varchar), '') || '-' || coalesce(cast("impression share" as varchar), '') || '-' || coalesce(cast("search rank lost top impression share" as varchar), '') || '-' || coalesce(cast("search budget lost top impression share" as varchar), '') as varchar)) as _airbyte_gg_cl_hashid, 2022-05-13 15:52:37 normalization > tmp.* 2022-05-13 15:52:37 normalization > from __dbt__cte__gg_cl_ab2 tmp 2022-05-13 15:52:37 normalization > -- gg_cl 2022-05-13 15:52:37 normalization > where 1 = 1 2022-05-13 15:52:37 normalization > )-- Final base SQL model 2022-05-13 15:52:37 normalization > -- depends_on: __dbt__cte__gg_cl_ab3 2022-05-13 15:52:37 normalization > select 2022-05-13 15:52:37 normalization > cost, 2022-05-13 15:52:37 normalization > date, 2022-05-13 15:52:37 normalization > clicks, 2022-05-13 15:52:37 normalization > "end date", 2022-05-13 15:52:37 normalization > "start date", 2022-05-13 15:52:37 normalization > impressions, 2022-05-13 15:52:37 normalization > "daily budget", 2022-05-13 15:52:37 normalization > "campaign name", 2022-05-13 15:52:37 normalization > "impression share", 2022-05-13 15:52:37 normalization > "search rank lost top impression share", 2022-05-13 15:52:37 normalization > "search budget lost top impression share", 2022-05-13 15:52:37 normalization > _airbyte_ab_id, 2022-05-13 15:52:37 normalization > _airbyte_emitted_at, 2022-05-13 15:52:37 normalization > getdate() as _airbyte_normalized_at, 2022-05-13 15:52:37 normalization > _airbyte_gg_cl_hashid 2022-05-13 15:52:37 normalization > from __dbt__cte__gg_cl_ab3 2022-05-13 15:52:37 normalization > -- gg_cl from "houmdw_prod".airbyte_gspread._airbyte_raw_gg_cl 2022-05-13 15:52:37 normalization > where 1 = 1 2022-05-13 15:52:37 normalization > ); 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:34.061502 (Thread-3): Database Error in model bb_fb (models/generated/airbyte_tables/airbyte_gspread/bb_fb.sql) 2022-05-13 15:52:37 normalization > function json_extract_path_text(super, "unknown", boolean) does not exist 2022-05-13 15:52:37 normalization > HINT: No function matches the given name and argument types. You may need to add explicit type casts. 2022-05-13 15:52:37 normalization > compiled SQL at ../build/run/airbyte_utils/models/generated/airbyte_tables/airbyte_gspread/bb_fb.sql 2022-05-13 15:52:37 normalization > Traceback (most recent call last): 2022-05-13 15:52:37 normalization > File "/usr/local/lib/python3.8/site-packages/dbt/adapters/postgres/connections.py", line 56, in exception_handler 2022-05-13 15:52:37 normalization > yield 2022-05-13 15:52:37 normalization > File "/usr/local/lib/python3.8/site-packages/dbt/adapters/sql/connections.py", line 80, in add_query 2022-05-13 15:52:37 normalization > cursor.execute(sql, bindings) 2022-05-13 15:52:37 normalization > psycopg2.errors.UndefinedFunction: function json_extract_path_text(super, "unknown", boolean) does not exist 2022-05-13 15:52:37 normalization > HINT: No function matches the given name and argument types. You may need to add explicit type casts. 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:37 normalization > The above exception was the direct cause of the following exception: 2022-05-13 15:52:37 normalization > 2022-05-13 15:52:37 normalization > Traceback (most recent call last): 2022-05-13 15:52:37 normalization > File "/usr/local/lib/python3.8/site-packages/dbt/task/base.py", line 348, in safe_run 2022-05-13 15:52:37 normalization > result = self.compile_and_execute(manifest, ctx) 2022-05-13 15:52:37 normalization > File "/usr/local/lib/python3.8/site-packages/dbt/task/base.py", line 291, in compile_and_execute 2022-05-13 15:52:37 normalization > result = self.run(ctx.node, manifest) 2022-05-13 15:52:37 normalization > File "/usr/local/lib/python3.8/site-packages/dbt/task/base.py", line 393, in run 2022-05-13 15:52:37 normalization > return self.execute(compiled_node, manifest) 2022-05-13 15:52:37 normalization > File "/usr/local/lib/python3.8/site-packages/dbt/task/run.py", line 249, in execute 2022-05-13 15:52:37 normalization > result = MacroGenerator(materialization_macro, context)() 2022-05-13 15:52:37 normalization > File "/usr/local/lib/python3.8/site-packages/dbt/clients/jinja.py", line 333, in __call__ 2022-05-13 15:52:37 normalization > return self.call_macro(*args, **kwargs) 2022-05-13 15:52:37 normalization > File "/usr/local/lib/python3.8/site-packages/dbt/clients/jinja.py", line 260, in call_macro 2022-05-13 15:52:37 normalization > return macro(*args, **kwargs) 2022-05-13 15:52:37 normalization > File "/usr/local/lib/python3.8/site-packages/jinja2/runtime.py", line 675, in __call__ 2022-05-13 15:52:37 normalization > return self._invoke(arguments, autoescape) 2022-05-13 15:52:37 normalization > File "/usr/local/lib/python3.8/site-packages/jinja2/runtime.py", line 679, in _invoke 2022-05-13 15:52:37 normalization > rv = self._func(*arguments) 2022-05-13 15:52:37 normalization > File "