update dag intervals

peterbull · peterbull · commit bb3713ff90a3 · 2024-06-11T12:04:09.000-04:00
diff --git a/airflow/dags/sl_data_etl.py b/airflow/dags/sl_data_etl.py
@@ -30,7 +30,7 @@
 @dag(
     dag_id="sl_data_etl",
     start_date=start_date,
-    schedule="@daily",
+    schedule="30 9 * * *",
     catchup=False,
     is_paused_upon_creation=False,
 )
diff --git a/airflow/dags/update_noaa_station_inventory.py b/airflow/dags/update_noaa_station_inventory.py
@@ -52,7 +52,7 @@ def update_station_inventory(db, station_inventory, station, data_mapping):
     "update_noaa_station_inventory",
     default_args=default_args,
     description="Cycle through NOAA COOPS station list and append any new stations and inventory data to postgis table",
-    schedule="@daily",
+    schedule="0 6 * * *",
     catchup=False,
     is_paused_upon_creation=False,
 ) as dag:

Original file line number	Diff line number	Diff line change
`@@ -30,7 +30,7 @@`
`30`	`30`	`@dag(`
`31`	`31`	`dag_id="sl_data_etl",`
`32`	`32`	`start_date=start_date,`
`33`		`- schedule="@daily",`
	`33`	`+ schedule="30 9 * * *",`
`34`	`34`	`catchup=False,`
`35`	`35`	`is_paused_upon_creation=False,`
`36`	`36`	`)`