From e587b8f5f3605f25a565fb74cde525ecd430eb06 Mon Sep 17 00:00:00 2001
From: Austin <93135983+austinFlipside@users.noreply.github.com>
Date: Thu, 17 Oct 2024 16:29:50 -0400
Subject: [PATCH] new files (#401)

---
 ...line__decode_logs_history_061850178_062150178.sql | 12 ++++++++++++
 ...line__decode_logs_history_062150179_062350179.sql | 12 ++++++++++++
 ...line__decode_logs_history_062350180_062550180.sql | 12 ++++++++++++
 ...line__decode_logs_history_062550181_062750181.sql | 12 ++++++++++++
 ...line__decode_logs_history_062750182_062950182.sql | 12 ++++++++++++
 ...line__decode_logs_history_062950183_063150183.sql | 12 ++++++++++++
 ...line__decode_logs_history_063150184_064150184.sql | 12 ++++++++++++
 ...line__decode_logs_history_064150185_065150185.sql | 12 ++++++++++++
 ...line__decode_logs_history_065150186_066150186.sql | 12 ++++++++++++
 ...line__decode_logs_history_066150187_067150187.sql | 12 ++++++++++++
 ...line__decode_logs_history_067150188_068150188.sql | 12 ++++++++++++
 ...line__decode_logs_history_068150189_069150189.sql | 12 ++++++++++++
 12 files changed, 144 insertions(+)
 create mode 100644 models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_061850178_062150178.sql
 create mode 100644 models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_062150179_062350179.sql
 create mode 100644 models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_062350180_062550180.sql
 create mode 100644 models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_062550181_062750181.sql
 create mode 100644 models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_062750182_062950182.sql
 create mode 100644 models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_062950183_063150183.sql
 create mode 100644 models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_063150184_064150184.sql
 create mode 100644 models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_064150185_065150185.sql
 create mode 100644 models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_065150186_066150186.sql
 create mode 100644 models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_066150187_067150187.sql
 create mode 100644 models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_067150188_068150188.sql
 create mode 100644 models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_068150189_069150189.sql

diff --git a/models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_061850178_062150178.sql b/models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_061850178_062150178.sql
new file mode 100644
index 00000000..23145e9a
--- /dev/null
+++ b/models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_061850178_062150178.sql
@@ -0,0 +1,12 @@
+{{ 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_range_6']
+) }}
+
+{% set start = this.identifier.split("_") [-2] %}
+{% set stop = this.identifier.split("_") [-1] %}
+{{ fsc_utils.decode_logs_history(
+    start,
+    stop
+) }}
diff --git a/models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_062150179_062350179.sql b/models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_062150179_062350179.sql
new file mode 100644
index 00000000..23145e9a
--- /dev/null
+++ b/models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_062150179_062350179.sql
@@ -0,0 +1,12 @@
+{{ 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_range_6']
+) }}
+
+{% set start = this.identifier.split("_") [-2] %}
+{% set stop = this.identifier.split("_") [-1] %}
+{{ fsc_utils.decode_logs_history(
+    start,
+    stop
+) }}
diff --git a/models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_062350180_062550180.sql b/models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_062350180_062550180.sql
new file mode 100644
index 00000000..23145e9a
--- /dev/null
+++ b/models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_062350180_062550180.sql
@@ -0,0 +1,12 @@
+{{ 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_range_6']
+) }}
+
+{% set start = this.identifier.split("_") [-2] %}
+{% set stop = this.identifier.split("_") [-1] %}
+{{ fsc_utils.decode_logs_history(
+    start,
+    stop
+) }}
diff --git a/models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_062550181_062750181.sql b/models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_062550181_062750181.sql
new file mode 100644
index 00000000..23145e9a
--- /dev/null
+++ b/models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_062550181_062750181.sql
@@ -0,0 +1,12 @@
+{{ 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_range_6']
+) }}
+
+{% set start = this.identifier.split("_") [-2] %}
+{% set stop = this.identifier.split("_") [-1] %}
+{{ fsc_utils.decode_logs_history(
+    start,
+    stop
+) }}
diff --git a/models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_062750182_062950182.sql b/models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_062750182_062950182.sql
new file mode 100644
index 00000000..23145e9a
--- /dev/null
+++ b/models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_062750182_062950182.sql
@@ -0,0 +1,12 @@
+{{ 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_range_6']
+) }}
+
+{% set start = this.identifier.split("_") [-2] %}
+{% set stop = this.identifier.split("_") [-1] %}
+{{ fsc_utils.decode_logs_history(
+    start,
+    stop
+) }}
diff --git a/models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_062950183_063150183.sql b/models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_062950183_063150183.sql
new file mode 100644
index 00000000..23145e9a
--- /dev/null
+++ b/models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_062950183_063150183.sql
@@ -0,0 +1,12 @@
+{{ 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_range_6']
+) }}
+
+{% set start = this.identifier.split("_") [-2] %}
+{% set stop = this.identifier.split("_") [-1] %}
+{{ fsc_utils.decode_logs_history(
+    start,
+    stop
+) }}
diff --git a/models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_063150184_064150184.sql b/models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_063150184_064150184.sql
new file mode 100644
index 00000000..23145e9a
--- /dev/null
+++ b/models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_063150184_064150184.sql
@@ -0,0 +1,12 @@
+{{ 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_range_6']
+) }}
+
+{% set start = this.identifier.split("_") [-2] %}
+{% set stop = this.identifier.split("_") [-1] %}
+{{ fsc_utils.decode_logs_history(
+    start,
+    stop
+) }}
diff --git a/models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_064150185_065150185.sql b/models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_064150185_065150185.sql
new file mode 100644
index 00000000..23145e9a
--- /dev/null
+++ b/models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_064150185_065150185.sql
@@ -0,0 +1,12 @@
+{{ 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_range_6']
+) }}
+
+{% set start = this.identifier.split("_") [-2] %}
+{% set stop = this.identifier.split("_") [-1] %}
+{{ fsc_utils.decode_logs_history(
+    start,
+    stop
+) }}
diff --git a/models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_065150186_066150186.sql b/models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_065150186_066150186.sql
new file mode 100644
index 00000000..23145e9a
--- /dev/null
+++ b/models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_065150186_066150186.sql
@@ -0,0 +1,12 @@
+{{ 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_range_6']
+) }}
+
+{% set start = this.identifier.split("_") [-2] %}
+{% set stop = this.identifier.split("_") [-1] %}
+{{ fsc_utils.decode_logs_history(
+    start,
+    stop
+) }}
diff --git a/models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_066150187_067150187.sql b/models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_066150187_067150187.sql
new file mode 100644
index 00000000..23145e9a
--- /dev/null
+++ b/models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_066150187_067150187.sql
@@ -0,0 +1,12 @@
+{{ 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_range_6']
+) }}
+
+{% set start = this.identifier.split("_") [-2] %}
+{% set stop = this.identifier.split("_") [-1] %}
+{{ fsc_utils.decode_logs_history(
+    start,
+    stop
+) }}
diff --git a/models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_067150188_068150188.sql b/models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_067150188_068150188.sql
new file mode 100644
index 00000000..23145e9a
--- /dev/null
+++ b/models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_067150188_068150188.sql
@@ -0,0 +1,12 @@
+{{ 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_range_6']
+) }}
+
+{% set start = this.identifier.split("_") [-2] %}
+{% set stop = this.identifier.split("_") [-1] %}
+{{ fsc_utils.decode_logs_history(
+    start,
+    stop
+) }}
diff --git a/models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_068150189_069150189.sql b/models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_068150189_069150189.sql
new file mode 100644
index 00000000..23145e9a
--- /dev/null
+++ b/models/streamline/silver/decoder/history/range_6/streamline__decode_logs_history_068150189_069150189.sql
@@ -0,0 +1,12 @@
+{{ 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_range_6']
+) }}
+
+{% set start = this.identifier.split("_") [-2] %}
+{% set stop = this.identifier.split("_") [-1] %}
+{{ fsc_utils.decode_logs_history(
+    start,
+    stop
+) }}