Skip to content

Commit

Permalink
revert async_connector change
Browse files Browse the repository at this point in the history
  • Loading branch information
masahi committed Mar 15, 2024
1 parent ad482bf commit 39065c2
Showing 1 changed file with 1 addition and 4 deletions.
5 changes: 1 addition & 4 deletions serve/mlc_serve/engine/async_connector.py
Original file line number Diff line number Diff line change
Expand Up @@ -150,10 +150,7 @@ async def _add_request(self, request: Request) -> ResultQueue:
queue = asyncio.Queue()
self.result_queues[request.request_id] = queue

try:
await asyncio.to_thread(self.engine.add, [request])
except TextGenerationError as e:
raise asyncio.CancelledError(e)
await asyncio.to_thread(self.engine.add, [request])

return queue

Expand Down

0 comments on commit 39065c2

Please sign in to comment.