From 6cc33c28ca99d87a15394e9a0954345c7813805a Mon Sep 17 00:00:00 2001 From: salaboy Date: Fri, 28 Feb 2025 08:31:45 +0000 Subject: [PATCH] waiting for Dapr to be done with init Signed-off-by: salaboy --- .../java/io/dapr/it/testcontainers/DaprContainerIT.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/sdk-tests/src/test/java/io/dapr/it/testcontainers/DaprContainerIT.java b/sdk-tests/src/test/java/io/dapr/it/testcontainers/DaprContainerIT.java index d37680a2d5..8493b6a23e 100644 --- a/sdk-tests/src/test/java/io/dapr/it/testcontainers/DaprContainerIT.java +++ b/sdk-tests/src/test/java/io/dapr/it/testcontainers/DaprContainerIT.java @@ -27,6 +27,7 @@ import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Tag; import org.junit.jupiter.api.Test; +import org.testcontainers.containers.wait.strategy.Wait; import org.testcontainers.junit.jupiter.Container; import org.testcontainers.junit.jupiter.Testcontainers; @@ -59,6 +60,7 @@ public class DaprContainerIT { private static final String KEY = "my-key"; private static final String PUBSUB_NAME = "pubsub"; private static final String PUBSUB_TOPIC_NAME = "topic"; + private static final String DAPR_INIT_RUNNING_MESSAGE_PATTERN = ".*dapr initialized. Status: Running.*"; @Container private static final DaprContainer DAPR_CONTAINER = new DaprContainer("daprio/daprd") @@ -124,8 +126,8 @@ public void testStateStore() throws Exception { @Test public void testPlacement() throws Exception { - // Dapr and Placement need some time to connect - Thread.sleep(1000); + + Wait.forLogMessage(DAPR_INIT_RUNNING_MESSAGE_PATTERN, 1).waitUntilReady(DAPR_CONTAINER); OkHttpClient okHttpClient = new OkHttpClient.Builder() .build();