Await callback() as well

Co-authored-by: Stef Piatek <[email protected]>
SAFEHR-data · Dec 4, 2023 · 7925899 · 7925899
1 parent 1252f90
commit 7925899
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pixl_core/src/core/patient_queue/subscriber.py b/pixl_core/src/core/patient_queue/subscriber.py
@@ -71,7 +71,7 @@ async def run(self, callback: Callable[[bytes], Awaitable[None]]) -> None:
 
                 try:
                     await asyncio.sleep(0.01)  # Avoid very fast callbacks
-                    callback(message.body)
+                    await callback(message.body)
                 except Exception:
                     LOGGER.exception(
                         "Failed to process %s" "Not re-queuing message",