Return status of populate (#22)

Author: yqiu24

javascript/dist/queue/Worker.d.ts

@@ -9,7 +9,7 @@ export declare class Worker extends BaseRunner {
     acknowledge(test: string): Promise<boolean>;
     requeue(test: string, offset?: number): Promise<boolean>;
     release(): Promise<void>;
-    populate(tests: string[], seed?: number): Promise<void>;
+    populate(tests: string[], seed?: number): Promise<boolean>;
     shutdown(): void;
     private throwOnMismatchingTest;
     private reserveTest;

javascript/dist/queue/Worker.js

@@ -64,15 +64,20 @@ class Worker extends BaseRunner_1.BaseRunner {
         if (this.config.retriedBuildId) {
             console.log(`[ci-queue] Retrying failed tests for build ${this.config.retriedBuildId}`);
             const failedTestGroups = await this.getFailedTestGroupsFromPreviousBuild();
+            if (failedTestGroups.length === 0) {
+                console.log(`[ci-queue] No failed tests found for build ${this.config.retriedBuildId}`);
+                return false;
+            }
             console.log(`[ci-queue] Failed test groups: ${failedTestGroups}`);
             await this.push(failedTestGroups);
-            return;
+            return true;
         }
         console.log(`[ci-queue] Populating tests`);
         if (seed !== undefined) {
             tests = (0, utils_1.shuffleArray)(tests, seed);
         }
         await this.push(tests);
+        return true;
     }
     shutdown() {
         this.shutdownRequired = true;

javascript/src/queue/Worker.ts

@@ -91,20 +91,25 @@ export class Worker extends BaseRunner {
     );
   }
 
-  async populate(tests: string[], seed?: number) {
+  async populate(tests: string[], seed?: number): Promise<boolean> {
     if (this.config.retriedBuildId) {
       console.log(`[ci-queue] Retrying failed tests for build ${this.config.retriedBuildId}`);
       const failedTestGroups = await this.getFailedTestGroupsFromPreviousBuild();
+      if (failedTestGroups.length === 0) {
+        console.log(`[ci-queue] No failed tests found for build ${this.config.retriedBuildId}`);
+        return false;
+      }
       console.log(`[ci-queue] Failed test groups: ${failedTestGroups}`);
       await this.push(failedTestGroups);
-      return;
+      return true;
     }
 
     console.log(`[ci-queue] Populating tests`);
     if (seed !== undefined) {
       tests = shuffleArray(tests, seed);
     }
     await this.push(tests);
+    return true;
   }
 
   shutdown() {