Fix early shutdown logic (#24)

Author: yqiu24

javascript/dist/queue/Worker.js

@@ -132,7 +132,8 @@ class Worker extends BaseRunner_1.BaseRunner {
         const totalWorkers = await this.client.sMembers(this.key('workers'));
         const totalWorkersCount = totalWorkers.length;
         console.log("[ci-queue] Total workers count: ", totalWorkersCount);
-        const stayRunningThreshold = Math.min(Math.floor(totalWorkersCount * 0.6), 1);
+        // Only keep 20% of workers running
+        const stayRunningThreshold = Math.max(Math.floor(totalWorkersCount * 0.2), 1);
         console.log("[ci-queue] Threshold for early shutdown: ", stayRunningThreshold);
         const parallelJob = parseInt(this.config.workerId, 10);
         const shouldShutdownEarly = parallelJob > stayRunningThreshold;

javascript/src/queue/Worker.ts

@@ -192,7 +192,8 @@ export class Worker extends BaseRunner {
     const totalWorkersCount = totalWorkers.length;
     console.log("[ci-queue] Total workers count: ", totalWorkersCount);
 
-    const stayRunningThreshold = Math.min(Math.floor(totalWorkersCount * 0.4), 1);
+    // Only keep 20% of workers running
+    const stayRunningThreshold = Math.max(Math.floor(totalWorkersCount * 0.2), 1);
     console.log("[ci-queue] Threshold for early shutdown: ", stayRunningThreshold);
 
     const parallelJob = parseInt(this.config.workerId, 10);