Log clarity

andystaples · andystaples · commit 57b767316022 · 2025-11-06T14:00:59.000-07:00
diff --git a/durabletask/worker.py b/durabletask/worker.py
@@ -2089,7 +2089,7 @@ async def run(self):
                     )
                 )
         except Exception as queue_exception:
-            self._logger.error(f"Uncaught error in activity manager thread pool: {queue_exception}")
+            self._logger.error(f"Shutting down worker - Uncaught error in activity manager thread pool: {queue_exception}")
             while self.activity_queue is not None and not self.activity_queue.empty():
                 try:
                     func, cancellation_func, args, kwargs = self.activity_queue.get_nowait()

Original file line number	Diff line number	Diff line change
`@@ -2089,7 +2089,7 @@ async def run(self):`
`2089`	`2089`	`)`
`2090`	`2090`	`)`
`2091`	`2091`	`except Exception as queue_exception:`
`2092`		`- self._logger.error(f"Uncaught error in activity manager thread pool: {queue_exception}")`
	`2092`	`+ self._logger.error(f"Shutting down worker - Uncaught error in activity manager thread pool: {queue_exception}")`
`2093`	`2093`	`while self.activity_queue is not None and not self.activity_queue.empty():`
`2094`	`2094`	`try:`
`2095`	`2095`	`func, cancellation_func, args, kwargs = self.activity_queue.get_nowait()`