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

jstastnycz pushed a commit to branch main
in repository 
https://gitbox.apache.org/repos/asf/incubator-kie-kogito-runtimes.git


The following commit(s) were added to refs/heads/main by this push:
     new 3eae2d66db kie-issues#622: explicitly provide startupTimeout in 
waitingFor call
3eae2d66db is described below

commit 3eae2d66dbc31661071bc764f76ba015e89b070c
Author: jstastny-cz <[email protected]>
AuthorDate: Mon Oct 9 10:48:24 2023 +0200

    kie-issues#622: explicitly provide startupTimeout in waitingFor call
---
 .../main/java/org/kie/kogito/testcontainers/KogitoKafkaContainer.java | 2 +-
 .../java/org/kie/kogito/testcontainers/KogitoKeycloakContainer.java   | 2 +-
 .../org/kie/kogito/testcontainers/KogitoRedisSearchContainer.java     | 2 +-
 .../workflow/deployment/devservices/DataIndexInMemoryContainer.java   | 4 +++-
 4 files changed, 6 insertions(+), 4 deletions(-)

diff --git 
a/kogito-test-utils/src/main/java/org/kie/kogito/testcontainers/KogitoKafkaContainer.java
 
b/kogito-test-utils/src/main/java/org/kie/kogito/testcontainers/KogitoKafkaContainer.java
index da5ef0b4e8..6bd3a3dce7 100644
--- 
a/kogito-test-utils/src/main/java/org/kie/kogito/testcontainers/KogitoKafkaContainer.java
+++ 
b/kogito-test-utils/src/main/java/org/kie/kogito/testcontainers/KogitoKafkaContainer.java
@@ -47,7 +47,7 @@ public class KogitoKafkaContainer extends 
KogitoGenericContainer<KogitoKafkaCont
         withExposedPorts(KAFKA_PORT);
         withCreateContainerCmdModifier(cmd -> cmd.withEntrypoint("sh"));
         withCommand("-c", "while [ ! -f " + STARTER_SCRIPT + " ]; do sleep 
0.1; done; " + STARTER_SCRIPT);
-        waitingFor(Wait.forLogMessage(".*Started Kafka API server.*", 1));
+        waitingFor(Wait.forLogMessage(".*Started Kafka API server.*", 
1).withStartupTimeout(Constants.CONTAINER_START_TIMEOUT));
     }
 
     @Override
diff --git 
a/kogito-test-utils/src/main/java/org/kie/kogito/testcontainers/KogitoKeycloakContainer.java
 
b/kogito-test-utils/src/main/java/org/kie/kogito/testcontainers/KogitoKeycloakContainer.java
index 811ec8eeb0..3cd8f46fa4 100644
--- 
a/kogito-test-utils/src/main/java/org/kie/kogito/testcontainers/KogitoKeycloakContainer.java
+++ 
b/kogito-test-utils/src/main/java/org/kie/kogito/testcontainers/KogitoKeycloakContainer.java
@@ -43,7 +43,7 @@ public class KogitoKeycloakContainer extends 
KogitoGenericContainer<KogitoKeyclo
         withEnv("KEYCLOAK_ADMIN", USER);
         withEnv("KEYCLOAK_ADMIN_PASSWORD", PASSWORD);
         
withClasspathResourceMapping("testcontainers/keycloak/kogito-realm.json", 
REALM_FILE, BindMode.READ_ONLY);
-        waitingFor(Wait.forLogMessage(".*Keycloak.*started.*", 1));
+        waitingFor(Wait.forLogMessage(".*Keycloak.*started.*", 
1).withStartupTimeout(Constants.CONTAINER_START_TIMEOUT));
         withCommand("start-dev --import-realm");
     }
 
diff --git 
a/kogito-test-utils/src/main/java/org/kie/kogito/testcontainers/KogitoRedisSearchContainer.java
 
b/kogito-test-utils/src/main/java/org/kie/kogito/testcontainers/KogitoRedisSearchContainer.java
index f4adf9377a..39433a57e6 100644
--- 
a/kogito-test-utils/src/main/java/org/kie/kogito/testcontainers/KogitoRedisSearchContainer.java
+++ 
b/kogito-test-utils/src/main/java/org/kie/kogito/testcontainers/KogitoRedisSearchContainer.java
@@ -29,7 +29,7 @@ public class KogitoRedisSearchContainer extends 
KogitoGenericContainer<KogitoRed
     public KogitoRedisSearchContainer() {
         super(NAME);
         addExposedPort(PORT);
-        waitingFor(Wait.forLogMessage(".*Ready to accept connections.*\\s", 
1));
+        waitingFor(Wait.forLogMessage(".*Ready to accept connections.*\\s", 
1).withStartupTimeout(Constants.CONTAINER_START_TIMEOUT));
     }
 
     @Override
diff --git 
a/quarkus/extensions/kogito-quarkus-workflow-extension-common/kogito-quarkus-workflow-common-deployment/src/main/java/org/kie/kogito/quarkus/workflow/deployment/devservices/DataIndexInMemoryContainer.java
 
b/quarkus/extensions/kogito-quarkus-workflow-extension-common/kogito-quarkus-workflow-common-deployment/src/main/java/org/kie/kogito/quarkus/workflow/deployment/devservices/DataIndexInMemoryContainer.java
index f1beaf4c98..ee5a1593ca 100644
--- 
a/quarkus/extensions/kogito-quarkus-workflow-extension-common/kogito-quarkus-workflow-common-deployment/src/main/java/org/kie/kogito/quarkus/workflow/deployment/devservices/DataIndexInMemoryContainer.java
+++ 
b/quarkus/extensions/kogito-quarkus-workflow-extension-common/kogito-quarkus-workflow-common-deployment/src/main/java/org/kie/kogito/quarkus/workflow/deployment/devservices/DataIndexInMemoryContainer.java
@@ -18,6 +18,8 @@
  */
 package org.kie.kogito.quarkus.workflow.deployment.devservices;
 
+import java.time.Duration;
+
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.testcontainers.containers.GenericContainer;
@@ -60,7 +62,7 @@ public class DataIndexInMemoryContainer extends 
GenericContainer<DataIndexInMemo
         withEnv("KOGITO_DATA_INDEX_VERTX_GRAPHQL_UI_PATH", "/q/graphql-ui");
         withEnv("KOGITO_DATA_INDEX_QUARKUS_PROFILE", "http-events-support");
         withExposedPorts(PORT);
-        waitingFor(Wait.forHttp("/q/health/ready").forStatusCode(200));
+        
waitingFor(Wait.forHttp("/q/health/ready").forStatusCode(200).withStartupTimeout(Duration.ofMinutes(5)));
     }
 
     @Override


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to