#713 reduce concurrency and no catchup

CityofToronto · Oct 4, 2023 · 36b6832 · 36b6832
1 parent b84e016
commit 36b6832
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/dags/pull_wys.py b/dags/pull_wys.py
@@ -69,6 +69,8 @@ def custom_fail_slack_alert(context: dict) -> str:
 
 @dag(dag_id = dag_name,
      default_args=default_args,
+     catchup=False,
+     max_active_runs=5,
      schedule_interval='0 15 * * *' # Run at 3 PM local time every day
      )
 def pull_wys_dag():
@@ -118,4 +120,4 @@ def read_google_sheets():
     pull_schedules()
     read_google_sheets()
 
-pull_wys_dag()
+pull_wys_dag()