From fbcb648d9703a9676366a50d36a00ebe74403d32 Mon Sep 17 00:00:00 2001 From: CaptainOfHacks Date: Wed, 22 Feb 2023 22:29:11 +0200 Subject: [PATCH 1/2] Update fetch_notices_by_date_range.py --- dags/fetch_notices_by_date_range.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dags/fetch_notices_by_date_range.py b/dags/fetch_notices_by_date_range.py index 65f3059ba..ac6fe8001 100644 --- 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, } From e9969433311a1918147f2231fed47860a99955d3 Mon Sep 17 00:00:00 2001 From: CaptainOfHacks Date: Wed, 22 Feb 2023 22:39:20 +0200 Subject: [PATCH 2/2] Update fetch_notices_by_date_range.py --- dags/fetch_notices_by_date_range.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/dags/fetch_notices_by_date_range.py b/dags/fetch_notices_by_date_range.py index ac6fe8001..4c4f0e6c0 100644 --- a/dags/fetch_notices_by_date_range.py +++ b/dags/fetch_notices_by_date_range.py @@ -8,7 +8,8 @@ from dags import DEFAULT_DAG_ARGUMENTS from dags.dags_utils import get_dag_param -from dags.fetch_notices_by_date import WILD_CARD_DAG_KEY, TRIGGER_COMPLETE_WORKFLOW_DAG_KEY +from dags.fetch_notices_by_date import WILD_CARD_DAG_KEY, TRIGGER_COMPLETE_WORKFLOW_DAG_KEY, \ + DAG_NAME as FETCH_NOTICES_BY_DATE_DAG_NAME from ted_sws.event_manager.adapters.event_log_decorator import event_log from ted_sws.event_manager.model.event_message import TechnicalEventMessage, EventMessageMetadata, \ EventMessageProcessType @@ -50,7 +51,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="fetch_notices_by_date", + trigger_dag_id=FETCH_NOTICES_BY_DATE_DAG_NAME, conf={WILD_CARD_DAG_KEY: date_wildcard, TRIGGER_COMPLETE_WORKFLOW_DAG_KEY: trigger_complete_workflow, }