Skip to content

Commit

Permalink
updated
Browse files Browse the repository at this point in the history
  • Loading branch information
robertgshaw2-redhat committed Jan 3, 2025
1 parent b7c50dc commit dcfd3b8
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions vllm/v1/executor/multiproc_executor.py
Original file line number Diff line number Diff line change
Expand Up @@ -390,7 +390,6 @@ class ResponseStatus(Enum):

def worker_busy_loop(self):
"""Main busy loop for Multiprocessing Workers"""

while True:
method, args, kwargs = self.rpc_broadcast_mq.dequeue()

Expand All @@ -403,7 +402,7 @@ def worker_busy_loop(self):
(WorkerProc.ResponseStatus.FAILURE, e))
traceback = get_exception_traceback()
logger.error("WorkerProc hit an exception: %s", traceback)
raise SystemExit()
continue

self.worker_response_mq.enqueue(
(WorkerProc.ResponseStatus.SUCCESS, output))

0 comments on commit dcfd3b8

Please sign in to comment.