Асинхронное подключение к базе данных как зависимость маршрутизатора FastAPI

Я пытаюсь инициализировать ConnectionPool, используя asyncpg, а затем использую этот пул для создания соединения каждый раз, когда мне нужно прочитать что-то из моей БД. Все работало нормально, пока я не переместил конечные точки SQL на APIRouter. Я немного растерялся, так как не смог найти документов для этого конкретного случая.

Чтобы создать соединение, я использую жизненный цикл приложения main.py:

@asynccontextmanager
async def lifespan(app: FastAPI):
   app.state.db_pool = await create_async_pool()
   yield
   await app.state.db_pool.close()

Затем я объявляю две зависимости в main.py:

async def get_database():
   yield app.state.db_pool

async def get_db_connection(pool: asyncpg.pool.Pool = Depends(get_database)):
   async with pool.acquire() as connection:
      yield connection

До сих пор все работает отлично, и я могу использовать свою базу данных на конечных точках своего приложения, написанных на main.py. Теперь я хочу перенести эти конечные точки на новый маршрутизатор API в файле с именем analytics.py. Импорт этих зависимостей непосредственно из моего analytics.py возвращает ошибки циклического импорта, но я совершенно не могу передать последнюю зависимость в свой новый маршрутизатор Analytics. Мое дерево файлов сейчас выглядит так:

.
├── app
│   ├── __init__.py
│   ├── main.py
│   └── analytics
│       ├── __init__.py
│       └── analytics.py

Есть идеи, как я могу это исправить? Определенно должно быть что-то, чего мне не хватает

Мои полные файлы выглядят так: main.py:

from fastapi import FastAPI

@asynccontextmanager
async def lifespan(app: FastAPI):
   app.state.db_pool = await create_async_pool()
   yield
   await app.state.db_pool.close()

app = FastAPI(lifespan=lifespan)

app.include_router(analytics.router)

async def get_database():
   yield app.state.db_pool

async def get_db_connection(pool: asyncpg.pool.Pool = Depends(get_database)):
   async with pool.acquire() as connection:
      yield connection

@app.get("/"):
async def hello():
   return {"message": "Hello world!"}

analytics.py:

from fastapi import APIRouter
from app.main import get_db_connection

router = APIRouter(
    prefix = "/analytics"
)

@router.post("/test")
async def test_analytics(input_data, db = Depends(get_db_connection)):
    return "OK"

Ошибка в этой конфигурации:

Import Error: cannot import name 'get_db_connection' from partially initialized module 'app.main' (most likely due to a circular import)