Skip to content

Commit

Permalink
update
Browse files Browse the repository at this point in the history
  • Loading branch information
aniketmaurya committed Sep 18, 2024
1 parent 801ad63 commit aa1420d
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/litserve/server.py
Original file line number Diff line number Diff line change
Expand Up @@ -214,7 +214,7 @@ def launch_inference_worker(self, num_uvicorn_servers: int):
spec.setup(server_copy)

process_list = []
for worker_id, device in enumerate(self.devices * self.workers_per_device):
for worker_id, device in enumerate(self.inference_workers):
if len(device) == 1:
device = device[0]

Expand Down Expand Up @@ -252,7 +252,7 @@ async def lifespan(self, app: FastAPI):
)

response_queue = self.response_queues[app.response_queue_id]
response_executor = ThreadPoolExecutor(max_workers=len(self.devices * self.workers_per_device))
response_executor = ThreadPoolExecutor(max_workers=len(self.inference_workers))
future = response_queue_to_buffer(response_queue, self.response_buffer, self.stream, response_executor)
task = loop.create_task(future)

Expand Down

0 comments on commit aa1420d

Please sign in to comment.