adding check to see that API is responsive

Author: Andrei Neagu

packages/service-library/src/servicelib/docker_utils.py

@@ -9,6 +9,7 @@
 import aiodocker
 import aiohttp
 import arrow
+import tenacity
 from aiohttp import ClientSession
 from fastapi import FastAPI
 from models_library.docker import DockerGenericTag
@@ -332,11 +333,23 @@ async def _(app: FastAPI) -> AsyncIterator[None]:
 
             app.state.remote_docker_client = client
 
+            await wait_till_docker_api_proxy_is_responsive(app)
+
             yield
 
     return _
 
 
+@tenacity.retry(
+    wait=tenacity.wait_fixed(5),
+    stop=tenacity.stop_after_delay(60),
+    before_sleep=tenacity.before_sleep_log(_logger, logging.INFO),
+    reraise=True,
+)
+async def wait_till_docker_api_proxy_is_responsive(app: FastAPI) -> None:
+    await get_remote_docker_client(app).version()
+
+
 def get_remote_docker_client(app: FastAPI) -> aiodocker.Docker:
     assert isinstance(app.state.remote_docker_client, aiodocker.Docker)  # nosec
     return app.state.remote_docker_client

services/docker-api-proxy/tests/integration/conftest.py

@@ -59,7 +59,7 @@ async def _(env_vars: EnvVarsDict) -> AsyncIterator[aiodocker.Docker]:
 
         app = _get_test_app()
 
-        async with LifespanManager(app):
+        async with LifespanManager(app, startup_timeout=30, shutdown_timeout=30):
             yield get_remote_docker_client(app)
 
     return _

services/docker-api-proxy/tests/integration/test_docker_api_proxy_autenticated.py

@@ -10,6 +10,7 @@
 
 import aiodocker
 import pytest
+from pytest_mock import MockerFixture
 from pytest_simcore.helpers.monkeypatch_envs import EnvVarsDict
 from settings_library.docker_api_proxy import DockerApiProxysettings
 from tenacity import AsyncRetrying, stop_after_delay, wait_fixed
@@ -45,8 +46,14 @@ def caddy_file() -> str:
     """
 
 
+@pytest.fixture
+def mock_wait_till_docker_api_proxy_is_responsive(mocker: MockerFixture) -> None:
+    mocker.patch("servicelib.docker_utils.wait_till_docker_api_proxy_is_responsive")
+
+
 @pytest.fixture
 def authentication_proxy(
+    mock_wait_till_docker_api_proxy_is_responsive: None,
     docker_swarm: None,
     docker_api_proxy_settings: DockerApiProxysettings,
     caddy_file: str,