fix: create manager event routing in case the TM is not started

ICIJ · Oct 15, 2024 · c7002ac · c7002ac
1 parent b97a601
commit c7002ac
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/icij-worker/icij_worker/worker/amqp.py b/icij-worker/icij_worker/worker/amqp.py
@@ -108,6 +108,9 @@ async def _aenter__(self):
         await self._exit_stack.enter_async_context(self._channel)
         await self._bind_task_queue()
         await self._bind_worker_event_queue()
+        await self._create_routing(
+            self.manager_evt_routing(), declare_queues=True, declare_exchanges=True
+        )
 
     async def _aexit__(self, exc_type, exc_val, exc_tb):
         event_transient_queue = await self._channel.get_queue(