🐛 The backend shall serve requests once the database reachable

backend/backend/db/db.py

@@ -1,10 +1,11 @@
+from asyncio import sleep
 from logging import getLogger
 from typing import Annotated, AsyncIterator
 
 from fastapi import Depends
 from opentelemetry.instrumentation.sqlalchemy import SQLAlchemyInstrumentor
 from sqlalchemy import text
-from sqlalchemy.exc import SQLAlchemyError
+from sqlalchemy.exc import OperationalError, SQLAlchemyError
 from sqlalchemy.ext.asyncio import (
     async_sessionmaker,
     AsyncEngine,
@@ -56,11 +57,20 @@ class Database:
                 class_=AsyncSession,
             )
 
-            async with self._async_engine.begin() as session:
-                await session.execute(text("CREATE EXTENSION IF NOT EXISTS pg_trgm;"))
-                if clear_static_data:
-                    await session.run_sync(Base.metadata.drop_all)
-                    await session.run_sync(Base.metadata.create_all)
+            ret = False
+            while not ret:
+                try:
+                    async with self._async_engine.begin() as session:
+                        await session.execute(
+                            text("CREATE EXTENSION IF NOT EXISTS pg_trgm;")
+                        )
+                        if clear_static_data:
+                            await session.run_sync(Base.metadata.drop_all)
+                            await session.run_sync(Base.metadata.create_all)
+                        ret = True
+                except OperationalError as err:
+                    logger.error(err)
+                    await sleep(1)
 
         return True