diff --git a/.github/workflows/dbt_run_scheduled_curated.yml b/.github/workflows/dbt_run_scheduled_curated.yml index 3ecb1c0..2d42d01 100644 --- a/.github/workflows/dbt_run_scheduled_curated.yml +++ b/.github/workflows/dbt_run_scheduled_curated.yml @@ -43,4 +43,4 @@ jobs: dbt deps - name: Run DBT Jobs run: | - dbt run -m "blast_models,tag:curated" \ No newline at end of file + dbt run -m "blast_models,tag:curated" "fsc_evm,tag:curated" \ No newline at end of file diff --git a/.github/workflows/dbt_run_scheduled_non_realtime.yml b/.github/workflows/dbt_run_scheduled_non_realtime.yml index 697f84a..bc89602 100644 --- a/.github/workflows/dbt_run_scheduled_non_realtime.yml +++ b/.github/workflows/dbt_run_scheduled_non_realtime.yml @@ -43,4 +43,4 @@ jobs: dbt deps - name: Run DBT Jobs run: | - dbt run --vars '{"STREAMLINE_INVOKE_STREAMS":True}' -m "blast_models,tag:non_realtime" "blast_models,tag:streamline_decoded_logs_complete" "blast_models,tag:streamline_decoded_logs_realtime" \ No newline at end of file + dbt run --vars '{"STREAMLINE_INVOKE_STREAMS":True}' -m "blast_models,tag:non_realtime" "fsc_evm,tag:silver_core" "fsc_evm,tag:gold_core" "fsc_evm,tag:streamline_decoded_logs_complete" "fsc_evm,tag:streamline_decoded_logs_realtime" \ No newline at end of file diff --git a/.github/workflows/dbt_run_streamline_chainhead.yml b/.github/workflows/dbt_run_streamline_chainhead.yml index 71cc7cc..bbf3469 100644 --- a/.github/workflows/dbt_run_streamline_chainhead.yml +++ b/.github/workflows/dbt_run_streamline_chainhead.yml @@ -43,4 +43,4 @@ jobs: dbt deps - name: Run DBT Jobs run: | - dbt run --vars '{"STREAMLINE_INVOKE_STREAMS":True}' -m "blast_models,tag:streamline_core_complete" "blast_models,tag:streamline_core_realtime" + dbt run --vars '{"STREAMLINE_INVOKE_STREAMS":True}' -m "fsc_evm,tag:streamline_core_complete" "fsc_evm,tag:streamline_core_realtime" diff --git a/.github/workflows/dbt_run_streamline_decoder_history.yml b/.github/workflows/dbt_run_streamline_decoder_history.yml index 001afe1..d3dc27c 100644 --- a/.github/workflows/dbt_run_streamline_decoder_history.yml +++ b/.github/workflows/dbt_run_streamline_decoder_history.yml @@ -44,4 +44,4 @@ jobs: dbt deps - name: Run DBT Jobs run: | - dbt run --threads 8 --vars '{"STREAMLINE_INVOKE_STREAMS":True,"WAIT":120}' -m "blast_models,tag:streamline_decoded_logs_complete" "blast_models,tag:streamline_decoded_logs_history" \ No newline at end of file + dbt run --threads 8 --vars '{"STREAMLINE_INVOKE_STREAMS":True,"WAIT":120}' -m "fsc_evm,tag:streamline_decoded_logs_complete" "blast_models,tag:streamline_decoded_logs_history" \ No newline at end of file diff --git a/.github/workflows/dbt_run_streamline_history_adhoc.yml b/.github/workflows/dbt_run_streamline_history_adhoc.yml index f197ccf..5dd99f1 100644 --- a/.github/workflows/dbt_run_streamline_history_adhoc.yml +++ b/.github/workflows/dbt_run_streamline_history_adhoc.yml @@ -29,7 +29,7 @@ on: description: 'DBT Run Command' required: true options: - - dbt run --vars '{"STREAMLINE_INVOKE_STREAMS":True}' -m "blast_models,tag:streamline_core_history" "blast_models,tag:streamline_core_complete" + - dbt run --vars '{"STREAMLINE_INVOKE_STREAMS":True}' -m "fsc_evm,tag:streamline_core_history" "fsc_evm,tag:streamline_core_history_receipts" "fsc_evm,tag:streamline_core_complete" "fsc_evm,tag:streamline_core_complete_receipts" env: DBT_PROFILES_DIR: ./ diff --git a/.github/workflows/dbt_test_daily.yml b/.github/workflows/dbt_test_daily.yml index e345855..076424a 100644 --- a/.github/workflows/dbt_test_daily.yml +++ b/.github/workflows/dbt_test_daily.yml @@ -44,7 +44,7 @@ jobs: dbt deps - name: Run DBT Jobs run: | - dbt test --exclude "blast_models,tag:full_test" "blast_models,tag:recent_test" "blast_models,tag:gha_tasks" livequery_models + dbt test --exclude "blast_models,tag:full_test" "blast_models,tag:recent_test" "fsc_evm,tag:gha_tasks" livequery_models diff --git a/.github/workflows/dbt_test_tasks.yml b/.github/workflows/dbt_test_tasks.yml index a1ffffa..9794a27 100644 --- a/.github/workflows/dbt_test_tasks.yml +++ b/.github/workflows/dbt_test_tasks.yml @@ -24,6 +24,24 @@ concurrency: jobs: - called_workflow_template: - uses: FlipsideCrypto/analytics-workflow-templates/.github/workflows/dbt_test_tasks.yml@main - secrets: inherit \ No newline at end of file + run_dbt_jobs: + runs-on: ubuntu-latest + environment: + name: workflow_prod + + steps: + - uses: actions/checkout@v3 + + - uses: actions/setup-python@v4 + with: + python-version: "3.10" + cache: "pip" + + - name: install dependencies + run: | + pip install -r requirements.txt + dbt deps + + - name: Run DBT Jobs + run: | + dbt test -m "fsc_evm,tag:gha_tasks" \ No newline at end of file diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_000000001_000100001.sql b/models/streamline/decoder/history/streamline__decode_logs_history_000000001_000100001.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_000000001_000100001.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_000000001_000100001.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_000100002_000200002.sql b/models/streamline/decoder/history/streamline__decode_logs_history_000100002_000200002.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_000100002_000200002.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_000100002_000200002.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_000200003_000300003.sql b/models/streamline/decoder/history/streamline__decode_logs_history_000200003_000300003.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_000200003_000300003.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_000200003_000300003.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_000300004_000400004.sql b/models/streamline/decoder/history/streamline__decode_logs_history_000300004_000400004.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_000300004_000400004.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_000300004_000400004.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_000400005_000500005.sql b/models/streamline/decoder/history/streamline__decode_logs_history_000400005_000500005.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_000400005_000500005.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_000400005_000500005.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_000500006_000600006.sql b/models/streamline/decoder/history/streamline__decode_logs_history_000500006_000600006.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_000500006_000600006.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_000500006_000600006.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_000600007_000700007.sql b/models/streamline/decoder/history/streamline__decode_logs_history_000600007_000700007.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_000600007_000700007.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_000600007_000700007.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_000700008_000800008.sql b/models/streamline/decoder/history/streamline__decode_logs_history_000700008_000800008.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_000700008_000800008.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_000700008_000800008.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_000800009_000900009.sql b/models/streamline/decoder/history/streamline__decode_logs_history_000800009_000900009.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_000800009_000900009.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_000800009_000900009.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_000900010_001000010.sql b/models/streamline/decoder/history/streamline__decode_logs_history_000900010_001000010.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_000900010_001000010.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_000900010_001000010.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_001000011_001100011.sql b/models/streamline/decoder/history/streamline__decode_logs_history_001000011_001100011.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_001000011_001100011.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_001000011_001100011.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_001100012_001200012.sql b/models/streamline/decoder/history/streamline__decode_logs_history_001100012_001200012.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_001100012_001200012.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_001100012_001200012.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_001200013_001300013.sql b/models/streamline/decoder/history/streamline__decode_logs_history_001200013_001300013.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_001200013_001300013.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_001200013_001300013.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_001300014_001400014.sql b/models/streamline/decoder/history/streamline__decode_logs_history_001300014_001400014.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_001300014_001400014.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_001300014_001400014.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_001400015_001500015.sql b/models/streamline/decoder/history/streamline__decode_logs_history_001400015_001500015.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_001400015_001500015.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_001400015_001500015.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_001500016_001600016.sql b/models/streamline/decoder/history/streamline__decode_logs_history_001500016_001600016.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_001500016_001600016.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_001500016_001600016.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_001600017_001700017.sql b/models/streamline/decoder/history/streamline__decode_logs_history_001600017_001700017.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_001600017_001700017.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_001600017_001700017.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_001700018_001800018.sql b/models/streamline/decoder/history/streamline__decode_logs_history_001700018_001800018.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_001700018_001800018.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_001700018_001800018.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_001800019_001900019.sql b/models/streamline/decoder/history/streamline__decode_logs_history_001800019_001900019.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_001800019_001900019.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_001800019_001900019.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_001900020_002000020.sql b/models/streamline/decoder/history/streamline__decode_logs_history_001900020_002000020.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_001900020_002000020.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_001900020_002000020.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_002000021_002100021.sql b/models/streamline/decoder/history/streamline__decode_logs_history_002000021_002100021.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_002000021_002100021.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_002000021_002100021.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_002100022_002200022.sql b/models/streamline/decoder/history/streamline__decode_logs_history_002100022_002200022.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_002100022_002200022.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_002100022_002200022.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_002200023_002300023.sql b/models/streamline/decoder/history/streamline__decode_logs_history_002200023_002300023.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_002200023_002300023.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_002200023_002300023.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_002300024_002400024.sql b/models/streamline/decoder/history/streamline__decode_logs_history_002300024_002400024.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_002300024_002400024.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_002300024_002400024.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_002400025_002500000.sql b/models/streamline/decoder/history/streamline__decode_logs_history_002400025_002500000.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_002400025_002500000.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_002400025_002500000.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_002500001_005000000.sql b/models/streamline/decoder/history/streamline__decode_logs_history_002500001_005000000.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_002500001_005000000.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_002500001_005000000.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_005000001_007500000.sql b/models/streamline/decoder/history/streamline__decode_logs_history_005000001_007500000.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_005000001_007500000.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_005000001_007500000.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_010000001_012500000.sql b/models/streamline/decoder/history/streamline__decode_logs_history_010000001_012500000.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_010000001_012500000.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_010000001_012500000.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_012500001_015000000.sql b/models/streamline/decoder/history/streamline__decode_logs_history_012500001_015000000.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_012500001_015000000.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_012500001_015000000.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_015000001_017500000.sql b/models/streamline/decoder/history/streamline__decode_logs_history_015000001_017500000.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_015000001_017500000.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_015000001_017500000.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_017500001_020000000.sql b/models/streamline/decoder/history/streamline__decode_logs_history_017500001_020000000.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_017500001_020000000.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_017500001_020000000.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_020000001_022500000.sql b/models/streamline/decoder/history/streamline__decode_logs_history_020000001_022500000.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_020000001_022500000.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_020000001_022500000.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_022500001_025000000.sql b/models/streamline/decoder/history/streamline__decode_logs_history_022500001_025000000.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_022500001_025000000.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_022500001_025000000.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_025000001_027500000.sql b/models/streamline/decoder/history/streamline__decode_logs_history_025000001_027500000.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_025000001_027500000.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_025000001_027500000.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_027500001_030000000.sql b/models/streamline/decoder/history/streamline__decode_logs_history_027500001_030000000.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_027500001_030000000.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_027500001_030000000.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_030000001_032500000.sql b/models/streamline/decoder/history/streamline__decode_logs_history_030000001_032500000.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_030000001_032500000.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_030000001_032500000.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_032500001_035000000.sql b/models/streamline/decoder/history/streamline__decode_logs_history_032500001_035000000.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_032500001_035000000.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_032500001_035000000.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_035000001_037500000.sql b/models/streamline/decoder/history/streamline__decode_logs_history_035000001_037500000.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_035000001_037500000.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_035000001_037500000.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_037500001_040000000.sql b/models/streamline/decoder/history/streamline__decode_logs_history_037500001_040000000.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_037500001_040000000.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_037500001_040000000.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_040000001_042500000.sql b/models/streamline/decoder/history/streamline__decode_logs_history_040000001_042500000.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_040000001_042500000.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_040000001_042500000.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_042500001_045000000.sql b/models/streamline/decoder/history/streamline__decode_logs_history_042500001_045000000.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_042500001_045000000.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_042500001_045000000.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_045000001_047500000.sql b/models/streamline/decoder/history/streamline__decode_logs_history_045000001_047500000.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_045000001_047500000.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_045000001_047500000.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #} diff --git a/models/streamline/decoder/history/streamline__decode_logs_history_047500001_050000000.sql b/models/streamline/decoder/history/streamline__decode_logs_history_047500001_050000000.sql index 43fb9c3..a6bd158 100644 --- a/models/streamline/decoder/history/streamline__decode_logs_history_047500001_050000000.sql +++ b/models/streamline/decoder/history/streamline__decode_logs_history_047500001_050000000.sql @@ -29,7 +29,7 @@ params = streamline_params ), fsc_utils.if_data_call_wait()], - tags = ['streamline_' ~ model_name.lower() ~ model_type.lower()] + tags = ['streamline_decoded_logs_history'] ) }} {# Set up the range of blocks to decode #}