fix: missing kill_workers

subugoe · Jan 16, 2025 · 0467d4b · 0467d4b
1 parent ec080af
commit 0467d4b
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/broker/operandi_broker/broker.py b/src/broker/operandi_broker/broker.py
@@ -92,3 +92,6 @@ def create_worker_process(self, queue_name, worker_type: str) -> None:
             self.log.info(f"Assigning a new worker process with pid: {child_pid}, to queue: {queue_name}")
             # append the pid to the workers list of the queue_name
             (self.queues_and_workers[queue_name]).append(child_pid)
+
+    def kill_workers(self):
+        kill_workers(self.log, self.queues_and_workers)