#1056 update dag schedules to 5pm = less evening notifications

CityofToronto · Sep 5, 2024 · c090d9f · c090d9f
1 parent 756b162
commit c090d9f
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/dags/pull_here.py b/dags/pull_here.py
@@ -55,7 +55,7 @@
 
 @dag(dag_id = dag_name,
      default_args=default_args,
-     schedule_interval='30 18 * * * ' ,
+     schedule_interval='0 17 * * * ' ,
      catchup=False,
      doc_md = doc_md,
      tags=["HERE"]

diff --git a/dags/wys_check.py b/dags/wys_check.py
@@ -43,7 +43,7 @@
      catchup=False,
      max_active_runs=1,
      template_searchpath=os.path.join(repo_path,'dags/sql'),
-     schedule='0 20 * * *', # Run at 8:00 PM local time every day
+     schedule='0 18 * * *', # Run at 6:00 PM local time every day
      tags=["wys", "data_checks"],
      doc_md=DOC_MD
 )
@@ -56,7 +56,7 @@ def wys_check_dag():
         poke_interval=3600, #retry hourly
         mode="reschedule",
         timeout=86400, #one day
-        execution_delta=timedelta(hours=1, minutes=30) #pull_wys scheduled at '30 18 * * *'
+        execution_delta=timedelta(hours=1) #pull_wys scheduled at '0 17 * * *'
     )
 
     @task_group()

diff --git a/dags/wys_pull.py b/dags/wys_pull.py
@@ -57,7 +57,7 @@
     catchup=False,
     max_active_runs=5,
     template_searchpath=os.path.join(repo_path,'dags/sql'),
-    schedule='30 18 * * *', # Run at 6:30 PM local time every day
+    schedule='0 17 * * *', # Run at 5:00 PM local time every day
     tags=["wys", "data_pull", "partition_create", "data_checks"],
     doc_md=DOC_MD
 )