feat: adjust stg model to incorprate run_result genrated by dbt build

chenxuanrong · Sep 16, 2022 · 042d56f · 042d56f
1 parent f124f53
commit 042d56f
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 4 deletions.
diff --git a/models/staging/stg_dbt__model_executions.sql b/models/staging/stg_dbt__model_executions.sql
@@ -17,7 +17,7 @@ dbt_run as (
 
     select *
     from run_results
-    where data:args:which = 'run'
+    where data:args:which in ('run', 'build')
 
 ),
 
@@ -46,6 +46,7 @@ fields as (
         result.value:adapter_response:rows_affected::int as rows_affected
     from dbt_run,
         lateral flatten(input => data:results) as result
+    where startswith(node_id, 'model')
 
 ),
 

diff --git a/models/staging/stg_dbt__run_results.sql b/models/staging/stg_dbt__run_results.sql
@@ -17,7 +17,7 @@ dbt_run as (
 
     select *
     from run_results
-    where data:args:which in ('run', 'seed', 'snapshot', 'test')
+    where data:args:which in ('run', 'seed', 'snapshot', 'test', 'build')
 
 ),
 

diff --git a/models/staging/stg_dbt__run_results_env_keys.sql b/models/staging/stg_dbt__run_results_env_keys.sql
@@ -17,7 +17,7 @@ dbt_run as (
 
     select *
     from run_results
-    where data:args:which = 'run'
+    where data:args:which in ('run',' build')
 
 ),
 

diff --git a/models/staging/stg_dbt__test_executions.sql b/models/staging/stg_dbt__test_executions.sql
@@ -17,7 +17,7 @@ dbt_run as (
 
     select *
     from run_results
-    where data:args:which = 'test'
+    where data:args:which in ('test', 'build')
 
 ),
 
@@ -47,6 +47,7 @@ fields as (
         result.value:adapter_response:rows_affected::int as rows_affected
     from dbt_run,
         lateral flatten(input => data:results) as result
+    where startswith(node_id, 'test')
 
 ),