Skip to content

Commit

Permalink
Merge pull request #451 from OP-TED/feature/TED-1278
Browse files Browse the repository at this point in the history
Feature/ted 1278
  • Loading branch information
costezki authored Feb 22, 2023
2 parents 2b455af + e996943 commit b86cb82
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions dags/fetch_notices_by_date_range.py
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down Expand Up @@ -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="notice_fetch_by_date_workflow",
trigger_dag_id=FETCH_NOTICES_BY_DATE_DAG_NAME,
conf={WILD_CARD_DAG_KEY: date_wildcard,
TRIGGER_COMPLETE_WORKFLOW_DAG_KEY: trigger_complete_workflow,
}
Expand Down

0 comments on commit b86cb82

Please sign in to comment.