diff --git a/packages/api/src/webhooks/cannon.test.ts b/packages/api/src/webhooks/cannon.test.ts
index e599bef126..629b1345f5 100644
--- a/packages/api/src/webhooks/cannon.test.ts
+++ b/packages/api/src/webhooks/cannon.test.ts
@@ -286,8 +286,7 @@ describe("webhook cannon", () => {
       expect(callCount).toBe(1);
       expect(receivedEvent).toBe("stream.started");
 
-      // at this point the semaphore is re-acquired cause we just waited (acquired) above
-
+      sem = semaphore();
       await server.queue.publishWebhook("events.stream.idle", {
         type: "webhook_event",
         id: "webhook_test_42",
@@ -302,6 +301,7 @@ describe("webhook cannon", () => {
       expect(receivedEvent).toBe("stream.idle");
 
       // does not receive some random event
+      sem = semaphore();
       await server.queue.publishWebhook("events.stream.unknown" as any, {
         type: "webhook_event",
         id: "webhook_test_93",
@@ -311,8 +311,7 @@ describe("webhook cannon", () => {
         userId: nonAdminUser.id,
       });
 
-      const err = await sem.wait(1000).catch((err) => err);
-      expect(err?.message).toBe("timeout");
+      await sem.wait(1000);
       expect(callCount).toBe(2);
     });