We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 5ccec17 commit aa2eedcCopy full SHA for aa2eedc
core/testcontainers/core/container.py
@@ -209,7 +209,21 @@ def _create_instance(cls) -> "Reaper":
209
container_port = int(Reaper._container.get_exposed_port(8080))
210
211
Reaper._socket = socket()
212
- Reaper._socket.connect((container_host, container_port))
+
213
+ last_connection_exception: Optional[ConnectionRefusedError] = None
214
+ for _ in range(50):
215
+ try:
216
+ Reaper._socket.connect((container_host, container_port))
217
+ last_connection_exception = None
218
+ break
219
+ except ConnectionRefusedError as e:
220
+ last_connection_exception = e
221
+ from time import sleep
222
223
+ sleep(0.5)
224
+ if last_connection_exception:
225
+ raise last_connection_exception
226
227
Reaper._socket.send(f"label={LABEL_SESSION_ID}={SESSION_ID}\r\n".encode())
228
229
Reaper._instance = Reaper()
0 commit comments