Skip to content

Commit e996943

Browse files
Update fetch_notices_by_date_range.py
1 parent fbcb648 commit e996943

1 file changed

Lines changed: 3 additions & 2 deletions

File tree

dags/fetch_notices_by_date_range.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,8 @@
88

99
from dags import DEFAULT_DAG_ARGUMENTS
1010
from dags.dags_utils import get_dag_param
11-
from dags.fetch_notices_by_date import WILD_CARD_DAG_KEY, TRIGGER_COMPLETE_WORKFLOW_DAG_KEY
11+
from dags.fetch_notices_by_date import WILD_CARD_DAG_KEY, TRIGGER_COMPLETE_WORKFLOW_DAG_KEY, \
12+
DAG_NAME as FETCH_NOTICES_BY_DATE_DAG_NAME
1213
from ted_sws.event_manager.adapters.event_log_decorator import event_log
1314
from ted_sws.event_manager.model.event_message import TechnicalEventMessage, EventMessageMetadata, \
1415
EventMessageProcessType
@@ -50,7 +51,7 @@ def trigger_notice_by_date_for_each_date_in_range():
5051
for date_wildcard in date_wildcards:
5152
TriggerDagRunOperator(
5253
task_id=f'trigger_notice_fetch_by_date_workflow_dag_{date_wildcard[:-1]}',
53-
trigger_dag_id="fetch_notices_by_date",
54+
trigger_dag_id=FETCH_NOTICES_BY_DATE_DAG_NAME,
5455
conf={WILD_CARD_DAG_KEY: date_wildcard,
5556
TRIGGER_COMPLETE_WORKFLOW_DAG_KEY: trigger_complete_workflow,
5657
}

0 commit comments

Comments
 (0)