[Bugfix][V1][Minor] Fix shutting_down flag checking in V1 MultiprocExecutor (#14053)

This commit is contained in:
Li, Jiang
2025-03-01 14:31:01 +08:00
committed by GitHub
parent 6a92ff93e1
commit 02296f420d

View File

@ -170,7 +170,7 @@ class MultiprocExecutor(Executor):
def shutdown(self):
"""Properly shut down the executor and its workers"""
if getattr(self, 'shutting_down', False):
if not getattr(self, 'shutting_down', False):
self.shutting_down = True
for w in self.workers:
w.worker_response_mq = None