retrigger test

Signed-off-by: MregXN <[email protected]>

test/e2e/common/server.test.ts

@@ -50,8 +50,8 @@ const bulkSubscribeClodEventTopic = "bulk-subscribe-ce-topic";
 const bulkSubscribeCloudEventToRawPayloadTopic = "bulk-subscribe-ce-rp-topic";
 const bulkSubscribeRawPayloadToClodEventTopic = "bulk-subscribe-rp-ce-topic";
 
-// Set timeout to 11s for all tests
-jest.setTimeout(11000);
+// Set timeout to 10s for all tests
+jest.setTimeout(10000);
 
 describe("common/server", () => {
   let httpServer: DaprServer;
@@ -139,14 +139,8 @@ describe("common/server", () => {
 
     await setupPubSubSubscriptions();
 
-    // Sleep 1s to get subscriptions ready
-    await NodeJSUtil.sleep(3000);
-
     await httpServer.start();
     await grpcServer.start();
-
-    // Sleep 1s to get server ready
-    await NodeJSUtil.sleep(3000);
   });
 
   beforeEach(() => {
@@ -171,7 +165,7 @@ describe("common/server", () => {
         const res = await server.client.pubsub.publish(pubSubName, getTopic(topicWithStatusCb, protocol), "SUCCESS");
         expect(res.error).toBeUndefined();
         // Delay a bit for event to arrive
-        await new Promise((resolve, _reject) => setTimeout(resolve, 1000));
+        await new Promise((resolve, _reject) => setTimeout(resolve, 5000));
         expect(mockSubscribeStatusHandler.mock.calls.length).toBe(1);
         expect(mockSubscribeStatusHandler.mock.calls[0][1]).toEqual("SUCCESS");
         expect(mockSubscribeDeadletterHandler.mock.calls.length).toBe(0);