Legge til last av dim_virksomhet i run_eiendom

navikt · Sep 26, 2024 · 0f06b16 · 0f06b16
1 parent c955cf0
commit 0f06b16
Showing 1 changed file with 15 additions and 7 deletions.
diff --git a/dags/run_eiendom.py b/dags/run_eiendom.py
@@ -144,8 +144,6 @@ def run_dbt_job(job_name: str):
     dvh_eiendom__dim_lokasjon = last_fra_dvh_eiendom("dvh_eiendom__dim_lokasjon")
     dvh_eiendom__lyd_loc_dt = last_fra_dvh_eiendom("dvh_eiendom__lyd_loc_dt")
     dvh_eiendom__lyd_agreement = last_fra_dvh_eiendom("dvh_eiendom__lyd_agreement")
-    dvh_eiendom__dim_org = last_fra_dvh_eiendom("dvh_eiendom__dim_org")
-    dvh_eiendom__dim_geografi = last_fra_dvh_eiendom("dvh_eiendom__dim_geografi")
     dvh_eiendom__hrres_stillinger_eiendom = last_fra_dvh_eiendom(
         "dvh_eiendom__hrres_stillinger_eiendom"
     )
@@ -175,9 +173,15 @@ def run_dbt_job(job_name: str):
     )
     dvh_eiendom__lyd_utl_stat = last_fra_dvh_eiendom("dvh_eiendom__lyd_utl_stat")
     dvh_eiendom__eiendom_kor2024 = last_fra_dvh_eiendom("dvh_eiendom__eiendom_kor2024")
-    dvh_eiendom__eiendom_statenslokaler_json = last_fra_dvh_eiendom("dvh_eiendom__eiendom_statenslokaler_json")
-    dvh_eiendom__statlok_leieforhold = last_fra_dvh_eiendom("dvh_eiendom__statlok_leieforhold")
-    dvh_eiendom__statlok_leieobjekt = last_fra_dvh_eiendom("dvh_eiendom__statlok_leieobjekt")
+    dvh_eiendom__eiendom_statenslokaler_json = last_fra_dvh_eiendom(
+        "dvh_eiendom__eiendom_statenslokaler_json"
+    )
+    dvh_eiendom__statlok_leieforhold = last_fra_dvh_eiendom(
+        "dvh_eiendom__statlok_leieforhold"
+    )
+    dvh_eiendom__statlok_leieobjekt = last_fra_dvh_eiendom(
+        "dvh_eiendom__statlok_leieobjekt"
+    )
     dvh_eiendom__statlok_lokale = last_fra_dvh_eiendom("dvh_eiendom__statlok_lokale")
 
     mainmanager__dim_adresse = last_fra_mainmanager("mainmanager__dim_adresse")
@@ -187,6 +191,9 @@ def run_dbt_job(job_name: str):
     dvh_kodeverk__org_enhet_til_node = last_fra_dvh_eiendom(
         "dvh_kodeverk__org_enhet_til_node"
     )
+    dvh_kodeverk__dim_org = last_fra_dvh_eiendom("dvh_kodeverk__dim_org")
+    dvh_kodeverk__dim_geografi = last_fra_dvh_eiendom("dvh_kodeverk__dim_geografi")
+    dvh_kodeverk__dim_virksomhet = last_fra_dvh_eiendom("dvh_kodeverk__dim_virksomhet")
 
     dbt_run = run_dbt_job("dbt_build")
 
@@ -214,8 +221,6 @@ def run_dbt_job(job_name: str):
     dvh_eiendom__dim_lokasjon >> dbt_run
     dvh_eiendom__lyd_loc_dt >> dbt_run
     dvh_eiendom__lyd_agreement >> dbt_run
-    dvh_eiendom__dim_org >> dbt_run
-    dvh_eiendom__dim_geografi >> dbt_run
     dvh_eiendom__hrres_stillinger_eiendom >> dbt_run
     dvh_eiendom__hrorg_orgstrukt_eiendom >> dbt_run
     dvh_eiendom__lyd_agreementitem >> dbt_run
@@ -243,5 +248,8 @@ def run_dbt_job(job_name: str):
     mainmanager__dim_lokasjon >> dbt_run
 
     dvh_kodeverk__org_enhet_til_node >> dbt_run
+    dvh_kodeverk__dim_org >> dbt_run
+    dvh_kodeverk__dim_geografi >> dbt_run
+    dvh_kodeverk__dim_virksomhet >> dbt_run
 
     dbt_run >> notify_slack_success