Skip to content

Commit c325dbd

Browse files
committed
use 1 day in the past as default date
1 parent 25402c6 commit c325dbd

1 file changed

Lines changed: 3 additions & 2 deletions

File tree

dags/dts_open_311_scrape.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@
77
from airflow.decorators import task
88
from airflow.models import DAG
99
from airflow.operators.docker_operator import DockerOperator
10-
from pendulum import datetime, duration
10+
from pendulum import datetime, duration, now
1111

1212
from utils.onepassword import get_env_vars_task
1313
from utils.slack_operator import task_fail_slack_alert
@@ -71,7 +71,8 @@
7171
docker_image = "atddocker/dts-311-reporting:production"
7272

7373
env_vars = get_env_vars_task(REQUIRED_SECRETS)
74-
date_arg = get_previous_run_date(fallback_date="2025-10-22")
74+
one_day_ago = now("America/Chicago").subtract(days=1)
75+
date_arg = get_previous_run_date(fallback_date=one_day_ago.to_iso8601_string())
7576

7677
t1 = DockerOperator(
7778
task_id="open311_to_socrata",

0 commit comments

Comments
 (0)