Skip to content

aria2_server.db

DATABASE_URL module-attribute

DATABASE_URL = _sqlite_url_prefix + as_posix()

async_session_maker module-attribute

async_session_maker = async_sessionmaker(
    engine, expire_on_commit=False
)

engine module-attribute

engine = create_async_engine(
    DATABASE_URL, connect_args={"check_same_thread": False}
)

__all__ module-attribute

__all__ = (
    "DATABASE_URL",
    "async_session_maker",
    "engine",
    "get_async_session",
)

get_async_session async

get_async_session() -> AsyncGenerator[AsyncSession, None]
Source code in src/aria2_server/db/_core.py
async def get_async_session() -> AsyncGenerator[AsyncSession, None]:
    async with async_session_maker() as session:
        yield session