From 42e41aded621e73a368c1b57de24e9401bd798ad Mon Sep 17 00:00:00 2001 From: haggqvist <43087043+haggqvist@users.noreply.github.com> Date: Mon, 28 Sep 2026 15:45:47 +0200 Subject: [PATCH] fix(nats): replace deprecated wait_container_is_ready with LogMessageWaitStrategy --- src/testcontainers/community/nats/__init__.py | 10 ++++------ 1 file changed, 4 insertions(+), 6 deletions(-) diff --git a/src/testcontainers/community/nats/__init__.py b/src/testcontainers/community/nats/__init__.py index c0d72a17b..a4673d4a4 100644 --- a/src/testcontainers/community/nats/__init__.py +++ b/src/testcontainers/community/nats/__init__.py @@ -14,7 +14,7 @@ from typing_extensions import Self from testcontainers.core.container import DockerContainer -from testcontainers.core.waiting_utils import wait_container_is_ready, wait_for_logs +from testcontainers.core.wait_strategies import LogMessageWaitStrategy class NatsContainer(DockerContainer): @@ -59,10 +59,9 @@ def __init__( self.with_exposed_ports(self.client_port, self.management_port) if jetstream: self.with_command("-js") - - @wait_container_is_ready() - def _healthcheck(self) -> None: - wait_for_logs(self, self._expected_ready_log, timeout=self._ready_timeout_secs) + self._wait_strategy = LogMessageWaitStrategy(self._expected_ready_log).with_startup_timeout( + self._ready_timeout_secs + ) def nats_uri(self) -> str: return f"nats://{self.get_container_host_ip()}:{self.get_exposed_port(self.client_port)}" @@ -75,5 +74,4 @@ def nats_management_uri(self) -> str: def start(self) -> Self: super().start() - self._healthcheck() return self