[manager] Reuse testRunId on repeat

Author: jamesgpearce

src/index.ts

@@ -405,6 +405,7 @@ export const createManager: typeof createManagerDecl = (): Manager => {
                       taskRun[TaskRunPositions.Arg],
                       repeatDelay,
                       taskRun[TaskRunPositions.Config],
+                      taskRunId,
                     ),
                 );
               }
@@ -628,6 +629,7 @@ export const createManager: typeof createManagerDecl = (): Manager => {
     arg?: string,
     startAfter: TimestampMs | DurationMs = 0,
     config: TaskRunConfig = {},
+    repeatTestRunId?: Id,
   ): Id | undefined => {
     if (status == ManagerStatusValues.Stopping) {
       return undefined;
@@ -640,7 +642,7 @@ export const createManager: typeof createManagerDecl = (): Manager => {
         taskIdOrArgs.config,
       );
     }
-    const taskRunId = getUniqueId();
+    const taskRunId = repeatTestRunId ?? getUniqueId();
     const startTimestamp = normalizeTimestamp(startAfter);
     mapSet(taskRunMap, taskRunId, [
       id(taskIdOrArgs),

test/unit/core/running.test.ts

@@ -152,16 +152,18 @@ describe('ticks', () => {
     expect(manager.getScheduledTaskRunIds().length).toEqual(0);
     expect(manager.getRunningTaskRunIds()).toEqual([taskRunId]);
     await pause(10);
-    expect(manager.getTaskRunInfo(taskRunId!)).toBeUndefined();
+    expect(manager.getTaskRunInfo(taskRunId!)?.running).toEqual(false);
     expect(manager.getScheduledTaskRunIds().length).toEqual(1);
     expect(manager.getRunningTaskRunIds().length).toEqual(0);
     await pause(10);
     expect(manager.getScheduledTaskRunIds().length).toEqual(1);
     expect(manager.getRunningTaskRunIds().length).toEqual(0);
     await pause(20);
+    expect(manager.getTaskRunInfo(taskRunId!)?.running).toEqual(true);
     expect(manager.getScheduledTaskRunIds().length).toEqual(0);
     expect(manager.getRunningTaskRunIds().length).toEqual(1);
     await pause(30);
+    expect(manager.getTaskRunInfo(taskRunId!)?.running).toEqual(false);
     expect(manager.getScheduledTaskRunIds().length).toEqual(1);
     expect(manager.getRunningTaskRunIds().length).toEqual(0);
     manager.stop();