Log when Worker loop is disrupted

alephdata · Dec 13, 2024 · fd4052f · fd4052f
1 parent 74329d9
commit fd4052f
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/servicelayer/taskqueue.py b/servicelayer/taskqueue.py
@@ -511,6 +511,10 @@ def process_blocking(self):
                 channel.connection.add_callback_threadsafe(cb)
             except Empty:
                 pass
+            except Exception:
+                log.exception(f"Worker loop has been disrupted while handling task"
+                   f" {task.id or 'Unknown ID'} from collection"
+                   f" {task.collection_id or 'Unknown ID'}")
             finally:
                 clear_contextvars()