Lisätty onnistuneiden ajojen kirjanpito

dbt/dbt_project.yml

@@ -31,7 +31,10 @@ models:
         - columns: ['dw_metadata_stg_stored_at']
       +docs:
         node_color: "#00008b"
-
+      +pre-hook:
+        - "{{ stg_start() }}"
+      +post-hook:
+        - "{{ stg_end() }}"
     dw:
       +schema: dw
       # materialized=incremental set in dw macro

dbt/macros/helpers/stg_end.sql

@@ -0,0 +1,20 @@
+{% macro stg_end() -%}
+{%- if target.name == 'prod' %}
+with data as (
+    select
+        model,
+        replace(regexp_replace(split_part(model, '.', 3),'stg_',''),'"','') as raw_table,
+        start_time
+        from raw.dbt_runs dr
+    where model = '{{ this }}'
+)
+
+merge into raw.completed_dbt_runs as t
+using data as s
+	on t.model = s.model
+when matched
+	then update set start_time=s.start_time
+when not matched
+then insert values (model,raw_table,start_time)
+{% endif %}
+{%- endmacro %}

dbt/macros/helpers/stg_start.sql

@@ -0,0 +1,17 @@
+{% macro stg_start() -%}
+{%- if target.name == 'prod' %}
+    with data as (
+	select
+		'{{ this }}' as model,
+		current_timestamp as start_time
+)
+
+merge into raw.dbt_runs as t
+using data as s
+	on t.model = s.model
+when matched
+	then update set start_time=s.start_time
+when not matched
+then insert values (model,start_time)
+{% endif %}
+{%- endmacro %}