reworked for bytecode matching (#355)

* reworked for bytecode matching

* add tx_hash to created

* unique bytecode + bytecode in silver

* unique

* add var for row limit

* update history / check for dupe ABIs on bytecodes

* exclude dupe bytecode matches

* lower row limit

.github/workflows/dbt_run_streamline_decoder_history.yml

@@ -41,4 +41,4 @@ jobs:
           dbt deps
       - name: Run DBT Jobs
         run: |
-          dbt run --threads 8 --vars '{"STREAMLINE_INVOKE_STREAMS":True,"WAIT":600}' -m models/silver/streamline/decoder/history
+          dbt run --threads 8 --vars '{"STREAMLINE_INVOKE_STREAMS":True,"WAIT":600,"row_limit":2000000}' -m models/silver/streamline/decoder/history

models/silver/abis/silver__abis.sql

@@ -0,0 +1,109 @@
+{{ config (
+    materialized = "incremental",
+    unique_key = "contract_address",
+    post_hook = "ALTER TABLE {{ this }} ADD SEARCH OPTIMIZATION on equality(contract_address)"
+) }}
+
+WITH verified_abis AS (
+
+    SELECT
+        contract_address,
+        DATA,
+        _inserted_timestamp,
+        abi_source,
+        discord_username,
+        abi_hash,
+        1 AS priority
+    FROM
+        {{ ref('silver__verified_abis') }}
+
+{% if is_incremental() %}
+WHERE
+    _inserted_timestamp >= (
+        SELECT
+            MAX(
+                _inserted_timestamp
+            )
+        FROM
+            {{ this }}
+        WHERE
+            abi_source <> 'bytecode_matched'
+    )
+{% endif %}
+),
+bytecode_abis AS (
+    SELECT
+        contract_address,
+        abi,
+        abi_hash,
+        'bytecode_matched' AS abi_source,
+        NULL AS discord_username,
+        _inserted_timestamp,
+        2 AS priority
+    FROM
+        {{ ref('silver__bytecode_abis') }}
+    WHERE
+        NOT bytecode_dupe
+
+{% if is_incremental() %}
+AND _inserted_timestamp >= (
+    SELECT
+        MAX(
+            _inserted_timestamp
+        )
+    FROM
+        {{ this }}
+    WHERE
+        abi_source = 'bytecode_matched'
+)
+{% endif %}
+),
+all_abis AS (
+    SELECT
+        contract_address,
+        DATA,
+        _inserted_timestamp,
+        abi_source,
+        discord_username,
+        abi_hash,
+        priority
+    FROM
+        verified_abis
+    UNION
+    SELECT
+        contract_address,
+        abi AS DATA,
+        _inserted_timestamp,
+        abi_source,
+        discord_username,
+        abi_hash,
+        priority
+    FROM
+        bytecode_abis
+),
+priority_abis AS (
+    SELECT
+        contract_address,
+        DATA,
+        _inserted_timestamp,
+        abi_source,
+        discord_username,
+        abi_hash,
+        priority
+    FROM
+        all_abis qualify(ROW_NUMBER() over(PARTITION BY contract_address
+    ORDER BY
+        priority ASC)) = 1
+)
+SELECT
+    p.contract_address,
+    p.data,
+    p._inserted_timestamp,
+    p.abi_source,
+    p.discord_username,
+    p.abi_hash,
+    created_contract_input AS bytecode
+FROM
+    priority_abis p
+    LEFT JOIN {{ ref('silver__created_contracts') }}
+    ON p.contract_address = created_contract_address

models/silver/abis/silver__bytecode_abis.sql

@@ -0,0 +1,86 @@
+{{ config (
+    materialized = "incremental",
+    unique_key = "abi_id"
+) }}
+
+WITH bytecodes AS (
+
+    SELECT
+        created_contract_address AS contract_address,
+        A.data AS abi,
+        created_contract_input AS bytecode,
+        abi_hash
+    FROM
+        {{ ref('silver__created_contracts') }}
+        LEFT JOIN {{ ref('silver__verified_abis') }} A
+        ON A.contract_address = created_contract_address
+
+{% if is_incremental() %}
+AND created_contract_address NOT IN (
+    SELECT
+        contract_address
+    FROM
+        {{ this }}
+)
+{% endif %}
+),
+contracts_missing_abis AS (
+    SELECT
+        contract_address,
+        bytecode
+    FROM
+        bytecodes
+    WHERE
+        abi_hash IS NULL
+),
+bytecode_abis AS (
+    SELECT
+        *,
+        ROW_NUMBER() over(
+            PARTITION BY bytecode
+            ORDER BY
+                abi_length DESC
+        ) AS abi_row_no
+    FROM
+        (
+            SELECT
+                DISTINCT bytecode,
+                abi,
+                abi_hash,
+                LENGTH(abi) AS abi_length
+            FROM
+                bytecodes
+            WHERE
+                abi_hash IS NOT NULL
+        )
+),
+dupe_check AS (
+    SELECT
+        bytecode,
+        COUNT(*) AS num_abis
+    FROM
+        bytecode_abis
+    GROUP BY
+        bytecode
+    HAVING
+        COUNT(*) > 1
+)
+SELECT
+    contract_address,
+    abi,
+    abi_hash,
+    SYSDATE() AS _inserted_timestamp,
+    abi_row_no,
+    CONCAT(
+        contract_address,
+        '-',
+        abi_row_no
+    ) AS abi_id,
+    CASE
+        WHEN num_abis > 1 THEN TRUE
+        ELSE FALSE
+    END AS bytecode_dupe
+FROM
+    contracts_missing_abis
+    JOIN bytecode_abis USING (bytecode)
+    LEFT JOIN dupe_check USING (bytecode)

models/silver/abis/silver__bytecode_abis.yml

@@ -0,0 +1,7 @@
+version: 2
+models:
+  - name: silver__bytecode_abis
+    tests:
+      - dbt_utils.unique_combination_of_columns:
+          combination_of_columns:
+            - ABI_ID

models/silver/abis/silver__verified_abis.yml

@@ -0,0 +1,7 @@
+version: 2
+models:
+  - name: silver__verified_abis
+    tests:
+      - dbt_utils.unique_combination_of_columns:
+          combination_of_columns:
+            - CONTRACT_ADDRESS

models/silver/silver__created_contracts.sql

@@ -0,0 +1,35 @@
+{{ config (
+    materialized = "incremental",
+    unique_key = "created_contract_address"
+) }}
+
+SELECT
+    block_number,
+    block_timestamp,
+    tx_hash,
+    to_address AS created_contract_address,
+    from_address AS creator_address,
+    input AS created_contract_input,
+    _inserted_timestamp
+FROM
+    {{ ref('silver__traces') }}
+WHERE
+    TYPE ILIKE 'create%'
+    AND to_address IS NOT NULL
+    AND input IS NOT NULL
+    AND input != '0x'
+
+{% if is_incremental() %}
+AND _inserted_timestamp >= (
+    SELECT
+        MAX(
+            _inserted_timestamp
+        )
+    FROM
+        {{ this }}
+)
+{% endif %}
+
+qualify(ROW_NUMBER() over(PARTITION BY created_contract_address
+ORDER BY
+    _inserted_timestamp DESC)) = 1

models/silver/silver__created_contracts.yml

@@ -0,0 +1,27 @@
+version: 2
+models:
+  - name: silver__created_contracts
+    tests:
+      - dbt_utils.unique_combination_of_columns:
+          combination_of_columns:
+            - created_contract_address
+    columns:
+      - name: BLOCK_TIMESTAMP
+        tests:
+          - not_null
+          - dbt_expectations.expect_row_values_to_have_recent_data:
+              datepart: day
+              interval: 1
+          - dbt_expectations.expect_column_values_to_be_in_type_list:
+              column_type_list:
+                - TIMESTAMP_NTZ
+      - name: _INSERTED_TIMESTAMP
+        tests:
+          - not_null
+          - dbt_expectations.expect_row_values_to_have_recent_data:
+              datepart: day
+              interval: 1
+          - dbt_expectations.expect_column_values_to_be_in_type_list:
+              column_type_list:
+                - TIMESTAMP_NTZ
+     

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}

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

@@ -1,6 +1,6 @@
 {{ 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', 7500000))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()]
+    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()]
 ) }}
 
 {% set start = this.identifier.split("_") [-2] %}