reset external query model

This commit is contained in:
Jack Forgash 2023-08-01 14:15:00 -06:00
parent d5c321c3c5
commit c7e7f2b8bb

View File

@ -80,42 +80,24 @@ WHERE
table_name => '{{ source( "bronze_streamline", model) }}'
)
) A
),
external_table_query AS (
SELECT
{{ unique_key }},
DATA,
MD5(
CAST(
COALESCE(CAST({{ unique_key }} AS text), '' :: STRING) AS text
)
) AS id,
{{ partition_name }},
VALUE AS VALUE
FROM
{{ source(
"bronze_streamline",
model
) }}
WHERE
{{ partition_name }} >= (
SELECT
MIN(
{{ partition_name }}
)
FROM
meta
)
)
SELECT
{{ unique_key }},
DATA,
_inserted_timestamp,
id,
MD5(
CAST(
COALESCE(CAST({{ unique_key }} AS text), '' :: STRING) AS text
)
) AS id,
s.{{ partition_name }},
s.value AS VALUE
FROM
external_table_query s
{{ source(
"bronze_streamline",
model
) }}
s
JOIN meta b
ON b.file_name = metadata$filename
AND b.{{ partition_name }} = s.{{ partition_name }}