Duplicate submission check

src/submission/submit.py

@@ -17,6 +17,19 @@ from shared.workflows.structs import TossupWorkflow, Workflow
 from submission.structs import CompetitionType, Submission, SubmissionStatus, SubmissionType
 
 
+def make_unique_submission_key(submission: dict) -> str:
+    stype = submission["submission_type"]
+    if stype == "simple_workflow":
+        workflow = submission["workflow"]
+        workflow["steps"].sort(key=lambda x: x["id"])
+        wstr = json.dumps(workflow, sort_keys=True, ensure_ascii=False)
+        return f"workflow:{wstr}"
+    elif stype == "hf_pipeline":
+        return f"hf:{submission['model_name']}"
+    else:
+        raise ValueError(f"Unsupported submission type {stype}")
+
+
 def get_user_submissions(username: str, competition_type: str, pattern: str = None) -> list[Submission]:
     """Get all submissions for a user."""
     out_dir = f"{LOCAL_REQUESTS_PATH}/{username}"
@@ -234,6 +247,15 @@ def submit_agent(
         # Convert to dictionary format
         submission_dict = submission.to_dict()
 
+        user_submissions = [s.model_dump() for s in get_user_submissions(username, competition_type)]
+        unq_keys = {make_unique_submission_key(s): s["model_name"] for s in user_submissions}
+        submission_key = make_unique_submission_key(submission_dict)
+        if submission_key in unq_keys:
+            similar_model = unq_keys[submission_key]
+            return styled_error(
+                f"Duplicate submission!<br> You submission is equivalent to your previous submission '{similar_model}'."
+            )
+
         # Create output directory path
 
         rel_filepath = f"{username}/{submission.id}.json"