fix: flaky tests

Author: CahidArda

src/client/index.test.ts

@@ -133,10 +133,17 @@ describe("workflow client", () => {
           url: "http://requestcatcher.com",
         });
 
-        const firstCancel = await liveClient.cancel({
-          ids: [workflowRunIdOne, workflowRunIdTwo, "non-existent"],
-        });
-        expect(firstCancel).toEqual({ cancelled: 2 });
+        await new Promise((r) => setTimeout(r, 2000));
+
+        eventually(
+          async () => {
+            const firstCancel = await liveClient.cancel({
+              ids: [workflowRunIdOne, workflowRunIdTwo, "non-existent"],
+            });
+            expect(firstCancel).toEqual({ cancelled: 2 });
+          },
+          { timeout: 5000, interval: 1000 }
+        );
 
         // trying to cancel the workflows one by one gives error, as they were canceled above
         const secondCancel = await liveClient.cancel({ ids: workflowRunIdOne });
@@ -147,7 +154,7 @@ describe("workflow client", () => {
         expect(thirdCancel).toEqual({ cancelled: 0 });
       },
       {
-        timeout: 10000,
+        timeout: 20000,
       }
     );
 
@@ -161,14 +168,20 @@ describe("workflow client", () => {
           url: "http://requestcatcher.com/second",
         });
 
-        const cancel = await liveClient.cancel({
-          urlStartingWith: "http://requestcatcher.com",
-        });
+        await new Promise((r) => setTimeout(r, 2000));
 
-        expect(cancel).toEqual({ cancelled: 2 });
+        eventually(
+          async () => {
+            const cancel = await liveClient.cancel({
+              urlStartingWith: "http://requestcatcher.com",
+            });
+            expect(cancel).toEqual({ cancelled: 2 });
+          },
+          { timeout: 5000, interval: 1000 }
+        );
       },
       {
-        timeout: 10000,
+        timeout: 15000,
       }
     );
 

src/serve/serve-many.test.ts

@@ -17,7 +17,7 @@ describe("serveMany", () => {
     test("should throw if workflowId contains '/'", () => {
       const throws = () =>
         serveMany({
-          "workflow/one": createWorkflow(async () => { }),
+          "workflow/one": createWorkflow(async () => {}),
         });
       expect(throws).toThrow(
         "Invalid workflow name found: 'workflow/one'. Workflow name cannot contain '/'."
@@ -26,7 +26,7 @@ describe("serveMany", () => {
 
     test("should throw if workflowId doesn't match", async () => {
       const { POST: handler } = serveMany({
-        "workflow-one": createWorkflow(async () => { }),
+        "workflow-one": createWorkflow(async () => {}),
       });
 
       const request = new Request("http://localhost:3001/workflow-two", { method: "POST" });