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.
MultiprocExecutor.workers
1 parent c20ef40 commit ed5272cCopy full SHA for ed5272c
vllm/v1/executor/multiproc_executor.py
@@ -258,9 +258,10 @@ def shutdown(self):
258
self.io_thread_pool.shutdown(wait=False, cancel_futures=True)
259
self.io_thread_pool = None
260
261
- for w in self.workers:
262
- w.worker_response_mq = None
263
- self._ensure_worker_termination([w.proc for w in self.workers])
+ if workers := getattr(self, 'workers', None):
+ for w in workers:
+ w.worker_response_mq = None
264
+ self._ensure_worker_termination([w.proc for w in workers])
265
266
self.rpc_broadcast_mq = None
267
0 commit comments