add global lock for git-push.

src/submission/submit.py

@@ -5,7 +5,7 @@ from datetime import datetime, timezone
 from huggingface_hub import ModelCard, snapshot_download
 
 from src.display.formatting import styled_error, styled_message, styled_warning
-from src.envs import API, EVAL_REQUESTS_PATH, DYNAMIC_INFO_PATH, DYNAMIC_INFO_FILE_PATH, DYNAMIC_INFO_REPO, H4_TOKEN, QUEUE_REPO, RATE_LIMIT_PERIOD, RATE_LIMIT_QUOTA, REPO, GIT_REQUESTS_PATH, GIT_STATUS_PATH
+from src.envs import API, EVAL_REQUESTS_PATH, DYNAMIC_INFO_PATH, DYNAMIC_INFO_FILE_PATH, DYNAMIC_INFO_REPO, H4_TOKEN, QUEUE_REPO, RATE_LIMIT_PERIOD, RATE_LIMIT_QUOTA, REPO, GIT_REQUESTS_PATH, GIT_STATUS_PATH, GLOBAL_COND
 from src.leaderboard.filter_models import DO_NOT_SUBMIT_MODELS
 from src.submission.check_validity import (
     already_submitted_models,
@@ -220,23 +220,30 @@ def add_new_eval(
     sta_out_path = f"{OUT_DIR}/{model_path}_eval_request_{private}_{quant_type}_{precision}_{weight_dtype}_{compute_dtype}.json"
     sta_git_path = "/".join(sta_out_path.split('/')[1:])
 
-
-    print("Uploading eval file")
-
-    REPO.index.remove("requests", False, r=True)
-
     with open(req_out_path, "w") as f:
         f.write(json.dumps(eval_entry, indent=4))
     with open(sta_out_path, "w") as f:
         f.write(json.dumps(eval_entry, indent=4))
 
-    branch = REPO.active_branch.name
-    REPO.index.add([req_git_path, sta_git_path])
-    commit = REPO.index.commit(f"Add {model} to eval requests/status.")
-    # REPO.index.add([sta_git_path])
-    # commit = REPO.index.commit(f"Add {model} to eval status")
-    REPO.remotes.origin.pull(branch)
-    REPO.remotes.origin.push(branch)
+
+    print("Uploading eval file")
+    try:
+        print("git-push get lock..............")
+        GLOBAL_COND.acquire()
+        REPO.remotes.origin.pull(branch)
+        REPO.remotes.origin.push(branch)
+
+        REPO.index.remove("requests", False, r=True)
+
+        branch = REPO.active_branch.name
+        REPO.index.add([req_git_path, sta_git_path])
+        commit = REPO.index.commit(f"Add {model} to eval requests/status.")
+
+        print("git-push release lock..............")
+        GLOBAL_COND.release()
+    except:
+        print("git-push error........")
+        GLOBAL_COND.release()
 
     return styled_message(
         "Your request has been submitted to the evaluation queue!\nPlease wait for up to an hour for the model to show in the PENDING list."