From 8933a01db4d9c926673274aebb41692b2a8fc955 Mon Sep 17 00:00:00 2001 From: Cayo Dias <80067418+cayod@users.noreply.github.com> Date: Mon, 27 Nov 2023 13:29:47 -0300 Subject: [PATCH] Add dim_dates table to mgi_transform dag (#253) --- dags/mgi_transforms_dag.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/dags/mgi_transforms_dag.py b/dags/mgi_transforms_dag.py index 6b82eb04..0a77028b 100644 --- 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 ) (