Add dim_dates table to mgi_transform dag (#253)

stellar · Nov 27, 2023 · 8933a01 · 8933a01
1 parent ecfa767
commit 8933a01
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/dags/mgi_transforms_dag.py b/dags/mgi_transforms_dag.py
@@ -39,6 +39,9 @@
 # tasks for dim wallets
 dim_mgi_wallets = build_dbt_task(dag, "dim_mgi_wallets")
 
+# task for dim dates
+dim_dates = build_dbt_task(dag, "dim_dates")
+
 # tasks for network stats
 enriched_history_mgi_operations = build_dbt_task(dag, "enriched_history_mgi_operations")
 mgi_network_stats_agg = build_dbt_task(dag, "mgi_network_stats_agg")
@@ -52,6 +55,7 @@
     >> stg_country_code
     >> int_mgi_transactions_transformed
     >> int_mgi_transactions_null_id
+    >> dim_dates
     >> fct_mgi_cashflow
 )
 (