fix start_date

lsst-uk · Jul 2, 2024 · 0d6f207 · 0d6f207
1 parent fe19d63
commit 0d6f207
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/echo-side/dags/cleanup_logs.py b/echo-side/dags/cleanup_logs.py
@@ -1,6 +1,6 @@
 from airflow import DAG
 from airflow.providers.cncf.kubernetes.operators.pod import KubernetesPodOperator
-from datetime import timedelta
+from datetime import timedelta, datetime
 from kubernetes.client import models
 
 # Create k8s storage mount 
@@ -24,6 +24,7 @@
     default_args=default_args,
     description='List backup CSV files from S3 bucket',
     schedule_interval=timedelta(days=2),
+    start_date=datetime(2024, 1, 1),
     catchup=False,
 )
 

diff --git a/echo-side/dags/monitor.py b/echo-side/dags/monitor.py
@@ -1,7 +1,7 @@
 from airflow import DAG
 from airflow.providers.cncf.kubernetes.operators.pod import KubernetesPodOperator
 from airflow.models import Variable
-from datetime import timedelta
+from datetime import timedelta, datetime
 from kubernetes.client import models
 
 # Create k8s storage mount 
@@ -25,6 +25,7 @@
     default_args=default_args,
     description='List backup CSV files from S3 bucket',
     schedule_interval=timedelta(hours=1),
+    start_date=datetime(2024, 1, 1),
     catchup=False,
 )