2022-03-30 09:34:13 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.35.45-alpha 2022-03-30 09:34:14 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/180/2/logs.log 2022-03-30 09:34:14 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.45-alpha 2022-03-30 09:34:14 INFO i.a.w.DefaultReplicationWorker(run):103 - start sync worker. job id: 180 attempt id: 2 2022-03-30 09:34:14 INFO i.a.w.DefaultReplicationWorker(run):115 - configured sync modes: {null.lists=full_refresh - append} 2022-03-30 09:34:14 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination... 2022-03-30 09:34:14 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-snowflake:0.4.17 exists... 2022-03-30 09:34:14 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-snowflake:0.4.17 was found locally. 2022-03-30 09:34:14 INFO i.a.w.p.DockerProcessFactory(create):104 - Creating docker job ID: 180 2022-03-30 09:34:14 INFO i.a.w.p.DockerProcessFactory(create):155 - Preparing command: docker run --rm --init -i -w /data/180/2 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local airbyte/destination-snowflake:0.4.17 write --config destination_config.json --catalog destination_catalog.json 2022-03-30 09:34:14 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-sportsapi:dev exists... 2022-03-30 09:34:14 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-sportsapi:dev was found locally. 2022-03-30 09:34:14 INFO i.a.w.p.DockerProcessFactory(create):104 - Creating docker job ID: 180 2022-03-30 09:34:14 INFO i.a.w.p.DockerProcessFactory(create):155 - Preparing command: docker run --rm --init -i -w /data/180/2 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local airbyte/source-sportsapi:dev read --config source_config.json --catalog source_catalog.json 2022-03-30 09:34:14 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):338 - Destination output thread started. 2022-03-30 09:34:14 INFO i.a.w.DefaultReplicationWorker(run):157 - Waiting for source and destination threads to complete. 2022-03-30 09:34:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):278 - Replication thread started. 2022-03-30 09:34:19 destination > SLF4J: Class path contains multiple SLF4J bindings. 2022-03-30 09:34:19 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-03-30 09:34:19 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-03-30 09:34:19 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-03-30 09:34:19 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-03-30 09:34:20 source > Starting syncing SourceSportsapi 2022-03-30 09:34:20 source > Syncing stream: lists 2022-03-30 09:34:21 source > Read 1 records from lists stream 2022-03-30 09:34:21 source > Finished syncing lists 2022-03-30 09:34:21 source > SourceSportsapi runtimes: Syncing stream lists 0:00:01.179379 2022-03-30 09:34:21 source > Finished syncing SourceSportsapi 2022-03-30 09:34:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):304 - Total records read: 1 2022-03-30 09:34:21 INFO i.a.w.DefaultReplicationWorker(run):162 - One of source or destination thread complete. Waiting on the other. 2022-03-30 09:34:22 destination > 2022-03-30 09:34:22 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json} 2022-03-30 09:34:22 destination > 2022-03-30 09:34:22 INFO i.a.i.b.IntegrationRunner(run):88 - Sentry transaction event: 9ed812fd217c403d8d787ddad690dafd 2022-03-30 09:34:22 destination > 2022-03-30 09:34:22 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2022-03-30 09:34:22 destination > 2022-03-30 09:34:22 INFO i.a.i.b.IntegrationRunner(runInternal):107 - Command: WRITE 2022-03-30 09:34:22 destination > 2022-03-30 09:34:22 INFO i.a.i.b.IntegrationRunner(runInternal):108 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'} 2022-03-30 09:34:22 destination > 2022-03-30 09:34:22 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-03-30 09:34:22 destination > 2022-03-30 09:34:22 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-03-30 09:34:22 destination > 2022-03-30 09:34:22 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-03-30 09:34:22 destination > 2022-03-30 09:34:22 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword multiline - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-03-30 09:34:22 destination > 2022-03-30 09:34:22 INFO i.a.i.d.j.c.SwitchingDestination(getConsumer):65 - Using destination type: INTERNAL_STAGING 2022-03-30 09:34:22 destination > 2022-03-30 09:34:22 INFO i.a.i.d.s.SnowflakeInternalStagingConsumerFactory(lambda$toWriteConfig$0):92 - Write config: WriteConfig{streamName=lists, namespace=null, outputSchemaName=public, tmpTableName=_airbyte_tmp_tqt_lists, outputTableName=_airbyte_raw_lists, syncMode=append} 2022-03-30 09:34:22 destination > 2022-03-30 09:34:22 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):141 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started. 2022-03-30 09:34:22 destination > 2022-03-30 09:34:22 INFO i.a.i.d.s.SnowflakeInternalStagingConsumerFactory(lambda$onStartFunction$2):111 - Preparing tmp tables in destination started for 1 streams 2022-03-30 09:34:22 destination > 2022-03-30 09:34:22 INFO i.a.i.d.s.SnowflakeInternalStagingConsumerFactory(lambda$onStartFunction$2):119 - Preparing stage in destination started for schema public stream lists: tmp table: _airbyte_tmp_tqt_lists, stage: PUBLIC_AIRBYTE_RAW_LISTS 2022-03-30 09:34:26 destination > 2022-03-30 09:34:26 INFO i.a.d.j.DefaultJdbcDatabase(lambda$query$1):106 - closing connection 2022-03-30 09:34:26 destination > 2022-03-30 09:34:26 INFO i.a.i.d.s.SnowflakeInternalStagingConsumerFactory(lambda$onStartFunction$2):130 - Preparing stage in destination completed for schema public stream lists 2022-03-30 09:34:26 destination > 2022-03-30 09:34:26 INFO i.a.i.d.s.SnowflakeInternalStagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing tables in destination completed. 2022-03-30 09:34:26 destination > 2022-03-30 09:34:26 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded. 2022-03-30 09:34:26 destination > 2022-03-30 09:34:26 INFO i.a.i.d.b.BufferedStreamConsumer(close):217 - executing on success close procedure. 2022-03-30 09:34:26 destination > 2022-03-30 09:34:26 INFO i.a.i.d.b.BufferedStreamConsumer(flushQueueToDestination):181 - Flushing buffer: 8472 bytes 2022-03-30 09:34:26 destination > 2022-03-30 09:34:26 INFO i.a.i.d.b.BufferedStreamConsumer(lambda$flushQueueToDestination$1):185 - Flushing lists: 1 records 2022-03-30 09:34:27 destination > 2022-03-30 09:34:26 INFO i.a.i.d.s.SnowflakeStagingSqlOperations(insertRecordsInternal):29 - Writing 1 records to PUBLIC_AIRBYTE_RAW_LISTS/STAGED/EFD43623-8C92-49E7-9A00-5C2708B91AF2 2022-03-30 09:34:29 destination > 2022-03-30 09:34:29 INFO i.a.i.d.s.SnowflakeInternalStagingConsumerFactory(lambda$onCloseFunction$4):173 - Finalizing tables in destination started for 1 streams 2022-03-30 09:34:29 destination > 2022-03-30 09:34:29 INFO i.a.i.d.s.SnowflakeInternalStagingConsumerFactory(lambda$onCloseFunction$4):181 - Finalizing stream lists. schema public, tmp table _airbyte_tmp_tqt_lists, final table _airbyte_raw_lists, stage path PUBLIC_AIRBYTE_RAW_LISTS/STAGED/EFD43623-8C92-49E7-9A00-5C2708B91AF2 2022-03-30 09:34:30 destination > 2022-03-30 09:34:30 INFO i.a.i.d.s.SnowflakeInternalStagingConsumerFactory(lambda$onCloseFunction$4):201 - Executing finalization of tables. 2022-03-30 09:34:31 destination > 2022-03-30 09:34:31 INFO i.a.i.d.s.SnowflakeInternalStagingConsumerFactory(lambda$onCloseFunction$4):203 - Finalizing tables in destination completed. 2022-03-30 09:34:31 destination > 2022-03-30 09:34:31 INFO i.a.i.d.s.SnowflakeInternalStagingConsumerFactory(lambda$onCloseFunction$4):205 - Cleaning tmp tables in destination started for 1 streams 2022-03-30 09:34:31 destination > 2022-03-30 09:34:31 INFO i.a.i.d.s.SnowflakeInternalStagingConsumerFactory(lambda$onCloseFunction$4):209 - Cleaning tmp table in destination started for stream lists. schema public, tmp table name: _airbyte_tmp_tqt_lists 2022-03-30 09:34:31 destination > 2022-03-30 09:34:31 INFO i.a.i.d.s.SnowflakeInternalStagingConsumerFactory(lambda$onCloseFunction$4):215 - Cleaning stage in destination started for stream lists. schema public, stage: PUBLIC_AIRBYTE_RAW_LISTS 2022-03-30 09:34:31 destination > 2022-03-30 09:34:31 INFO i.a.i.d.s.SnowflakeInternalStagingConsumerFactory(lambda$onCloseFunction$4):219 - Cleaning tmp tables and stages in destination completed. 2022-03-30 09:34:31 destination > 2022-03-30 09:34:31 INFO i.a.i.b.IntegrationRunner(runInternal):154 - Completed integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2022-03-30 09:34:32 INFO i.a.w.DefaultReplicationWorker(run):164 - Source and destination threads complete. 2022-03-30 09:34:32 INFO i.a.w.DefaultReplicationWorker(run):227 - sync summary: io.airbyte.config.ReplicationAttemptSummary@771f5794[status=completed,recordsSynced=1,bytesSynced=2118,startTime=1648632854197,endTime=1648632872809,totalStats=io.airbyte.config.SyncStats@79c1c113[recordsEmitted=1,bytesEmitted=2118,stateMessagesEmitted=0,recordsCommitted=1],streamStats=[io.airbyte.config.StreamSyncStats@73a7af6c[streamName=lists,stats=io.airbyte.config.SyncStats@5c9e2b42[recordsEmitted=1,bytesEmitted=2118,stateMessagesEmitted=,recordsCommitted=1]]]] 2022-03-30 09:34:32 INFO i.a.w.DefaultReplicationWorker(run):249 - Source did not output any state messages 2022-03-30 09:34:32 WARN i.a.w.DefaultReplicationWorker(run):260 - State capture: No state retained. 2022-03-30 09:34:32 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2022-03-30 09:34:32 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$1):147 - sync summary: io.airbyte.config.StandardSyncOutput@6f13598e[standardSyncSummary=io.airbyte.config.StandardSyncSummary@718e6090[status=completed,recordsSynced=1,bytesSynced=2118,startTime=1648632854197,endTime=1648632872809,totalStats=io.airbyte.config.SyncStats@79c1c113[recordsEmitted=1,bytesEmitted=2118,stateMessagesEmitted=0,recordsCommitted=1],streamStats=[io.airbyte.config.StreamSyncStats@73a7af6c[streamName=lists,stats=io.airbyte.config.SyncStats@5c9e2b42[recordsEmitted=1,bytesEmitted=2118,stateMessagesEmitted=,recordsCommitted=1]]]],state=,outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@a794c31[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@5931a4fd[stream=io.airbyte.protocol.models.AirbyteStream@2c9b597c[name=lists,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-04/schema#","required":["football","cricket","golf"],"properties":{"golf":{"type":"array","items":{}},"cricket":{"type":"array","items":[{"type":"object","required":["stadium","country","region","tournament","start","match"],"properties":{"match":{"type":"string"},"start":{"type":"string"},"region":{"type":"string"},"country":{"type":"string"},"stadium":{"type":"string"},"tournament":{"type":"string"}}},{"type":"object","required":["stadium","country","region","tournament","start","match"],"properties":{"match":{"type":"string"},"start":{"type":"string"},"region":{"type":"string"},"country":{"type":"string"},"stadium":{"type":"string"},"tournament":{"type":"string"}}}]},"football":{"type":"array","items":[{"type":"object","required":["stadium","country","region","tournament","start","match"],"properties":{"match":{"type":"string"},"start":{"type":"string"},"region":{"type":"string"},"country":{"type":"string"},"stadium":{"type":"string"},"tournament":{"type":"string"}}},{"type":"object","required":["stadium","country","region","tournament","start","match"],"properties":{"match":{"type":"string"},"start":{"type":"string"},"region":{"type":"string"},"country":{"type":"string"},"stadium":{"type":"string"},"tournament":{"type":"string"}}},{"type":"object","required":["stadium","country","region","tournament","start","match"],"properties":{"match":{"type":"string"},"start":{"type":"string"},"region":{"type":"string"},"country":{"type":"string"},"stadium":{"type":"string"},"tournament":{"type":"string"}}},{"type":"object","required":["stadium","country","region","tournament","start","match"],"properties":{"match":{"type":"string"},"start":{"type":"string"},"region":{"type":"string"},"country":{"type":"string"},"stadium":{"type":"string"},"tournament":{"type":"string"}}},{"type":"object","required":["stadium","country","region","tournament","start","match"],"properties":{"match":{"type":"string"},"start":{"type":"string"},"region":{"type":"string"},"country":{"type":"string"},"stadium":{"type":"string"},"tournament":{"type":"string"}}},{"type":"object","required":["stadium","country","region","tournament","start","match"],"properties":{"match":{"type":"string"},"start":{"type":"string"},"region":{"type":"string"},"country":{"type":"string"},"stadium":{"type":"string"},"tournament":{"type":"string"}}},{"type":"object","required":["stadium","country","region","tournament","start","match"],"properties":{"match":{"type":"string"},"start":{"type":"string"},"region":{"type":"string"},"country":{"type":"string"},"stadium":{"type":"string"},"tournament":{"type":"string"}}},{"type":"object","required":["stadium","country","region","tournament","start","match"],"properties":{"match":{"type":"string"},"start":{"type":"string"},"region":{"type":"string"},"country":{"type":"string"},"stadium":{"type":"string"},"tournament":{"type":"string"}}},{"type":"object","required":["stadium","country","region","tournament","start","match"],"properties":{"match":{"type":"string"},"start":{"type":"string"},"region":{"type":"string"},"country":{"type":"string"},"stadium":{"type":"string"},"tournament":{"type":"string"}}},{"type":"object","required":["stadium","country","region","tournament","start","match"],"properties":{"match":{"type":"string"},"start":{"type":"string"},"region":{"type":"string"},"country":{"type":"string"},"stadium":{"type":"string"},"tournament":{"type":"string"}}}]}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}]],additionalProperties={}],failures=[]] 2022-03-30 09:34:32 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating... 2022-03-30 09:34:32 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/180/2/logs.log 2022-03-30 09:34:32 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.45-alpha 2022-03-30 09:34:32 INFO i.a.w.DefaultNormalizationWorker(run):46 - Running normalization. 2022-03-30 09:34:32 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):122 - Running with normalization version: airbyte/normalization-snowflake:0.1.68 2022-03-30 09:34:32 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/normalization-snowflake:0.1.68 exists... 2022-03-30 09:34:33 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/normalization-snowflake:0.1.68 was found locally. 2022-03-30 09:34:33 INFO i.a.w.p.DockerProcessFactory(create):104 - Creating docker job ID: 180 2022-03-30 09:34:33 INFO i.a.w.p.DockerProcessFactory(create):155 - Preparing command: docker run --rm --init -i -w /data/180/2/normalize --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local airbyte/normalization-snowflake:0.1.68 run --integration-type snowflake --config destination_config.json --catalog destination_catalog.json 2022-03-30 09:34:34 normalization > Running: transform-config --config destination_config.json --integration-type snowflake --out /data/180/2/normalize 2022-03-30 09:34:34 normalization > Namespace(config='destination_config.json', integration_type=, out='/data/180/2/normalize') 2022-03-30 09:34:34 normalization > transform_snowflake 2022-03-30 09:34:34 normalization > Running: transform-catalog --integration-type snowflake --profile-config-dir /data/180/2/normalize --catalog destination_catalog.json --out /data/180/2/normalize/models/generated/ --json-column _airbyte_data 2022-03-30 09:34:34 normalization > Processing destination_catalog.json... 2022-03-30 09:34:34 normalization > Generating airbyte_ctes/PUBLIC/LISTS_AB1.sql from lists 2022-03-30 09:34:34 normalization > Generating airbyte_ctes/PUBLIC/LISTS_AB2.sql from lists 2022-03-30 09:34:34 normalization > Generating airbyte_ctes/PUBLIC/LISTS_AB3.sql from lists 2022-03-30 09:34:34 normalization > Generating airbyte_incremental/PUBLIC/LISTS.sql from lists 2022-03-30 09:34:34 normalization > Generating airbyte_ctes/PUBLIC/LISTS_CRICKET_AB1.sql from lists/cricket 2022-03-30 09:34:34 normalization > Generating airbyte_ctes/PUBLIC/LISTS_CRICKET_AB2.sql from lists/cricket 2022-03-30 09:34:34 normalization > Generating airbyte_ctes/PUBLIC/LISTS_CRICKET_AB3.sql from lists/cricket 2022-03-30 09:34:34 normalization > Generating airbyte_incremental/PUBLIC/LISTS_CRICKET.sql from lists/cricket 2022-03-30 09:34:34 normalization > Generating airbyte_ctes/PUBLIC/LISTS_FOOTBALL_AB1.sql from lists/football 2022-03-30 09:34:34 normalization > Generating airbyte_ctes/PUBLIC/LISTS_FOOTBALL_AB2.sql from lists/football 2022-03-30 09:34:34 normalization > Generating airbyte_ctes/PUBLIC/LISTS_FOOTBALL_AB3.sql from lists/football 2022-03-30 09:34:34 normalization > Generating airbyte_incremental/PUBLIC/LISTS_FOOTBALL.sql from lists/football 2022-03-30 09:34:34 normalization > detected no config file for ssh, assuming ssh is off. 2022-03-30 09:34:36 normalization > Running with dbt=0.21.1 2022-03-30 09:34:37 normalization > Unable to do partial parsing because ../build/partial_parse.msgpack not found 2022-03-30 09:34:38 normalization > [WARNING]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources. 2022-03-30 09:34:38 normalization > There are 2 unused configuration paths: 2022-03-30 09:34:38 normalization > - models.airbyte_utils.generated.airbyte_tables 2022-03-30 09:34:38 normalization > - models.airbyte_utils.generated.airbyte_views 2022-03-30 09:34:38 normalization > 2022-03-30 09:34:38 normalization > Found 12 models, 0 tests, 0 snapshots, 0 analyses, 504 macros, 0 operations, 0 seed files, 1 source, 0 exposures 2022-03-30 09:34:38 normalization > 2022-03-30 09:34:40 normalization > 09:34:40 | Concurrency: 5 threads (target='prod') 2022-03-30 09:34:40 normalization > 09:34:40 | 2022-03-30 09:34:43 normalization > 09:34:43 | 1 of 3 START incremental model PUBLIC.LISTS.................................................................. [RUN] 2022-03-30 09:34:46 normalization > 09:34:46 | 1 of 3 OK created incremental model PUBLIC.LISTS............................................................. [SUCCESS 1 in 3.57s] 2022-03-30 09:34:48 normalization > 09:34:48 | 2 of 3 START incremental model PUBLIC.LISTS_FOOTBALL......................................................... [RUN] 2022-03-30 09:34:49 normalization > 09:34:49 | 3 of 3 START incremental model PUBLIC.LISTS_CRICKET.......................................................... [RUN] 2022-03-30 09:34:52 normalization > 09:34:52 | 2 of 3 OK created incremental model PUBLIC.LISTS_FOOTBALL.................................................... [SUCCESS 1 in 3.14s] 2022-03-30 09:34:52 normalization > 09:34:52 | 3 of 3 OK created incremental model PUBLIC.LISTS_CRICKET..................................................... [SUCCESS 1 in 3.25s] 2022-03-30 09:34:52 normalization > 09:34:52 | 2022-03-30 09:34:52 normalization > 09:34:52 | Finished running 3 incremental models in 13.71s. 2022-03-30 09:34:52 normalization > 2022-03-30 09:34:52 normalization > Completed successfully 2022-03-30 09:34:52 normalization > 2022-03-30 09:34:52 normalization > Done. PASS=3 WARN=0 ERROR=0 SKIP=0 TOTAL=3 2022-03-30 09:34:52 INFO i.a.w.DefaultNormalizationWorker(run):69 - Normalization executed in 19 seconds. 2022-03-30 09:34:52 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2022-03-30 09:34:52 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating... 2022-03-30 09:34:52 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/180/2/logs.log 2022-03-30 09:34:52 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.45-alpha 2022-03-30 09:34:52 INFO i.a.w.DbtTransformationWorker(run):44 - Running dbt transformation. 2022-03-30 09:34:52 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):122 - Running with normalization version: airbyte/normalization-snowflake:0.1.68 2022-03-30 09:34:52 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/normalization-snowflake:0.1.68 exists... 2022-03-30 09:34:52 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/normalization-snowflake:0.1.68 was found locally. 2022-03-30 09:34:52 INFO i.a.w.p.DockerProcessFactory(create):104 - Creating docker job ID: 180 2022-03-30 09:34:52 INFO i.a.w.p.DockerProcessFactory(create):155 - Preparing command: docker run --rm --init -i -w /data/180/2/transform --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local airbyte/normalization-snowflake:0.1.68 configure-dbt --integration-type snowflake --config destination_config.json --git-repo https://github.com/Bharath-63/dbt_sports_api.git 2022-03-30 09:34:54 normalization > Running: git clone --depth 5 --single-branch $GIT_REPO git_repo 2022-03-30 09:34:54 normalization > Cloning into 'git_repo'... 2022-03-30 09:34:55 normalization > Last 5 commits in git_repo: 2022-03-30 09:34:55 normalization > 558aeea Update LISTS_FOOTBALL.sql 2022-03-30 09:34:55 normalization > d3848cf Update LISTS_CRICKET.sql 2022-03-30 09:34:55 normalization > eb51b06 Update LISTS.sql 2022-03-30 09:34:55 normalization > 725f312 Update LISTS_FOOTBALL.sql 2022-03-30 09:34:55 normalization > eaed7bc Update LISTS_CRICKET.sql 2022-03-30 09:34:55 normalization > /data/180/2/transform 2022-03-30 09:34:55 normalization > Running: transform-config --config destination_config.json --integration-type snowflake --out /data/180/2/transform 2022-03-30 09:34:55 normalization > Namespace(config='destination_config.json', integration_type=, out='/data/180/2/transform') 2022-03-30 09:34:55 normalization > transform_snowflake 2022-03-30 09:34:55 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if fishtownanalytics/dbt:1.0.0 exists... 2022-03-30 09:34:55 INFO i.a.c.i.LineGobbler(voidCall):82 - fishtownanalytics/dbt:1.0.0 was found locally. 2022-03-30 09:34:55 INFO i.a.w.p.DockerProcessFactory(create):104 - Creating docker job ID: 180 2022-03-30 09:34:55 INFO i.a.w.p.DockerProcessFactory(create):155 - Preparing command: docker run --rm --init -i -w /data/180/2/transform --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local --entrypoint /bin/bash fishtownanalytics/dbt:1.0.0 entrypoint.sh seed 2022-03-30 09:34:56 dbt > Running from /data/180/2/transform/git_repo 2022-03-30 09:34:56 dbt > detected no config file for ssh, assuming ssh is off. 2022-03-30 09:34:56 dbt > Running: dbt seed --profiles-dir=/data/180/2/transform --project-dir=/data/180/2/transform/git_repo 2022-03-30 09:34:59 dbt > 09:34:59 Running with dbt=1.0.0 2022-03-30 09:34:59 dbt > 09:34:59 Partial parse save file not found. Starting full parse. 2022-03-30 09:35:00 dbt > 09:35:00 Found 5 models, 4 tests, 0 snapshots, 0 analyses, 179 macros, 0 operations, 0 seed files, 0 sources, 0 exposures, 0 metrics 2022-03-30 09:35:00 dbt > 09:35:00 2022-03-30 09:35:00 dbt > 09:35:00 [WARNING]: Nothing to do. Try checking your model configs and model specification args 2022-03-30 09:35:00 dbt > 09:35:00 2022-03-30 09:35:00 dbt > 09:35:00 Completed successfully 2022-03-30 09:35:00 dbt > 09:35:00 2022-03-30 09:35:00 dbt > 09:35:00 Done. PASS=0 WARN=0 ERROR=0 SKIP=0 TOTAL=0 2022-03-30 09:35:00 INFO i.a.w.DbtTransformationWorker(run):64 - Dbt Transformation executed in 0. 2022-03-30 09:35:00 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2022-03-30 09:35:00 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating... 2022-03-30 09:35:00 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/180/2/logs.log 2022-03-30 09:35:00 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.45-alpha 2022-03-30 09:35:00 INFO i.a.w.DbtTransformationWorker(run):44 - Running dbt transformation. 2022-03-30 09:35:00 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):122 - Running with normalization version: airbyte/normalization-snowflake:0.1.68 2022-03-30 09:35:00 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/normalization-snowflake:0.1.68 exists... 2022-03-30 09:35:00 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/normalization-snowflake:0.1.68 was found locally. 2022-03-30 09:35:00 INFO i.a.w.p.DockerProcessFactory(create):104 - Creating docker job ID: 180 2022-03-30 09:35:00 INFO i.a.w.p.DockerProcessFactory(create):155 - Preparing command: docker run --rm --init -i -w /data/180/2/transform --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local airbyte/normalization-snowflake:0.1.68 configure-dbt --integration-type snowflake --config destination_config.json --git-repo https://github.com/Bharath-63/dbt_sports_api.git 2022-03-30 09:35:02 normalization > Running: git clone --depth 5 --single-branch $GIT_REPO git_repo 2022-03-30 09:35:02 normalization > Cloning into 'git_repo'... 2022-03-30 09:35:03 normalization > Last 5 commits in git_repo: 2022-03-30 09:35:03 normalization > 558aeea Update LISTS_FOOTBALL.sql 2022-03-30 09:35:03 normalization > d3848cf Update LISTS_CRICKET.sql 2022-03-30 09:35:03 normalization > eb51b06 Update LISTS.sql 2022-03-30 09:35:03 normalization > 725f312 Update LISTS_FOOTBALL.sql 2022-03-30 09:35:03 normalization > eaed7bc Update LISTS_CRICKET.sql 2022-03-30 09:35:03 normalization > /data/180/2/transform 2022-03-30 09:35:03 normalization > Running: transform-config --config destination_config.json --integration-type snowflake --out /data/180/2/transform 2022-03-30 09:35:03 normalization > Namespace(config='destination_config.json', integration_type=, out='/data/180/2/transform') 2022-03-30 09:35:03 normalization > transform_snowflake 2022-03-30 09:35:03 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if fishtownanalytics/dbt:1.0.0 exists... 2022-03-30 09:35:03 INFO i.a.c.i.LineGobbler(voidCall):82 - fishtownanalytics/dbt:1.0.0 was found locally. 2022-03-30 09:35:03 INFO i.a.w.p.DockerProcessFactory(create):104 - Creating docker job ID: 180 2022-03-30 09:35:03 INFO i.a.w.p.DockerProcessFactory(create):155 - Preparing command: docker run --rm --init -i -w /data/180/2/transform --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local --entrypoint /bin/bash fishtownanalytics/dbt:1.0.0 entrypoint.sh run 2022-03-30 09:35:04 dbt > Running from /data/180/2/transform/git_repo 2022-03-30 09:35:04 dbt > detected no config file for ssh, assuming ssh is off. 2022-03-30 09:35:04 dbt > Running: dbt run --profiles-dir=/data/180/2/transform --project-dir=/data/180/2/transform/git_repo 2022-03-30 09:35:07 dbt > 09:35:07 Running with dbt=1.0.0 2022-03-30 09:35:07 dbt > 09:35:07 Partial parse save file not found. Starting full parse. 2022-03-30 09:35:07 dbt > 09:35:07 Found 5 models, 4 tests, 0 snapshots, 0 analyses, 179 macros, 0 operations, 0 seed files, 0 sources, 0 exposures, 0 metrics 2022-03-30 09:35:07 dbt > 09:35:07 2022-03-30 09:35:09 dbt > 09:35:09 Concurrency: 5 threads (target='prod') 2022-03-30 09:35:09 dbt > 09:35:09 2022-03-30 09:35:09 dbt > 09:35:09 1 of 5 START view model PUBLIC.LISTS.................................................................................... [RUN] 2022-03-30 09:35:09 dbt > 09:35:09 2 of 5 START view model PUBLIC.LISTS_CRICKET............................................................................ [RUN] 2022-03-30 09:35:09 dbt > 09:35:09 3 of 5 START view model PUBLIC.LISTS_FOOTBALL........................................................................... [RUN] 2022-03-30 09:35:09 dbt > 09:35:09 4 of 5 START table model PUBLIC.my_first_dbt_model...................................................................... [RUN] 2022-03-30 09:35:11 dbt > 09:35:11 3 of 5 ERROR creating view model PUBLIC.LISTS_FOOTBALL.................................................................. [ERROR in 1.92s] 2022-03-30 09:35:11 dbt > 09:35:11 1 of 5 ERROR creating view model PUBLIC.LISTS........................................................................... [ERROR in 2.03s] 2022-03-30 09:35:11 dbt > 09:35:11 2 of 5 ERROR creating view model PUBLIC.LISTS_CRICKET................................................................... [ERROR in 2.13s] 2022-03-30 09:35:12 dbt > 09:35:12 4 of 5 OK created table model PUBLIC.my_first_dbt_model................................................................. [SUCCESS 1 in 2.66s] 2022-03-30 09:35:12 dbt > 09:35:12 5 of 5 START view model PUBLIC.my_second_dbt_model...................................................................... [RUN] 2022-03-30 09:35:12 dbt > 09:35:12 5 of 5 OK created view model PUBLIC.my_second_dbt_model................................................................. [SUCCESS 1 in 0.71s] 2022-03-30 09:35:12 dbt > 09:35:12 2022-03-30 09:35:12 dbt > 09:35:12 Finished running 4 view models, 1 table model in 4.98s. 2022-03-30 09:35:12 dbt > 09:35:12 2022-03-30 09:35:12 dbt > 09:35:12 Completed with 3 errors and 0 warnings: 2022-03-30 09:35:12 dbt > 09:35:12 2022-03-30 09:35:12 dbt > 09:35:12 Database Error in model LISTS_FOOTBALL (models/example/LISTS_FOOTBALL.sql) 2022-03-30 09:35:12 dbt > 09:35:12 001003 (42000): SQL compilation error: 2022-03-30 09:35:12 dbt > 09:35:12 syntax error line 4 at position 4 unexpected 'create'. 2022-03-30 09:35:12 dbt > 09:35:12 syntax error line 14 at position 50 unexpected ','. 2022-03-30 09:35:12 dbt > 09:35:12 compiled SQL at target/run/dbt_sports_api/models/example/LISTS_FOOTBALL.sql 2022-03-30 09:35:12 dbt > 09:35:12 2022-03-30 09:35:12 dbt > 09:35:12 Database Error in model LISTS (models/example/LISTS.sql) 2022-03-30 09:35:12 dbt > 09:35:12 001003 (42000): SQL compilation error: 2022-03-30 09:35:12 dbt > 09:35:12 syntax error line 4 at position 4 unexpected 'create'. 2022-03-30 09:35:12 dbt > 09:35:12 syntax error line 12 at position 38 unexpected ','. 2022-03-30 09:35:12 dbt > 09:35:12 compiled SQL at target/run/dbt_sports_api/models/example/LISTS.sql 2022-03-30 09:35:12 dbt > 09:35:12 2022-03-30 09:35:12 dbt > 09:35:12 Database Error in model LISTS_CRICKET (models/example/LISTS_CRICKET.sql) 2022-03-30 09:35:12 dbt > 09:35:12 001003 (42000): SQL compilation error: 2022-03-30 09:35:12 dbt > 09:35:12 syntax error line 4 at position 4 unexpected 'create'. 2022-03-30 09:35:12 dbt > 09:35:12 syntax error line 14 at position 49 unexpected ','. 2022-03-30 09:35:12 dbt > 09:35:12 compiled SQL at target/run/dbt_sports_api/models/example/LISTS_CRICKET.sql 2022-03-30 09:35:12 dbt > 09:35:12 2022-03-30 09:35:12 dbt > 09:35:12 Done. PASS=2 WARN=0 ERROR=3 SKIP=0 TOTAL=5 2022-03-30 09:35:13 INFO i.a.w.t.TemporalAttemptExecution(lambda$getWorkerThread$2):158 - Completing future exceptionally... io.airbyte.workers.WorkerException: Dbt Transformation Failed. at io.airbyte.workers.DbtTransformationWorker.run(DbtTransformationWorker.java:57) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?] at io.airbyte.workers.DbtTransformationWorker.run(DbtTransformationWorker.java:16) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?] at java.lang.Thread.run(Thread.java:833) [?:?] Caused by: io.airbyte.workers.WorkerException: DBT Transformation Failed. at io.airbyte.workers.DbtTransformationWorker.run(DbtTransformationWorker.java:54) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?] ... 3 more Suppressed: io.airbyte.workers.WorkerException: Dbt transformation process wasn't successful at io.airbyte.workers.DbtTransformationRunner.close(DbtTransformationRunner.java:134) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?] at io.airbyte.workers.DbtTransformationWorker.run(DbtTransformationWorker.java:43) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?] at io.airbyte.workers.DbtTransformationWorker.run(DbtTransformationWorker.java:16) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?] at java.lang.Thread.run(Thread.java:833) [?:?] 2022-03-30 09:35:13 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2022-03-30 09:35:13 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating... 2022-03-30 09:35:13 WARN i.t.i.a.POJOActivityTaskHandler(activityFailureToResult):307 - Activity failure. ActivityId=39667a43-23ba-367b-a915-b01cc08f5d1d, activityType=Run, attempt=1 java.lang.RuntimeException: io.temporal.serviceclient.CheckedExceptionWrapper: java.util.concurrent.ExecutionException: io.airbyte.workers.WorkerException: Dbt Transformation Failed. at io.airbyte.workers.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:233) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?] at io.airbyte.workers.temporal.sync.DbtTransformationActivityImpl.run(DbtTransformationActivityImpl.java:74) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?] at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:?] at jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77) ~[?:?] at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?] at java.lang.reflect.Method.invoke(Method.java:568) ~[?:?] at io.temporal.internal.activity.POJOActivityTaskHandler$POJOActivityInboundCallsInterceptor.execute(POJOActivityTaskHandler.java:214) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.activity.POJOActivityTaskHandler$POJOActivityImplementation.execute(POJOActivityTaskHandler.java:180) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.activity.POJOActivityTaskHandler.handle(POJOActivityTaskHandler.java:120) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:204) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:164) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:93) ~[temporal-sdk-1.8.1.jar:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) [?:?] at java.lang.Thread.run(Thread.java:833) [?:?] Caused by: io.temporal.serviceclient.CheckedExceptionWrapper: java.util.concurrent.ExecutionException: io.airbyte.workers.WorkerException: Dbt Transformation Failed. at io.temporal.serviceclient.CheckedExceptionWrapper.wrap(CheckedExceptionWrapper.java:56) ~[temporal-serviceclient-1.8.1.jar:?] at io.temporal.internal.sync.WorkflowInternal.wrap(WorkflowInternal.java:448) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.activity.Activity.wrap(Activity.java:51) ~[temporal-sdk-1.8.1.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.get(TemporalAttemptExecution.java:135) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?] at io.airbyte.workers.temporal.sync.DbtTransformationActivityImpl.lambda$run$1(DbtTransformationActivityImpl.java:100) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?] at io.airbyte.workers.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:228) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?] ... 14 more Caused by: java.util.concurrent.ExecutionException: io.airbyte.workers.WorkerException: Dbt Transformation Failed. at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) ~[?:?] at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) ~[?:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.get(TemporalAttemptExecution.java:129) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?] at io.airbyte.workers.temporal.sync.DbtTransformationActivityImpl.lambda$run$1(DbtTransformationActivityImpl.java:100) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?] at io.airbyte.workers.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:228) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?] ... 14 more Caused by: io.airbyte.workers.WorkerException: Dbt Transformation Failed. at io.airbyte.workers.DbtTransformationWorker.run(DbtTransformationWorker.java:57) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?] at io.airbyte.workers.DbtTransformationWorker.run(DbtTransformationWorker.java:16) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?] ... 1 more Caused by: io.airbyte.workers.WorkerException: DBT Transformation Failed. at io.airbyte.workers.DbtTransformationWorker.run(DbtTransformationWorker.java:54) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?] at io.airbyte.workers.DbtTransformationWorker.run(DbtTransformationWorker.java:16) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?] ... 1 more Suppressed: io.airbyte.workers.WorkerException: Dbt transformation process wasn't successful at io.airbyte.workers.DbtTransformationRunner.close(DbtTransformationRunner.java:134) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?] at io.airbyte.workers.DbtTransformationWorker.run(DbtTransformationWorker.java:43) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?] at io.airbyte.workers.DbtTransformationWorker.run(DbtTransformationWorker.java:16) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?] at java.lang.Thread.run(Thread.java:833) [?:?] 2022-03-30 09:35:13 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. errors: $.method: does not have a value in the enumeration [Standard]