Skip to content

Commit b8d1ef2

Browse files
Update TaskManager.test.ts
1 parent 87c244c commit b8d1ef2

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

src/task/__tests__/TaskManager.test.ts

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -107,7 +107,7 @@ describe("TaskManager", () => {
107107
const worker: ConductorWorker = {
108108
taskDefName: "taskmanager-error-test",
109109
execute: async () => {
110-
throw Error("This is a forced error");
110+
throw new Error("This is a forced error");
111111
},
112112
};
113113

@@ -134,7 +134,7 @@ describe("TaskManager", () => {
134134
correlationId: "noErrorHandlerProvidedIdentifier"
135135
});
136136

137-
const workflowStatus = await TestUtil.waitForWorkflowCompletion(executor, executionId!, BASE_TIME * 4);
137+
const workflowStatus = await TestUtil.waitForWorkflowCompletion(executor, executionId!, BASE_TIME * 10);
138138
expect(workflowStatus.status).toEqual("FAILED");
139139
await manager.stopPolling();
140140
});
@@ -323,7 +323,7 @@ describe("TaskManager", () => {
323323
// decrease speed again
324324
manager.updatePollingOptions({ pollInterval: BASE_TIME, concurrency: 1 });
325325

326-
const workflowStatus = await TestUtil.waitForWorkflowCompletion(executor, executionId, BASE_TIME * 4);
326+
const workflowStatus = await TestUtil.waitForWorkflowCompletion(executor, executionId, BASE_TIME * 10);
327327

328328
expect(workflowStatus.status).toEqual("COMPLETED");
329329
await manager.stopPolling();

0 commit comments

Comments
 (0)