From 933f7ed394bde44197d45d0aeba6a492d2fc0150 Mon Sep 17 00:00:00 2001 From: Amisha Singla Date: Fri, 4 Oct 2024 11:12:33 -0500 Subject: [PATCH] Adjust schedule and remove unused tasks --- dags/dbt_recency_tests_dag.py | 2 +- dags/dbt_stellar_marts_dag.py | 4 ---- 2 files changed, 1 insertion(+), 5 deletions(-) diff --git a/dags/dbt_recency_tests_dag.py b/dags/dbt_recency_tests_dag.py index a3a759c2..a100cee8 100644 --- a/dags/dbt_recency_tests_dag.py +++ b/dags/dbt_recency_tests_dag.py @@ -18,7 +18,7 @@ default_args=get_default_dag_args(), start_date=datetime(2024, 9, 24, 0, 0), description="This DAG runs recency tests at a daily cadence", - schedule="0 15 * * *", # Every day at 3:00 PM UTC / 9:00 AM CST + schedule="0 3 * * *", # Every day at 3:00 AM UTC / 9:00 PM CST user_defined_filters={ "container_resources": lambda s: k8s.V1ResourceRequirements(requests=s), }, diff --git a/dags/dbt_stellar_marts_dag.py b/dags/dbt_stellar_marts_dag.py index 2f37787a..adaf80df 100644 --- a/dags/dbt_stellar_marts_dag.py +++ b/dags/dbt_stellar_marts_dag.py @@ -32,10 +32,6 @@ dag, "wait_on_dbt_enriched_base_tables", "dbt_enriched_base_tables" ) -wait_on_partner_pipeline_dag = build_cross_deps( - dag, "wait_on_partner_pipeline_dag", "partner_pipeline_dag" -) - # DBT models to run ohlc_task = dbt_task(dag, tag="ohlc") liquidity_pool_trade_volume_task = dbt_task(dag, tag="liquidity_pool_trade_volume")