From d90c8ea303b3454fccc56ac479634b93ca285e6b Mon Sep 17 00:00:00 2001 From: gabrielwol <80077912+gabrielwol@users.noreply.github.com> Date: Wed, 5 Feb 2025 15:52:48 +0000 Subject: [PATCH] #1143 depends_on_past=True, remove unused imports --- dags/miovision_pull.py | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/dags/miovision_pull.py b/dags/miovision_pull.py index 20b47954a..54f84712d 100644 --- 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))