(iggy) branch master updated: fix(test): Fix Iceberg container readiness check to use HTTP health check (#3077)

[maciej]

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

maciej pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iggy.git


The following commit(s) were added to refs/heads/master by this push:
     new 55117986e fix(test): Fix Iceberg container readiness check to use HTTP 
health check (#3077)
55117986e is described below

commit 55117986ef54c72833dec8b33f4509d042b6284b
Author: Krishna Vishal <krishnavishal2...@gmail.com>
AuthorDate: Mon Apr 6 11:53:58 2026 +0530

    fix(test): Fix Iceberg container readiness check to use HTTP health check 
(#3077)
    
    Closes #3076
---
 Cargo.lock                                                      | 4 ++++
 Cargo.toml                                                      | 2 +-
 core/integration/tests/connectors/fixtures/iceberg/container.rs | 7 ++++++-
 3 files changed, 11 insertions(+), 2 deletions(-)

diff --git a/Cargo.lock b/Cargo.lock
index 5189fca38..0b17b8860 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -9096,8 +9096,10 @@ checksum = 
"ab3f43e3283ab1488b624b44b0e988d0acea0b3214e694730a055cb6b2efa801"
 dependencies = [
  "base64 0.22.1",
  "bytes",
+ "encoding_rs",
  "futures-core",
  "futures-util",
+ "h2 0.4.13",
  "http 1.4.0",
  "http-body",
  "http-body-util",
@@ -9106,6 +9108,7 @@ dependencies = [
  "hyper-util",
  "js-sys",
  "log",
+ "mime",
  "percent-encoding",
  "pin-project-lite",
  "quinn",
@@ -11079,6 +11082,7 @@ dependencies = [
  "memchr",
  "parse-display",
  "pin-project-lite",
+ "reqwest 0.13.2",
  "serde",
  "serde_json",
  "serde_with",
diff --git a/Cargo.toml b/Cargo.toml
index 1d5ee62c3..48db24aa4 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -273,7 +273,7 @@ syn = { version = "2", features = ["full", "extra-traits"] }
 sysinfo = "0.38.4"
 tempfile = "3.27.0"
 test-case = "3.3.1"
-testcontainers-modules = { version = "0.15.0", features = ["postgres"] }
+testcontainers-modules = { version = "0.15.0", features = ["postgres", 
"http_wait"] }
 thiserror = "2.0.18"
 tokio = { version = "1.51.0", features = ["full"] }
 tokio-rustls = "0.26.4"
diff --git a/core/integration/tests/connectors/fixtures/iceberg/container.rs 
b/core/integration/tests/connectors/fixtures/iceberg/container.rs
index fd1c55fd5..e0fb27215 100644
--- a/core/integration/tests/connectors/fixtures/iceberg/container.rs
+++ b/core/integration/tests/connectors/fixtures/iceberg/container.rs
@@ -23,6 +23,7 @@ use reqwest_middleware::ClientWithMiddleware as HttpClient;
 use reqwest_retry::RetryTransientMiddleware;
 use reqwest_retry::policies::ExponentialBackoff;
 use std::collections::HashMap;
+use testcontainers_modules::testcontainers::core::wait::HttpWaitStrategy;
 use testcontainers_modules::testcontainers::core::{IntoContainerPort, WaitFor};
 use testcontainers_modules::testcontainers::runners::AsyncRunner;
 use testcontainers_modules::testcontainers::{ContainerAsync, GenericImage, 
ImageExt};
@@ -120,7 +121,11 @@ impl IcebergRestContainer {
 
         let container = GenericImage::new(ICEBERG_REST_IMAGE, ICEBERG_REST_TAG)
             .with_exposed_port(ICEBERG_REST_PORT.tcp())
-            .with_wait_for(WaitFor::message_on_stderr("Started Server@"))
+            .with_wait_for(WaitFor::http(
+                HttpWaitStrategy::new("/v1/config")
+                    .with_port(ICEBERG_REST_PORT.tcp())
+                    .with_expected_status_code(200u16),
+            ))
             .with_startup_timeout(std::time::Duration::from_secs(30))
             .with_network(network)
             .with_env_var(