Add job_sk (#5)

swdotcom · Sep 8, 2022 · de18a32 · de18a32
1 parent 92dda73
commit de18a32
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/models/fct_dbt__invocations.sql b/models/fct_dbt__invocations.sql
@@ -44,6 +44,7 @@ invocations as (
     select
         base.command_invocation_id,
         base.job_id,
+        base.job_sk,
         base.dbt_version,
         base.project_name,
         base.run_started_at,

diff --git a/models/staging/stg_dbt__invocations.sql b/models/staging/stg_dbt__invocations.sql
@@ -30,7 +30,12 @@ enhanced as (
 
     select
         command_invocation_id,
-        {{ dbt_utils.surrogate_key(['coalesce(dbt_cloud_job_id, job_name)']) }} as job_id,
+        coalesce(
+            dbt_cloud_job_id,
+            job_name,
+            target_database || '.' || target_schema
+        ) as job_id,
+        {{ dbt_utils.surrogate_key(['job_id']) }} as job_sk,
         dbt_version,
         project_name,
         run_started_at,