Fix timeout

allenai · Nov 14, 2024 · 06331d7 · 06331d7
1 parent 8e16780
commit 06331d7
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pdelfin/beakerpipeline.py b/pdelfin/beakerpipeline.py
@@ -480,8 +480,8 @@ async def process_line(line):
 
             last_queue_req = queue_req
 
-        # And have a semaphore release automatically if there are no running requests for > 30 seconds
-        if last_running_req == 0 and can_release_automatically and time.time() - last_semaphore_release > 30 and semaphore.locked():
+        # And have a semaphore release automatically if there are no queued requests for > 30 seconds
+        if last_queue_req == 0 and can_release_automatically and time.time() - last_semaphore_release > 30 and semaphore.locked():
             semaphore.release()
             last_semaphore_release = time.time()
             can_release_automatically = False