From 4efe5e87d0727ff61c63879fa8acadeafe978be6 Mon Sep 17 00:00:00 2001 From: Robin Ole Heinemann Date: Wed, 8 Jan 2025 17:58:42 +0100 Subject: [PATCH] worker: _discard_messages: fix return being missed --- worker/transcribee_worker/document.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/worker/transcribee_worker/document.py b/worker/transcribee_worker/document.py index b2d15a4f..a67eb9dd 100644 --- a/worker/transcribee_worker/document.py +++ b/worker/transcribee_worker/document.py @@ -50,7 +50,7 @@ async def _discard_messages(self): if self._stop.is_set(): for task in pending: task.cancel() - return + return else: pending.add(asyncio.create_task(self.conn.recv()))