Update new_worker_single_notice_process_orchestrator.py

CaptainOfHacks · CaptainOfHacks · commit 15c6024c2b3b · 2022-08-09T17:07:52.000+03:00
diff --git a/dags/new_worker_single_notice_process_orchestrator.py b/dags/new_worker_single_notice_process_orchestrator.py
@@ -141,8 +141,7 @@ def _transform_notice(**context_args):
         event_logger: EventLogger = get_logger_from_dag_context(context_args)
         event_message: NoticeEventMessage = NoticeEventMessage()
         event_message.start_record()
-
-        notice = pull_dag_upstream(NOTICE_ID)
+        notice = pull_dag_upstream(NOTICE_OBJECT)
         mapping_suite_id = pull_dag_upstream(MAPPING_SUITE_ID)
         mongodb_client = MongoClient(config.MONGO_DB_AUTH_URL)
         mapping_suite_repository = MappingSuiteRepositoryMongoDB(mongodb_client=mongodb_client)
