unit_of_work

class mersal_alchemy.sqlalchemy_unit_of_work.SQLAlchemyUnitOfWork

Bases: object

A unit of work class for SQLAlchemy.

__init__(async_session_maker: async_sessionmaker[AsyncSession]) → None

Initializes SQLAlchemyUnitOfWork.

Parameters:

async_session_maker – session factory.

async mersal_alchemy.sqlalchemy_unit_of_work.default_sqlalchemy_close_action(_: MessageContext, uow: SQLAlchemyUnitOfWork) → None

Helper function for SQLAalchemyUnitOfWork close

async mersal_alchemy.sqlalchemy_unit_of_work.default_sqlalchemy_commit_action(_: MessageContext, uow: SQLAlchemyUnitOfWork) → None

Helper function for SQLAalchemyUnitOfWork commit

async mersal_alchemy.sqlalchemy_unit_of_work.default_sqlalchemy_rollback_action(_: MessageContext, uow: SQLAlchemyUnitOfWork) → None

Helper function for SQLAalchemyUnitOfWork rollback