fix: Fix tests after merge

Author: duprijil

dags/fetch_notices_by_date.py

@@ -18,7 +18,7 @@
 from ted_sws.event_manager.services.log import log_error
 
 DAG_ID = "fetch_notices_by_date"
-DAG_NAME = "Fetch notices by date"
+FETCHER_DAG_NAME = "Fetch notices by date"
 BATCH_SIZE = 2000
 WILD_CARD_DAG_KEY = "wild_card"
 TRIGGER_COMPLETE_WORKFLOW_DAG_KEY = "trigger_complete_workflow"
@@ -31,7 +31,7 @@
 
 @dag(default_args=DEFAULT_DAG_ARGUMENTS,
      dag_id=DAG_ID,
-     dag_display_name=DAG_NAME,
+     dag_display_name=FETCHER_DAG_NAME,
      catchup=False,
      schedule=CronTriggerTimetable(
          cron=config.SCHEDULE_DAG_FETCH,

dags/reprocess_notices_from_backlog_by_id.py

@@ -1,10 +1,9 @@
 from airflow.decorators import dag, task
 from airflow.models import Param
 
-from dags import DEFAULT_DAG_ARGUMENTS
+from dags import DEFAULT_DAG_ARGUMENTS, NOTICE_NORMALISATION_PIPELINE_TASK_ID
 from dags.dags_utils import push_dag_downstream, get_dag_param
 from dags.operators.DagBatchPipelineOperator import NOTICE_IDS_KEY, TriggerNoticeBatchPipelineOperator
-from dags.notice_processing_pipeline import NOTICE_NORMALISATION_PIPELINE_TASK_ID
 from ted_sws.event_manager.adapters.event_log_decorator import event_log
 from ted_sws.event_manager.model.event_message import TechnicalEventMessage, EventMessageMetadata, EventMessageProcessType
 

dags/reprocess_notices_from_backlog_by_status.py

@@ -1,9 +1,8 @@
 from airflow.decorators import dag, task
 from airflow.models import Param
 
-from dags import DEFAULT_DAG_ARGUMENTS
+from dags import DEFAULT_DAG_ARGUMENTS, NOTICE_NORMALISATION_PIPELINE_TASK_ID
 from dags.dags_utils import push_dag_downstream, get_dag_param
-from dags.notice_processing_pipeline import NOTICE_NORMALISATION_PIPELINE_TASK_ID
 from dags.operators.DagBatchPipelineOperator import NOTICE_IDS_KEY, TriggerNoticeBatchPipelineOperator
 from dags.pipelines.notice_selectors_pipelines import notice_ids_selector_by_status
 from ted_sws.core.model.notice import NoticeStatus

tests/unit/event_manager/services/test_logger_from_context.py

@@ -56,7 +56,7 @@ def test_get_dag_run_id_from_dag_context(fake_dag_context):
 
 
 def test_handle_event_message_metadata_dag_context(fake_dag_context):
-    process_name = "DAG_NAME"
+    process_name = "FETCHER_DAG_NAME"
     process_id = "DAG_RUN_ID"
 
     metadata = handle_event_message_metadata_dag_context(ps_name=process_name, ps_id=process_id, ps_context={})
@@ -70,7 +70,7 @@ def test_handle_event_message_metadata_dag_context(fake_dag_context):
 
 
 def test_handle_event_message_metadata_context():
-    process_name = "DAG_NAME"
+    process_name = "FETCHER_DAG_NAME"
     process_id = "DAG_RUN_ID"
     process_type = EventMessageProcessType.CLI