We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 4e0a541 commit ce73ffaCopy full SHA for ce73ffa
temporalio/worker/_worker.py
@@ -762,11 +762,14 @@ async def raise_on_shutdown():
762
if worker and task.done() and task.exception():
763
tasks[worker] = asyncio.create_task(worker.drain_poll_queue())
764
765
+ logger.info("Task drain done")
766
+
767
# Notify shutdown occurring
768
if self._activity_worker:
769
self._activity_worker.notify_shutdown()
770
if self._workflow_worker:
771
self._workflow_worker.notify_shutdown()
772
+ logger.info("workers notified")
773
774
# Wait for all tasks to complete (i.e. for poller loops to stop)
775
await asyncio.wait(tasks.values())
0 commit comments