From 90abc69ce1ece8ef3313dc7708654a30990b1115 Mon Sep 17 00:00:00 2001 From: HermanL02 Date: Thu, 1 May 2025 15:27:38 -0300 Subject: [PATCH] single - submission - strategy --- worker/src/task/2-submission.ts | 35 ++++++++++++++------------------- 1 file changed, 15 insertions(+), 20 deletions(-) diff --git a/worker/src/task/2-submission.ts b/worker/src/task/2-submission.ts index 29a0d6a..632a0b5 100644 --- a/worker/src/task/2-submission.ts +++ b/worker/src/task/2-submission.ts @@ -19,35 +19,30 @@ export async function submission(roundNumber: number) : Promise { return; } console.log("[SUBMISSION] Orca client initialized successfully"); - console.log(`[SUBMISSION] Fetching task result for round ${roundNumber}...`); - const taskResult = await namespaceWrapper.storeGet(`result-${roundNumber}`); - if (!taskResult) { - console.log("[SUBMISSION] No task result found for this round"); - return status.NO_DATA_FOR_THIS_ROUND; - } - console.log(`[SUBMISSION] Task result status: ${taskResult}`); - - if (taskResult !== status.SAVING_TODO_PR_SUCCEEDED) { - console.log(`[SUBMISSION] Task not successfully summarized. Status: ${taskResult}`); + const shouldMakeSubmission = await namespaceWrapper.storeGet(`shouldMakeSubmission`); + if (!shouldMakeSubmission || shouldMakeSubmission !== "true") { + const taskResult = await namespaceWrapper.storeGet(`result-${roundNumber}`); + if (!taskResult) { + console.log("[SUBMISSION] No task result found for this round"); + return status.NO_DATA_FOR_THIS_ROUND; + } return taskResult; } - - console.log(`[SUBMISSION] Fetching submission data for round ${roundNumber}...`); - const result = await orcaClient.podCall(`submission/${roundNumber}`); + const submissionRoundNumber = await namespaceWrapper.storeGet(`submissionRoundNumber`); + if (!submissionRoundNumber) { + console.log("[SUBMISSION] No submission Round Number found for this round"); + return status.NO_DATA_FOR_THIS_ROUND; + } + console.log(`[SUBMISSION] Fetching submission data for round ${roundNumber}. and submission roundnumber ${submissionRoundNumber}`); + const result = await orcaClient.podCall(`submission/${submissionRoundNumber}`); let submission; console.log("[SUBMISSION] Submission result:", result.data); if (result.data === "No submission") { - // console.log("[SUBMISSION] No existing submission found, creating new submission object"); console.log("[SUBMISSION] No existing submission found"); - return status.NOT_FINISHED_TASK; - // submission = { - // githubUsername: process.env.GITHUB_USERNAME, - // prUrl: "none", - // roundNumber, - // }; + return status.NO_SUBMISSION_BUT_SUBMISSION_CALLED; } else { submission = result.data; }