There was an error while loading. Please reload this page.
2 parents 617505d + bb598ba commit 8816e89Copy full SHA for 8816e89
1 file changed
dags/dts_open_311_scrape.py
@@ -89,9 +89,14 @@
89
docker_image = "atddocker/dts-311-reporting:production"
90
91
env_vars = get_env_vars_task(REQUIRED_SECRETS)
92
- one_day_ago = now("America/Chicago").subtract(days=1)
+
93
+ @task
94
+ def one_day_prev():
95
+ return now("America/Chicago").subtract(days=1).to_iso8601_string()
96
97
+ one_day_ago = one_day_prev()
98
prev_run_time = get_previous_success_start_time(
- fallback_date=one_day_ago.to_iso8601_string()
99
+ fallback_date=one_day_ago
100
)
101
102
t1 = DockerOperator(
@@ -106,4 +111,4 @@
106
111
force_pull=True,
107
112
108
113
109
- t1
114
+ env_vars >> one_day_ago >> prev_run_time >> t1
0 commit comments