From 1c237c340c3dae02861abb22c9312ccf32dfaea9 Mon Sep 17 00:00:00 2001 From: Jacob Williamson Date: Tue, 10 Nov 2026 14:37:21 +0000 Subject: [PATCH] Always broadcast queue state changes --- src/daq_queuing_service/task_queue/queue.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/src/daq_queuing_service/task_queue/queue.py b/src/daq_queuing_service/task_queue/queue.py index 598bc4f..4894d1f 100644 --- a/src/daq_queuing_service/task_queue/queue.py +++ b/src/daq_queuing_service/task_queue/queue.py @@ -293,6 +293,7 @@ def _broadcast_changes(self): self._broadcaster.broadcast( Event(type="call_history_update", data=self._get_call_history()) ) + self._broadcaster.broadcast(Event(type="state_update", data=self._state)) async def get_next_call_once_available(self) -> BlueapiCall: """Waits until a call is available before returning the call. A call is @@ -555,7 +556,6 @@ def _pause_queue(self, reason: PauseReason): ) self._state.paused = True self._state.last_pause_reason = reason - self._broadcaster.broadcast(Event(type="state_update", data=self._state)) notify(f"Queue paused: {reason}", "INFO") async def pause_queue(self, reason: PauseReason) -> QueueState: @@ -581,7 +581,6 @@ async def resume_queue(self) -> QueueState: LOGGER.info("Resuming queue") async with self._modifying: self._state.paused = False - self._broadcaster.broadcast(Event(type="state_update", data=self._state)) return self._state @property