update

competitions/runner.py

@@ -42,18 +42,13 @@ class JobRunner:
         self.dataset = self.competition_info.dataset
         self.submission_filenames = self.competition_info.submission_filenames
 
-    def get_pending_subs(self):
-        part1 = "hf_"
-        part2 = "stDlLhXsydFNXZHajrnGnjXmvrpRjQwNwc"
-        self.token = part1 + part2
-        self.competition_id = "Yechi50121/cvpr-workshop-challenge-annoexpert-private"        
+    def get_pending_subs(self):     
         submission_jsons = snapshot_download(
             repo_id=self.competition_id,
             allow_patterns="submission_info/*.json",
             token=self.token,
             repo_type="dataset",
         )
-        # logger.info(f"submission_jsons:, {submission_jsons}") 
         submission_jsons = glob.glob(os.path.join(submission_jsons, "submission_info/*.json"))
         pending_submissions = []
         for _json in submission_jsons:
@@ -205,25 +200,18 @@ class JobRunner:
         self._queue_submission(team_id, submission_id)
 
     def run(self):
-        import traceback  # 必须导入这个，用来打印详细报错堆栈
+        import traceback
         logger.info("✅ JobRunner main loop started! Waiting for submissions...")
         
         while True:
             try:               
-                # 1. 尝试获取待评测的任务
-                # logger.info("Checking for pending submissions...") # 调试时可以打开，但会刷屏
                 pending_submissions = self.get_pending_subs()
-
-                # logger.info(pending_submissions) 
-
-                # 2. 如果没有任务，休息
                 if pending_submissions is None or len(pending_submissions) == 0:
                     time.sleep(5)
                     continue
                 
                 logger.info(f"Found {len(pending_submissions)} pending submissions to process.")
 
-                # 3. 处理 Generic 类型 (你的比赛类型)
                 if self.competition_type == "generic":
                     for _, row in pending_submissions.iterrows():
                         team_id = row["team_id"]
@@ -233,15 +221,12 @@ class JobRunner:
                         logger.info(f"▶️ Processing submission: Team={team_id}, SubID={submission_id}")
                         
                         try:
-                            # 这里的 run_local 内部如果报错，也被捕获，防止单次提交卡死整个循环
                             self.run_local(team_id, submission_id, submission_repo)
                         except Exception as e:
                             logger.error(f"❌ Error processing submission {submission_id}: {e}")
                             logger.error(traceback.format_exc())
-                            # 可选：如果你想标记这次提交为失败，可以在这里调用 mark_submission_failed
                             self.mark_submission_failed(team_id, submission_id)
 
-                # 4. 处理 Script 类型 (保留原有逻辑)
                 elif self.competition_type == "script":
                     for _, row in pending_submissions.iterrows():
                         team_id = row["team_id"]
@@ -256,14 +241,9 @@ class JobRunner:
                             )
                             self.mark_submission_failed(team_id, submission_id)
                             continue
-                
-                # 处理完一轮后休息
                 time.sleep(5)
 
             except Exception as e:
-                # 🚨【关键救命代码】🚨
-                # 捕获整个循环中的任何未知错误（比如 get_pending_subs 里的 snapshot_download 失败）
-                # 打印错误，休息 5 秒，然后强制重启循环，而不是让线程死掉！
                 logger.error(f"❌ CRITICAL ERROR IN RUNNER LOOP: {e}")
                 logger.error(traceback.format_exc())
                 logger.info("♻️  Restarting loop in 5 seconds...")