#1143 depends_on_past=True, remove unused imports

CityofToronto · Feb 6, 2025 · 670dfcd · 670dfcd
1 parent ebb5808
commit 670dfcd
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/dags/miovision_pull.py b/dags/miovision_pull.py
@@ -8,8 +8,6 @@
 import os
 import pendulum
 from datetime import timedelta
-import configparser
-import dateutil.parser
 
 from airflow.decorators import dag, task, task_group
 from airflow.models.param import Param
@@ -150,7 +148,7 @@ def aggregate_15_min_mvt_task(ds = None, **context):
                     intersections = get_intersection_info(conn, intersection=INTERSECTIONS)
                     aggregate_15_min_mvt(conn, time_period=time_period, intersections=intersections)
 
-        @task
+        @task(depends_on_past=True)
         def zero_volume_anomalous_ranges_task(ds = None, **context):
             mio_postgres = PostgresHook("miovision_api_bot")  
             time_period = (ds, ds_add(ds, 1))