Added timeout to pre_submit_lock in while-cycle

app.py

@@ -530,7 +530,7 @@ def gradio_app():
                     pre_submission_btn.click(
                         fn=on_submit_pressed,
                         outputs=[pre_submission_btn],
-                    ).then(  # TODO: Zjistit proč to neběží konkurentně.
+                    ).then(
                         fn=process_submission,
                         inputs=list(submission_inputs.values()),
                         outputs=[
@@ -541,6 +541,7 @@ def gradio_app():
                             pre_submit_info,
                             pre_submit_table,
                         ],
+                        concurrency_limit=None,
                     )
 
                     submission_btn_yes.click(

server.py

@@ -107,7 +107,27 @@ def check_significance(model_a_path, model_b_path):
     result = check_significance_wait_for_result(result_url)
     return result
 
-pre_submit_lock = Lock()
+class TimeoutLock:
+    def __init__(self, lock=None, timeout=-1):
+        self.lock = lock or Lock()
+        self.timeout = timeout
+        self._lock_acquired = False
+
+    def __enter__(self):
+        acquired = self.lock.acquire(timeout=self.timeout)
+        if acquired:
+            self._lock_acquired = True
+        return acquired
+
+    def __exit__(self, exc_type, exc_val, exc_tb):
+        if self._lock_acquired:
+            self.lock.release()
+            self._lock_acquired = False
+    
+    def __call__(self, timeout):
+        return TimeoutLock(lock=self.lock, timeout=timeout)
+
+pre_submit_lock = TimeoutLock()
 
 class _ReadLock:
     def __init__(self, lock):
@@ -312,8 +332,8 @@ class LeaderboardServer:
         """
         
         while True:
-            with self.pre_submit_lock:
-                if self.pre_submit == None:
+            with self.pre_submit_lock(timeout=5) as acquired:
+                if acquired and self.pre_submit == None:
                     gr.Info('Checking integrity...', duration=15)
                     self.update_leaderboard()
                     
@@ -703,8 +723,8 @@ class LeaderboardServer:
             json.dump(data, f, separators=(',', ':'))  # compact JSON
         
         while True:
-            with self.pre_submit_lock:
-                if self.pre_submit == None:
+            with self.pre_submit_lock(timeout=5) as acquired:
+                if acquired and self.pre_submit == None:
                     gr.Info('Running tournament...', duration=15)
                     self.update_leaderboard()
                     if HF_FAKE_TOURNAMENT: