Merge pull request #229 from cityofaustin/ch-date-task-dag

Add get_date_filter_arg to task flow definition
cityofaustin · May 21, 2024 · 89141da · 89141da
2 parents dd1c676 + f06faf6
commit 89141da
Show file tree

Hide file tree

Showing 8 changed files with 2 additions and 8 deletions.
diff --git a/dags/atd_bond_reporting.py b/dags/atd_bond_reporting.py
@@ -6,7 +6,6 @@
 
 from utils.onepassword import get_env_vars_task
 from utils.slack_operator import task_fail_slack_alert
-from utils.knack import get_date_filter_arg
 
 DEPLOYMENT_ENVIRONMENT = os.getenv("ENVIRONMENT", "development")
 

diff --git a/dags/atd_executive_dashboard_row_weekly_summary.py b/dags/atd_executive_dashboard_row_weekly_summary.py
@@ -9,7 +9,6 @@
 
 from utils.onepassword import get_env_vars_task
 from utils.slack_operator import task_fail_slack_alert
-from utils.knack import get_date_filter_arg
 
 DEPLOYMENT_ENVIRONMENT = os.getenv("ENVIRONMENT", "development")
 

diff --git a/dags/atd_kits_dms_message.py b/dags/atd_kits_dms_message.py
@@ -8,7 +8,6 @@
 
 from utils.onepassword import get_env_vars_task
 from utils.slack_operator import task_fail_slack_alert
-from utils.knack import get_date_filter_arg
 
 DEPLOYMENT_ENVIRONMENT = os.getenv("ENVIRONMENT", "development")
 

diff --git a/dags/atd_kits_sig_stat_pub.py b/dags/atd_kits_sig_stat_pub.py
@@ -6,7 +6,6 @@
 
 from utils.onepassword import get_env_vars_task
 from utils.slack_operator import task_fail_slack_alert
-from utils.knack import get_date_filter_arg
 
 DEPLOYMENT_ENVIRONMENT = os.getenv("ENVIRONMENT", "development")
 

diff --git a/dags/atd_knack_inventory_transactions.py b/dags/atd_knack_inventory_transactions.py
@@ -90,4 +90,4 @@
         mount_tmp_dir=False,
     )
 
-    t1 >> t2
+    get_date_filter_arg >> t1 >> t2
diff --git a/dags/atd_knack_purchase_request_copier.py b/dags/atd_knack_purchase_request_copier.py
@@ -5,7 +5,6 @@
 from pendulum import datetime, duration
 
 from utils.onepassword import get_env_vars_task
-from utils.knack import get_date_filter_arg
 from utils.slack_operator import task_fail_slack_alert
 
 DEPLOYMENT_ENVIRONMENT = os.getenv("ENVIRONMENT", "development")

diff --git a/dags/atd_moped_components_to_agol.py b/dags/atd_moped_components_to_agol.py
@@ -8,7 +8,6 @@
 
 from utils.onepassword import get_env_vars_task
 from utils.slack_operator import task_fail_slack_alert
-from utils.knack import get_date_filter_arg
 
 DEPLOYMENT_ENVIRONMENT = os.getenv("ENVIRONMENT", "development")
 

diff --git a/dags/atd_moped_data_tracker_sync.py b/dags/atd_moped_data_tracker_sync.py
@@ -70,4 +70,4 @@
         mount_tmp_dir=False,
     )
 
-    t1
+    get_date_filter_arg >> t1
-Original file line number
+Diff line change
@@ Expand Up / @@ -70,4 +70,4 @@ @@
             mount_tmp_dir=False,
         )
-        t1
+        get_date_filter_arg >> t1