renamed

Author: sanderegg

packages/simcore-sdk/src/simcore_sdk/node_ports_common/dbmanager.py

@@ -5,7 +5,7 @@
 from models_library.projects import ProjectID
 from models_library.users import UserID
 from pydantic import TypeAdapter
-from servicelib.db_asyncpg_utils import create_async_engine_and_pg_database_ready
+from servicelib.db_asyncpg_utils import create_async_engine_and_database_ready
 from settings_library.node_ports import NodePortsSettings
 from simcore_postgres_database.models.comp_tasks import comp_tasks
 from simcore_postgres_database.models.projects import projects
@@ -55,7 +55,7 @@ def __init__(self, db_engine: AsyncEngine | None = None) -> None:
     @staticmethod
     async def _create_db_engine() -> AsyncEngine:
         settings = NodePortsSettings.create_from_envs()
-        engine = await create_async_engine_and_pg_database_ready(
+        engine = await create_async_engine_and_database_ready(
             settings.POSTGRES_SETTINGS
         )
         assert isinstance(engine, AsyncEngine)  # nosec

services/api-server/src/simcore_service_api_server/db/events.py

@@ -3,7 +3,7 @@
 
 from aiopg.sa import Engine, create_engine
 from fastapi import FastAPI
-from servicelib.db_asyncpg_utils import create_async_engine_and_pg_database_ready
+from servicelib.db_asyncpg_utils import create_async_engine_and_database_ready
 from servicelib.logging_utils import log_context
 from servicelib.retry_policies import PostgresRetryPolicyUponInitialization
 from settings_library.postgres import PostgresSettings
@@ -66,7 +66,7 @@ async def asyncpg_connect_to_db(app: FastAPI, settings: PostgresSettings) -> Non
         logging.DEBUG,
         f"Connecting and migraging {settings.dsn_with_async_sqlalchemy}",
     ):
-        engine = await create_async_engine_and_pg_database_ready(settings)
+        engine = await create_async_engine_and_database_ready(settings)
 
     app.state.asyncpg_engine = engine
     logger.debug(