roll back

oj-lab · Sep 22, 2024 · 6d2881f · 6d2881f
1 parent 18a971a
commit 6d2881f
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 12 deletions.
diff --git a/judger/src/agent/platform/mod.rs b/judger/src/agent/platform/mod.rs
@@ -43,11 +43,10 @@ impl PlatformClient {
 
     pub async fn report_judge_task(
         &self,
-        judge_uid: &str,
         stream_id: &str,
         verdict: JudgeVerdict,
     ) -> Result<(), anyhow::Error> {
-        report_task(&self.client, judge_uid, stream_id, verdict).await
+        report_task(&self.client, stream_id, verdict).await
     }
 }
 
@@ -164,8 +163,6 @@ async fn report_judge_result(
 
 #[derive(Serialize)]
 struct ReportJudgeTaskBody {
-    #[serde(rename = "judgeUID")]
-    judge_uid: String,
     consumer: String,
     #[serde(rename = "redisStreamID")]
     redis_stream_id: String,
@@ -178,13 +175,11 @@ struct ReportJudgeTaskResponse {
 
 async fn report_task(
     client: &HttpClient,
-    judge_uid: &str,
     stream_id: &str,
     verdict: JudgeVerdict,
 ) -> Result<(), anyhow::Error> {
     let report_url = "api/v1/judge/task/report";
     let body = ReportJudgeTaskBody {
-        judge_uid: judge_uid.to_owned(),
         consumer: "".to_string(),
         redis_stream_id: stream_id.to_owned(),
         verdict,

diff --git a/judger/src/worker/mod.rs b/judger/src/worker/mod.rs
@@ -84,11 +84,7 @@ impl JudgeWorker {
                             verdict = JudgeVerdict::CompileError;
                         }
                         let _ = platform_client
-                            .report_judge_task(
-                                &task.judge_uid,
-                                &task.redis_stream_id.clone(),
-                                verdict,
-                            )
+                            .report_judge_task(&task.redis_stream_id.clone(), verdict)
                             .await
                             .map_err(|e| {
                                 log::debug!("Failed to report judge task: {:?}", e);
@@ -153,7 +149,7 @@ impl JudgeWorker {
                     }
 
                     let _ = platform_client
-                        .report_judge_task(&task.judge_uid, &task.redis_stream_id.clone(), verdict)
+                        .report_judge_task(&task.redis_stream_id.clone(), verdict)
                         .await
                         .map_err(|e| {
                             log::debug!("Failed to report judge task: {:?}", e);