Drop times queue wait

Author: sjmonson

src/guidellm/scheduler/worker.py

@@ -31,7 +31,6 @@
 from guidellm.scheduler.result import (
     MPQueues,
     SchedulerRequestInfo,
-    WorkerProcessRequestTime,
     WorkerProcessResult,
 )
 from guidellm.scheduler.types import RequestT, ResponseT
@@ -109,13 +108,6 @@ async def resolve(
         """
         ...
 
-    async def get_request_time(
-        self,
-        times_queue: Queue[WorkerProcessRequestTime],
-        timeout: Optional[int] = None,
-    ) -> WorkerProcessRequestTime:
-        return await asyncio.to_thread(times_queue.get, timeout=timeout)  # type: ignore[attr-defined]
-
     async def send_result(
         self,
         results_queue: Queue[WorkerProcessResult[RequestT, ResponseT]],
@@ -205,7 +197,7 @@ async def _process_runner():
                         else queues.requests.get_nowait()
                     )
                     dequeued_time = time.time()
-                    request_times = await self.get_request_time(queues.times, 5)
+                    request_times = queues.times.get_nowait()
                 except (QueueEmpty, IndexError):
                     # Requeue the session if we don't have a next time yet
                     if request_session is not None: