decoder history tags and workflows

.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"
+          dbt run -m "blast_models,tag:curated" "fsc_evm,tag:curated"

.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"
+          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"

.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"

.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"
+          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"

.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: ./

.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
   
 
 

.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
+  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"

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 #}

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 #}

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 #}

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 #}

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 #}

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 #}

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 #}

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 #}

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 #}

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 #}

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 #}

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 #}

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 #}

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 #}

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 #}

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 #}

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 #}

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 #}

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 #}

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 #}

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 #}

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 #}

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 #}

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 #}

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 #}

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 #}

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 #}

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 #}

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 #}

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 #}

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 #}

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 #}

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 #}

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 #}

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 #}

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 #}

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 #}

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 #}

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 #}

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 #}

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 #}

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 #}

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 #}