upgrades (#313)

* upgrades

* quotes

.github/workflows/dbt_run_dev_refresh.yml

@@ -4,8 +4,8 @@ run-name: dbt_run_dev_refresh
 on:
   workflow_dispatch:
   schedule:
-    # Runs "at 9:00 UTC" (see https://crontab.guru)
-    - cron: '0 9 * * *'
+    # Runs "at 13:36 UTC Monday" (see https://crontab.guru)
+    - cron: '36 13 * * 1'
     
 env:
   DBT_PROFILES_DIR: ./

.github/workflows/dbt_run_scheduled_decoded_logs_history_user_abis.yml

@@ -1,12 +1,11 @@
-name: dbt_run_streamline_decoder_history
-run-name: dbt_run_streamline_decoder_history
+name: dbt_run_scheduled_decoded_logs_history_user_abis
+run-name: dbt_run_scheduled_decoded_logs_history_user_abis
 
 on:
   workflow_dispatch:
-  schedule:
-    # Runs "at 10:00 UTC AM" (see https://crontab.guru)
-    - cron: '0 10 * * *'
-    
+    branches:
+      - "main"
+
 env:
   DBT_PROFILES_DIR: ./
 
@@ -22,12 +21,10 @@ env:
 concurrency:
   group: ${{ github.workflow }}
 
-
-
 jobs:
   run_dbt_jobs:
     runs-on: ubuntu-latest
-    environment: 
+    environment:
       name: workflow_prod
 
     steps:
@@ -42,6 +39,7 @@ jobs:
         run: |
           pip install -r requirements.txt
           dbt deps
-      - name: Run DBT Jobs
+
+      - name: Kick off decoded logs history, if there are new ABIs from users
         run: |
-          dbt run --threads 8 --vars '{"STREAMLINE_INVOKE_STREAMS":True,"WAIT":120}' -m "optimism_models,tag:streamline_decoded_logs_complete" "optimism_models,tag:streamline_decoded_logs_history"
+          dbt run-operation run_decoded_logs_history

.github/workflows/dbt_run_streamline_decoded_logs_history.yml

@@ -0,0 +1,49 @@
+name: dbt_run_streamline_decoded_logs_history
+run-name: dbt_run_streamline_decoded_logs_history
+
+on:
+  workflow_dispatch:
+    branches:
+      - "main"
+
+env:
+  DBT_PROFILES_DIR: ./
+
+  ACCOUNT: "${{ vars.ACCOUNT }}"
+  ROLE: "${{ vars.ROLE }}"
+  USER: "${{ vars.USER }}"
+  PASSWORD: "${{ secrets.PASSWORD }}"
+  REGION: "${{ vars.REGION }}"
+  DATABASE: "${{ vars.DATABASE }}"
+  WAREHOUSE: "${{ vars.WAREHOUSE }}"
+  SCHEMA: "${{ vars.SCHEMA }}"
+
+concurrency:
+  group: ${{ github.workflow }}
+
+jobs:
+  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: Update complete table
+        run: |
+          dbt run -m "optimism_models,tag:streamline_decoded_logs_complete"
+
+      - name: Decode historical logs
+        run: |
+          dbt run-operation decoded_logs_history --vars '{"STREAMLINE_INVOKE_STREAMS":True}'

data/github_actions__workflows.csv

@@ -4,4 +4,6 @@ dbt_run_streamline_chainhead,"20,50 * * * *"
 dbt_run_streamline_decoder,"5,35 * * * *"
 dbt_run_scheduled_curated,"10 * * * *"
 dbt_test_intraday,"8 */4 * * *"
-dbt_test_tasks,"15 * * * *"
+dbt_test_tasks,"15 * * * *"
+dbt_run_streamline_decoded_logs_history,"5 20 * * 6"
+dbt_run_scheduled_decoded_logs_history_user_abis,"39 23 * * *"

macros/decoder/decoded_logs_history.sql

@@ -0,0 +1,126 @@
+{% macro decoded_logs_history(backfill_mode=false) %}
+
+  {%- set params = {
+      "sql_limit": var("DECODED_LOGS_HISTORY_SQL_LIMIT", 7500000),
+      "producer_batch_size": var("DECODED_LOGS_HISTORY_PRODUCER_BATCH_SIZE", 400000),
+      "worker_batch_size": var("DECODED_LOGS_HISTORY_WORKER_BATCH_SIZE", 100000),
+      "producer_limit_size": var("DECODED_LOGS_HISTORY_WORKER_BATCH_SIZE", 100000)
+  } -%}
+
+  {% set wait_time = var("DECODED_LOGS_HISTORY_WAIT_TIME", 60) %}
+
+  {% set find_months_query %}
+    SELECT 
+      DISTINCT date_trunc('month', block_timestamp)::date as month
+    FROM {{ ref('core__fact_blocks') }}
+    ORDER BY month ASC
+  {% endset %}
+
+  {% set results = run_query(find_months_query) %}
+
+  {% if execute %}
+    {% set months = results.columns[0].values() %}
+
+    {% for month in months %}
+      {% set view_name = 'decoded_logs_history_' ~ month.strftime('%Y_%m') %}
+
+      {% set create_view_query %}
+        create or replace view streamline.{{view_name}} as (
+          WITH target_blocks AS (
+              SELECT 
+                  block_number
+              FROM {{ ref('core__fact_blocks') }}
+              WHERE date_trunc('month', block_timestamp) = '{{month}}'::timestamp
+          ),
+          new_abis AS (
+              SELECT 
+                abi,
+                parent_contract_address,
+                event_signature,
+                start_block,
+                end_block
+              FROM {{ ref('silver__complete_event_abis') }} 
+              {% if not backfill_mode %}
+                WHERE inserted_timestamp > dateadd('day', -30, sysdate())
+              {% endif %}
+          ),
+          existing_logs_to_exclude AS (
+              SELECT _log_id
+              FROM {{ ref('streamline__complete_decode_logs') }} l
+              INNER JOIN target_blocks b using (block_number)
+          ),
+          candidate_logs AS (
+              SELECT 
+                  l.block_number,
+                  l.tx_hash,
+                  l.event_index,
+                  l.contract_address,
+                  l.topics,
+                  l.data,
+                  concat(l.tx_hash::string, '-', l.event_index::string) as _log_id
+              FROM target_blocks b
+              INNER JOIN {{ ref('core__fact_event_logs') }} l using (block_number)
+              WHERE l.tx_status = 'SUCCESS' and date_trunc('month', l.block_timestamp) = '{{month}}'::timestamp
+          )
+          SELECT
+            l.block_number,
+            l._log_id,
+            A.abi,
+            OBJECT_CONSTRUCT(
+              'topics', l.topics,
+              'data', l.data,
+              'address', l.contract_address
+            ) AS data
+          FROM candidate_logs l
+          INNER JOIN new_abis A
+            ON A.parent_contract_address = l.contract_address
+            AND A.event_signature = l.topics[0]::STRING
+            AND l.block_number BETWEEN A.start_block AND A.end_block
+          WHERE NOT EXISTS (
+              SELECT 1 
+              FROM existing_logs_to_exclude e 
+              WHERE e._log_id = l._log_id
+          )
+          LIMIT {{ params.sql_limit }}
+        )
+      {% endset %}
+
+      {# Create the view #}
+      {% do run_query(create_view_query) %}
+      {{ log("Created view for month " ~ month.strftime('%Y-%m'), info=True) }}
+
+      {% if var("STREAMLINE_INVOKE_STREAMS", false) %}
+        {# Check if rows exist first #}
+        {% set check_rows_query %}
+          SELECT EXISTS(SELECT 1 FROM streamline.{{view_name}} LIMIT 1)
+        {% endset %}
+        
+        {% set results = run_query(check_rows_query) %}
+        {% set has_rows = results.columns[0].values()[0] %}
+
+        {% if has_rows %}
+          {# Invoke streamline since rows exist to decode #}
+          {% set decode_query %}
+            SELECT streamline.udf_bulk_decode_logs(
+              object_construct(
+                'sql_source', '{{view_name}}',
+                'producer_batch_size', {{ params.producer_batch_size }},
+                'producer_limit_size', {{ params.producer_limit_size }})
+              );
+          {% endset %}
+
+          {% do run_query(decode_query) %}
+          {{ log("Triggered decoding for month " ~ month.strftime('%Y-%m'), info=True) }}
+
+          {# Call wait since we actually did some decoding #}
+          {% do run_query("call system$wait(" ~ wait_time ~ ")") %}
+          {{ log("Completed wait after decoding for month " ~ month.strftime('%Y-%m'), info=True) }}
+        {% else %}
+          {{ log("No rows to decode for month " ~ month.strftime('%Y-%m'), info=True) }}
+        {% endif %}
+      {% endif %}
+
+    {% endfor %}
+  {% endif %}
+
+{% endmacro %}

macros/decoder/run_decoded_logs_history.sql

@@ -0,0 +1,29 @@
+{% macro run_decoded_logs_history() %}
+
+{% set check_for_new_user_abis_query %}
+    select 1
+    from {{ ref('silver__user_verified_abis') }}
+    where _inserted_timestamp::date = sysdate()::date
+    and dayname(sysdate()) <> 'Sat'
+{% endset %}
+
+{% set results = run_query(check_for_new_user_abis_query) %}
+
+{% if execute %}
+    {% set new_user_abis = results.columns[0].values()[0] %}
+    
+    {% if new_user_abis %}
+        {% set invoke_workflow_query %}
+            SELECT
+                github_actions.workflow_dispatches(
+                    'FlipsideCrypto',
+                    'optimism-models',
+                    'dbt_run_streamline_decoded_logs_history.yml',
+                    NULL
+                )
+        {% endset %}
+        
+        {% do run_query(invoke_workflow_query) %}
+    {% endif %}
+{% endif %}
+{% endmacro %}

models/github_actions/github_actions__current_task_status.yml

@@ -7,6 +7,8 @@ models:
           - dbt_expectations.expect_column_values_to_be_in_set:
               value_set:
                 - TRUE
+              config: 
+                  severity: warn
       - name: SUCCESSES
         tests:
           - dbt_expectations.expect_column_values_to_be_in_set:

models/streamline/silver/decoder/history/streamline__decode_logs_history_00000001_03021566.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0100712898_0102810202.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0102810205_0103571346.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_010309246_011523667.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0103571347_0104571347.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0104571348_0105571348.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0105571349_0106571349.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0106571350_0107571350.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0107571351_0108571351.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0108571352_0109571352.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0109571353_0110571353.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0110571354_0111571354.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0111571355_0112571355.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0112571356_0113571356.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0113571357_0114571357.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0114571358_0115571358.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_011523669_012507639.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0115571359_0116571359.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0116571360_0117571360.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0117571361_0118571361.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0118571362_0119571362.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0119571363_0120571363.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0120571364_0121571364.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0121571365_0122571365.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0122571366_0123571366.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0123571367_0124371367.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0124371368_0125171368.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_012507640_013665291.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0125171369_0125971369.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0125971370_0126771370.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0126771371_0127571371.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0127571372_0128371372.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0128371373_0129171373.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0129171374_0129971374.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0129971375_0130771375.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0130771376_0131571376.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0131571377_0132371377.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0132371378_0133171378.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0133171379_0133971379.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0133971380_0134771380.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0134771381_0135571381.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0135571382_0136371382.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0136371383_0137171383.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_013665292_014900517.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0137171384_0137971384.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0137971385_0138771385.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0138771386_0139571386.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0139571387_0140371387.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0140371388_0141171388.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0141171389_0141971389.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0141971390_0142771390.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0142771391_0143571391.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0143571392_0144371392.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0144371393_0145171393.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0145171394_0145971394.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0145971395_0146771395.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0146771396_0147571396.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0147571397_0148371397.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0148371398_0149171398.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_014900518_015881824.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0149171399_0149971399.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0149971400_0150771400.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0150771401_0151571401.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0151571402_0152371402.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0152371403_0153171403.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0153171404_0153971404.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0153971405_0154771405.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0154771406_0155571406.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0155571407_0156371407.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0156371408_0157171408.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0157171409_0157971409.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0157971410_0158771410.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0158771411_0159571411.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_015881825_016703952.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0159571412_0160371412.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0160371413_0161171413.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0161171414_0161971414.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0161971415_0162771415.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0162771416_0163571416.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0163571417_0164371417.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0164371418_0165171418.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0165171419_0165971419.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0165971420_0166771420.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0166771421_0167571421.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_016703953_017379884.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0167571422_0168371422.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0168371423_0169171423.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0169171424_0169971424.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0169971425_0170771425.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0170771426_0171571426.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0171571427_0172371427.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0172371428_0173171428.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}

models/streamline/silver/decoder/history/streamline__decode_logs_history_0173171429_0173971429.sql

@@ -1,12 +0,0 @@
-{{ config (
-    materialized = "view",
-    post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
-    tags = ['streamline_decoded_logs_history']
-) }}
-
-{% set start = this.identifier.split("_") [-2] %}
-{% set stop = this.identifier.split("_") [-1] %}
-{{ fsc_utils.decode_logs_history(
-    start,
-    stop
-) }}