Update fetch_notices_by_date_range.py

CaptainOfHacks · CaptainOfHacks · commit fbcb648d9703 · 2023-02-22T22:29:11.000+02:00
diff --git a/dags/fetch_notices_by_date_range.py b/dags/fetch_notices_by_date_range.py
@@ -50,7 +50,7 @@ def trigger_notice_by_date_for_each_date_in_range():
         for date_wildcard in date_wildcards:
             TriggerDagRunOperator(
                 task_id=f'trigger_notice_fetch_by_date_workflow_dag_{date_wildcard[:-1]}',
-                trigger_dag_id="notice_fetch_by_date_workflow",
+                trigger_dag_id="fetch_notices_by_date",
                 conf={WILD_CARD_DAG_KEY: date_wildcard,
                       TRIGGER_COMPLETE_WORKFLOW_DAG_KEY: trigger_complete_workflow,
                       }

Original file line number	Diff line number	Diff line change
`@@ -50,7 +50,7 @@ def trigger_notice_by_date_for_each_date_in_range():`
`50`	`50`	`for date_wildcard in date_wildcards:`
`51`	`51`	`TriggerDagRunOperator(`
`52`	`52`	`task_id=f'trigger_notice_fetch_by_date_workflow_dag_{date_wildcard[:-1]}',`
`53`		`- trigger_dag_id="notice_fetch_by_date_workflow",`
	`53`	`+ trigger_dag_id="fetch_notices_by_date",`
`54`	`54`	`conf={WILD_CARD_DAG_KEY: date_wildcard,`
`55`	`55`	`TRIGGER_COMPLETE_WORKFLOW_DAG_KEY: trigger_complete_workflow,`
`56`	`56`	`}`