updated the expire limit for testcases

Author: lightning-sagar

judge-image-for-worker/workers/index.js

@@ -180,7 +180,7 @@ async function processJob(ques_name, code, language, testcases) {
     await redis_server.hSet(`job:${ques_name}:status`, {
       state: "completed",
     });
-    await redis_server.expire(`job:${ques_name}:status`, 30);
+    await redis_server.expire(`job:${ques_name}:status`, 300);
   } catch (err) {
     console.error("Error during job processing:", err);
     await redis_server.setEx(

lib/src/run.js

@@ -80,11 +80,13 @@ export async function judge({
     );
 
     // 7. Push each batch to Redis queue
-    for (const batch of batches) {
-      await redis.rPush(`testcase_queue:${ques_name}`, JSON.stringify(batch));
-      await redis.lPush("job_queue", ques_name);  
+    for (let i = 0; i < batches.length; i++) {
+      const batchName = `${ques_name}_batch_${i + 1}`;
+      await redis.rPush(`testcase_queue:${batchName}`, JSON.stringify(batches[i]));
+      await redis.lPush("job_queue", batchName);  // push unique batch name
     }
 
+
     // 8. Initialize job status
     await redis.hSet(`job:${ques_name}:status`, {
       status: "queued",
@@ -97,8 +99,8 @@ export async function judge({
 
     // 9. Wait for job completion
     const waitUntilCompleted = async () => {
-      const POLL_INTERVAL = 500; // ms
-      const MAX_ATTEMPTS = 60; // 30 seconds
+      const POLL_INTERVAL = 1000; // ms
+      const MAX_ATTEMPTS = 120; // 30 seconds
       let attempts = 0;
 
       while (attempts < MAX_ATTEMPTS) {