Skip to content

Commit

Permalink
Adjust schedule and remove unused tasks
Browse files Browse the repository at this point in the history
  • Loading branch information
amishas157 committed Oct 4, 2024
1 parent d34e93b commit 933f7ed
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 5 deletions.
2 changes: 1 addition & 1 deletion dags/dbt_recency_tests_dag.py
Original file line number Diff line number Diff line change
Expand Up @@ -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),
},
Expand Down
4 changes: 0 additions & 4 deletions dags/dbt_stellar_marts_dag.py
Original file line number Diff line number Diff line change
Expand Up @@ -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")
Expand Down

0 comments on commit 933f7ed

Please sign in to comment.