from typing import AsyncGenerator

from src.integrations.db import DBClient


# Dependency
async def get_connection() -> AsyncGenerator:
    database = await DBClient.get_db()
    async with database.connection() as connection:
        yield connection

2f2a1d22a1348e621f7238ce1c1647a809cebcea
<mask token>

<mask token>


async def get_connection() ->AsyncGenerator:
    database = await DBClient.get_db()
    async with database.connection() as connection:
        yield connection

from typing import AsyncGenerator
from src.integrations.db import DBClient


async def get_connection() ->AsyncGenerator:
    database = await DBClient.get_db()
    async with database.connection() as connection:
        yield connection

from typing import AsyncGenerator

from src.integrations.db import DBClient


# Dependency
async def get_connection() -> AsyncGenerator:
    database = await DBClient.get_db()
    async with database.connection() as connection:
        yield connection
