Requeue session if we don't receive a start time

Author: sjmonson

src/guidellm/scheduler/worker.py

@@ -186,6 +186,7 @@ async def _process_runner():
             while True:  # TODO: Exit condition
                 await lock.acquire()
 
+                request_session = None
                 try:
                     request_session = (
                         pending_sessions.pop()
@@ -195,6 +196,9 @@ async def _process_runner():
                     dequeued_time = time.time()
                     request_times = queues.times.get()
                 except (QueueEmpty, IndexError):
+                    # Requeue the session if we don't have a next time yet
+                    if request_session is not None:
+                        pending_sessions.append(request_session)
                     lock.release()
                     continue