fix flaky integration test MethodInvokeIT (#959)

* fix flaky it MethodInvokeIT Signed-off-by: MregXN <[email protected]> * add debug print Signed-off-by: MregXN <[email protected]> * add debug print Signed-off-by: MregXN <[email protected]> * add more waiting time Signed-off-by: MregXN <[email protected]> * wait before invoke Signed-off-by: MregXN <[email protected]> * wait for health before invoke Signed-off-by: MregXN <[email protected]> --------- Signed-off-by: MregXN <[email protected]> Co-authored-by: Artur Souza <[email protected]>
dapr · Nov 20, 2023 · e4cb03f · e4cb03f
1 parent 5c79585
commit e4cb03f
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/sdk-tests/src/test/java/io/dapr/it/methodinvoke/grpc/MethodInvokeIT.java b/sdk-tests/src/test/java/io/dapr/it/methodinvoke/grpc/MethodInvokeIT.java
@@ -41,13 +41,15 @@ public void init() throws Exception {
           DaprApiProtocol.GRPC,  // appProtocol
           60000);
         daprRun.switchToGRPC();
-        daprRun.waitForAppHealth(20000);
+        daprRun.waitForAppHealth(40000);
     }
 
     @Test
     public void testInvoke() throws Exception {
         try (DaprClient client = new DaprClientBuilder().build()) {
             client.waitForSidecar(10000).block();
+            daprRun.waitForAppHealth(10000);
+
             for (int i = 0; i < NUM_MESSAGES; i++) {
                 String message = String.format("This is message #%d", i);
 
@@ -95,6 +97,8 @@ public void testInvoke() throws Exception {
     public void testInvokeTimeout() throws Exception {
         try (DaprClient client = new DaprClientBuilder().build()) {
             client.waitForSidecar(10000).block();
+            daprRun.waitForAppHealth(10000);
+
             long started = System.currentTimeMillis();
             SleepRequest req = SleepRequest.newBuilder().setSeconds(1).build();
             String message = assertThrows(IllegalStateException.class, () ->
@@ -110,6 +114,8 @@ public void testInvokeTimeout() throws Exception {
     public void testInvokeException() throws Exception {
         try (DaprClient client = new DaprClientBuilder().build()) {
             client.waitForSidecar(10000).block();
+            daprRun.waitForAppHealth(10000);
+
             SleepRequest req = SleepRequest.newBuilder().setSeconds(-9).build();
             DaprException exception = assertThrows(DaprException.class, () ->
                 client.invokeMethod(daprRun.getAppName(), "sleep", req.toByteArray(), HttpExtension.POST).block());