added email section

app.py

@@ -213,6 +213,7 @@ def _model_hub_page_link(model_id: str) -> str:
 def submit_model(
     model_id: str,
     submission_notes: str,
+    contact_email: str,
     extra_requirements: str,
     setup_script: str,
     custom_script: str,
@@ -255,6 +256,11 @@ def submit_model(
         if not on_hub:
             return styled_error(f"Model '{model_id}' {err_msg}")
 
+    try:
+        job_queue.sanitize_contact_email(contact_email)
+    except ValueError:
+        return styled_error("Please enter a valid email address.")
+
     script_hint = ""
     if (custom_script or "").strip():
         dep_warn = job_queue.custom_script_deprecated_api_warning(custom_script)
@@ -275,6 +281,7 @@ def submit_model(
             model_id,
             family_id,
             submission_notes=submission_notes or "",
+            contact_email=contact_email or "",
             extra_requirements=extra_requirements or "",
             setup_script=setup_script or "",
             custom_script=custom_script or "",
@@ -613,6 +620,11 @@ with gr.Blocks(title=APP_TITLE, theme=_theme, css=LEADERBOARD_CSS) as demo:
                 lines=2,
                 max_length=4000,
             )
+            email_input = gr.Textbox(
+                label="Contact email (optional)",
+                placeholder="you@example.com",
+                max_length=254,
+            )
 
             status_output = gr.HTML()
             gr.Markdown(
@@ -635,8 +647,8 @@ with gr.Blocks(title=APP_TITLE, theme=_theme, css=LEADERBOARD_CSS) as demo:
                 )
                 return extra, setup_out, custom
 
-            def _submit_and_refresh(model_id, notes, reqs, setup, script, recipe, gated):
-                status = submit_model(model_id, notes, reqs, setup, script, recipe, gated)
+            def _submit_and_refresh(model_id, notes, email, reqs, setup, script, recipe, gated):
+                status = submit_model(model_id, notes, email, reqs, setup, script, recipe, gated)
                 try:
                     nxt = job_queue.next_up_html()
                 except Exception as exc:
@@ -660,6 +672,7 @@ with gr.Blocks(title=APP_TITLE, theme=_theme, css=LEADERBOARD_CSS) as demo:
                 inputs=[
                     model_input,
                     notes_input,
+                    email_input,
                     requirements_input,
                     setup_script_input,
                     script_input,

constants.py

@@ -248,6 +248,7 @@ client = Client("__SPACE_ID__")
 result = client.predict(
     "openai/whisper-tiny",  # model id
     "",                      # optional notes
+    "",                      # contact email
     "",                      # extra requirements
     "",                      # setup script
     "",                      # custom evaluator

init.py

@@ -63,6 +63,7 @@ CSV_FIELDS = [
     "eval_rtf",
     "num_params",
     "submission_notes",
+    "contact_email",
     "submitted_at",
 ]
 
@@ -111,6 +112,7 @@ def leaderboard_row_from_eval_result(
     result: dict,
     submitted_at_iso: str,
     submission_notes: str = "",
+    contact_email: str = "",
 ) -> dict:
     """Build a full CSV row; scenario keys missing from `result` are left empty (future metrics)."""
     row = {k: "" for k in CSV_FIELDS}
@@ -156,6 +158,7 @@ def leaderboard_row_from_eval_result(
         if k in result and result[k] is not None and result[k] != "":
             row[k] = str(result[k])
     row["submission_notes"] = (submission_notes or "").strip()[:4000]
+    row["contact_email"] = (contact_email or "").strip()[:254]
     row["submitted_at"] = submitted_at_iso
     return row
 
@@ -164,6 +167,7 @@ def merge_leaderboard_row_from_eval_result(
     result: dict,
     submitted_at_iso: str,
     submission_notes: str = "",
+    contact_email: str = "",
 ) -> None:
     """
     Merge evaluation output into an existing leaderboard row (partial re-eval).
@@ -186,7 +190,7 @@ def merge_leaderboard_row_from_eval_result(
             break
 
     patch = leaderboard_row_from_eval_result(
-        result, submitted_at_iso, submission_notes=submission_notes
+        result, submitted_at_iso, submission_notes=submission_notes, contact_email=contact_email
     )
 
     if match_idx is None:
@@ -204,6 +208,8 @@ def merge_leaderboard_row_from_eval_result(
             row["num_params"] = patch["num_params"]
         if (submission_notes or "").strip():
             row["submission_notes"] = patch["submission_notes"]
+        if (contact_email or "").strip():
+            row["contact_email"] = patch["contact_email"]
         normalize_legacy_csv_row(row)
         rows[match_idx] = row
 
@@ -286,6 +292,7 @@ def load_raw_results(*, refresh: bool = False) -> list[dict]:
                     if not row.get("eval_family"):
                         row["eval_family"] = "N/A"
                     row.setdefault("submission_notes", "")
+                    row.setdefault("contact_email", "")
                     normalize_legacy_csv_row(row)
                 _raw_results_cache = results
                 return [dict(r) for r in results]
@@ -482,6 +489,7 @@ def raw_rows_for_version(version: str) -> list[dict]:
         if not row.get("eval_family"):
             row["eval_family"] = "N/A"
         row.setdefault("submission_notes", "")
+        row.setdefault("contact_email", "")
         normalize_legacy_csv_row(row)
         out.append(row)
     return out
@@ -636,6 +644,7 @@ def raw_rows_for_version(version: str) -> list[dict]:
         if not row.get("eval_family"):
             row["eval_family"] = "N/A"
         row.setdefault("submission_notes", "")
+        row.setdefault("contact_email", "")
         normalize_legacy_csv_row(row)
         out.append(row)
     return out

job_queue.py

@@ -62,6 +62,7 @@ class Job:
     error: str | None = None
     result: dict[str, Any] | None = None
     submission_notes: str = ""
+    contact_email: str = ""
     extra_requirements: str = ""
     setup_script: str = ""
     custom_script: str = ""
@@ -108,6 +109,7 @@ _JOBS_CSV_FIELDS = [
     "updated_at",
     "error",
     "submission_notes",
+    "contact_email",
     "extra_requirements",
     "setup_script_b64",
     "custom_script_b64",
@@ -149,6 +151,19 @@ def sanitize_custom_script(text: str) -> str:
     return s
 
 
+def sanitize_contact_email(text: str) -> str:
+    """Trim and validate an optional submitter email address."""
+    s = (text or "").strip()[:254]
+    if not s:
+        return ""
+    if s.count("@") != 1:
+        raise ValueError("Invalid email address.")
+    local, domain = s.split("@", 1)
+    if not local or not domain or "." not in domain:
+        raise ValueError("Invalid email address.")
+    return s
+
+
 def sanitize_setup_script(text: str) -> str:
     """Trim and cap one-time setup script (shell or Python) for storage."""
     s = (text or "").strip()
@@ -327,6 +342,7 @@ def _persist_jobs() -> None:
                     "updated_at": j.updated_at or j.created_at,
                     "error": (j.error or "").replace("\n", " ")[:2000],
                     "submission_notes": (j.submission_notes or "").replace("\n", " ")[:4000],
+                    "contact_email": (j.contact_email or "").replace("\n", " ")[:254],
                     "extra_requirements": (j.extra_requirements or "").replace("\r\n", "\n")[:8000],
                     "setup_script_b64": _encode_script_b64(j.setup_script or ""),
                     "custom_script_b64": _encode_script_b64(j.custom_script or ""),
@@ -399,6 +415,7 @@ def _load_persisted_jobs_once() -> None:
                 continue
             err = (row.get("error") or "").strip() or None
             notes = (row.get("submission_notes") or "").strip()
+            email = (row.get("contact_email") or "").strip()[:254]
             extra_req = (row.get("extra_requirements") or "").strip()
             setup = _decode_script_b64(row.get("setup_script_b64") or "")
             script = _decode_script_b64(row.get("custom_script_b64") or "")
@@ -434,6 +451,7 @@ def _load_persisted_jobs_once() -> None:
                 updated_at=updated,
                 error=err,
                 submission_notes=notes,
+                contact_email=email,
                 extra_requirements=extra_req,
                 setup_script=setup,
                 custom_script=script,
@@ -580,6 +598,7 @@ def _merge_eval_result_to_leaderboard(
     result: dict,
     submitted_at_iso: str,
     submission_notes: str,
+    contact_email: str = "",
     *,
     replace_existing: bool = False,
     merge_partial: bool = False,
@@ -595,7 +614,10 @@ def _merge_eval_result_to_leaderboard(
 
     if merge_partial:
         merge_leaderboard_row_from_eval_result(
-            result, submitted_at_iso, submission_notes=submission_notes
+            result,
+            submitted_at_iso,
+            submission_notes=submission_notes,
+            contact_email=contact_email,
         )
         return
 
@@ -607,7 +629,10 @@ def _merge_eval_result_to_leaderboard(
             rows.pop(i)
 
     new_row = leaderboard_row_from_eval_result(
-        result, submitted_at_iso, submission_notes=submission_notes
+        result,
+        submitted_at_iso,
+        submission_notes=submission_notes,
+        contact_email=contact_email,
     )
     normalize_legacy_csv_row(new_row)
     rows.append(new_row)
@@ -682,20 +707,36 @@ def _load_artifact_json_from_bucket(artifact_path: str) -> dict:
             pass
 
 
-def _submission_notes_for_artifact_import(
-    data: dict, artifact_path: str, override: str
-) -> str:
-    notes = (override or "").strip()
-    if notes:
-        return notes[:4000]
+def _submission_fields_for_artifact_import(
+    data: dict, artifact_path: str, notes_override: str, email_override: str
+) -> tuple[str, str]:
+    notes = (notes_override or "").strip()[:4000]
+    email = (email_override or "").strip()[:254]
+    if notes and email:
+        return notes, email
     space_job_id = str(data.get("job_id") or "").strip()
     with _jobs_lock:
         for j in _jobs.values():
             if space_job_id and j.id == space_job_id:
-                return (j.submission_notes or "").strip()[:4000]
+                if not notes:
+                    notes = (j.submission_notes or "").strip()[:4000]
+                if not email:
+                    email = (j.contact_email or "").strip()[:254]
+                return notes, email
             if (j.remote_artifact_path or "").strip() == artifact_path:
-                return (j.submission_notes or "").strip()[:4000]
-    return ""
+                if not notes:
+                    notes = (j.submission_notes or "").strip()[:4000]
+                if not email:
+                    email = (j.contact_email or "").strip()[:254]
+                return notes, email
+    return notes, email
+
+
+def _submission_notes_for_artifact_import(
+    data: dict, artifact_path: str, override: str
+) -> str:
+    notes, _ = _submission_fields_for_artifact_import(data, artifact_path, override, "")
+    return notes
 
 
 def _mark_job_done_for_artifact(
@@ -770,7 +811,9 @@ def import_artifact_to_leaderboard(
     if not model_id:
         return False, "Artifact result is missing model_id."
 
-    notes = _submission_notes_for_artifact_import(data, artifact_path, submission_notes)
+    notes, email = _submission_fields_for_artifact_import(
+        data, artifact_path, submission_notes, ""
+    )
     rows = load_raw_results()
     existing = [i for i, r in enumerate(rows) if (r.get("model_id") or "").strip() == model_id]
 
@@ -790,7 +833,9 @@ def import_artifact_to_leaderboard(
             rows.pop(i)
 
     submitted_at = _now_iso()
-    new_row = leaderboard_row_from_eval_result(result, submitted_at, submission_notes=notes)
+    new_row = leaderboard_row_from_eval_result(
+        result, submitted_at, submission_notes=notes, contact_email=email
+    )
     normalize_legacy_csv_row(new_row)
     rows.append(new_row)
     _leaderboard_sort_rows_inplace(rows)
@@ -950,6 +995,7 @@ def _remote_start_queued_job(job_id: str, jobs_token: str) -> None:
         mid = j.model_id
         fid = j.family_id
         notes = j.submission_notes or ""
+        email = j.contact_email or ""
         j.status = JobStatus.running
         j.progress_done = 0
         j.progress_total = 0
@@ -994,6 +1040,7 @@ def _remote_tick_job(job_id: str, jobs_token: str) -> None:
         mid = j.model_id
         fid = j.family_id
         notes = j.submission_notes or ""
+        email = j.contact_email or ""
 
     # Grace window absorbs the brief gap between the worker script returning
     # rc=0 (and uploading the JSON artifact) and the Hub flipping the job's
@@ -1035,6 +1082,7 @@ def _remote_tick_job(job_id: str, jobs_token: str) -> None:
                 result,
                 _now_iso(),
                 notes,
+                email,
                 replace_existing=replace_lb and not partial,
                 merge_partial=partial,
             )
@@ -1157,6 +1205,7 @@ def enqueue(
     family_id: str,
     submission_notes: str = "",
     *,
+    contact_email: str = "",
     extra_requirements: str = "",
     setup_script: str = "",
     custom_script: str = "",
@@ -1199,6 +1248,7 @@ def enqueue(
     created = _now_iso()
     notes_clean = (submission_notes or "").strip()[:4000]
     try:
+        email_clean = sanitize_contact_email(contact_email)
         from recipes.registry import apply_recipe_to_submission
 
         req_lines = parse_requirements_lines(extra_requirements)
@@ -1231,6 +1281,7 @@ def enqueue(
         created_at=created,
         updated_at=created,
         submission_notes=notes_clean,
+        contact_email=email_clean,
         extra_requirements=extra_req_clean,
         setup_script=setup_clean,
         custom_script=script_clean,