(camel) branch main updated: CAMEL-24786 - stabilize Milvus IT test by awaiting proxy marked as started in container log

[apupier]

This is an automated email from the ASF dual-hosted git repository.

apupier pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/main by this push:
     new bfee8e570b19 CAMEL-24786 - stabilize Milvus IT test by awaiting proxy 
marked as started in container log
bfee8e570b19 is described below

commit bfee8e570b191289250c1d359751c6f4c9ac77b1
Author: Aurélien Pupier <apup...@ibm.com>
AuthorDate: Wed Sep 2 14:56:46 2026 +0200

    CAMEL-24786 - stabilize Milvus IT test by awaiting proxy marked as
    started in container log
    
    it was causing this sporadic error:
    ```
    Failed to initialize connection. Error: UNKNOWN: service unavailable:
    internal: Milvus Proxy is not ready yet. please wait
    ```
    
    this error is occurring very often when using the 2.6.5 image version of
    Milvus. For ppc64le, this is the version used (there isn't a more recent
    yet)
    
    Co-authored-by: IBM Bob 2.0.3
    Signed-off-by: Aurélien Pupier <apup...@ibm.com>
---
 .../test/infra/milvus/services/MilvusLocalContainerInfraService.java | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/test-infra/camel-test-infra-milvus/src/main/java/org/apache/camel/test/infra/milvus/services/MilvusLocalContainerInfraService.java
 
b/test-infra/camel-test-infra-milvus/src/main/java/org/apache/camel/test/infra/milvus/services/MilvusLocalContainerInfraService.java
index d28a364629b2..37e9e79961e7 100644
--- 
a/test-infra/camel-test-infra-milvus/src/main/java/org/apache/camel/test/infra/milvus/services/MilvusLocalContainerInfraService.java
+++ 
b/test-infra/camel-test-infra-milvus/src/main/java/org/apache/camel/test/infra/milvus/services/MilvusLocalContainerInfraService.java
@@ -28,6 +28,7 @@ import 
org.apache.camel.test.infra.common.services.ContainerService;
 import org.apache.camel.test.infra.milvus.common.MilvusProperties;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.testcontainers.containers.wait.strategy.Wait;
 import org.testcontainers.milvus.MilvusContainer;
 import org.testcontainers.utility.DockerImageName;
 
@@ -60,12 +61,14 @@ public class MilvusLocalContainerInfraService implements 
MilvusInfraService, Con
         class TestInfraMilvusContainer extends MilvusContainer {
             public TestInfraMilvusContainer(boolean fixedPort) {
                 
super(DockerImageName.parse(imageName).asCompatibleSubstituteFor("milvusdb/milvus"));
-                withStartupTimeout(Duration.ofMinutes(3L));
+                waitingFor(Wait.forLogMessage(".*Milvus Proxy successfully 
initialized and ready to serve!.*", 1))
+                        .withStartupTimeout(Duration.ofMinutes(3L));
                 withEnv("DEPLOY_MODE", "STANDALONE");
 
                 ContainerEnvironmentUtil.configurePorts(this, fixedPort,
                         ContainerEnvironmentUtil.PortConfig.primary(19530),
                         ContainerEnvironmentUtil.PortConfig.secondary(9091));
+                ;
             }
         }