Skip to content

Commit 71cb75b

Browse files
jonathandannenbergalexanderankin
andauthoredMar 5, 2024··
fix: rabbitmq readiness probe (#375)
Add pika AMQPConnectionError to transient errors fixes #348 --------- Co-authored-by: David Ankin <daveankin@gmail.com>
1 parent 750e12a commit 71cb75b

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed
 

‎modules/rabbitmq/testcontainers/rabbitmq/__init__.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,7 @@ def __init__(
5151
self.with_env("RABBITMQ_DEFAULT_USER", self.username)
5252
self.with_env("RABBITMQ_DEFAULT_PASS", self.password)
5353

54-
@wait_container_is_ready(pika.exceptions.IncompatibleProtocolError)
54+
@wait_container_is_ready(pika.exceptions.IncompatibleProtocolError, pika.exceptions.AMQPConnectionError)
5555
def readiness_probe(self) -> bool:
5656
"""Test if the RabbitMQ broker is ready."""
5757
connection = pika.BlockingConnection(self.get_connection_params())

0 commit comments

Comments
 (0)
Please sign in to comment.