unit_of_work¶

class mersal_sqlalchemy.sqlalchemy_unit_of_work.SQLAlchemyUnitOfWork[source]¶

Bases: object

A unit of work class for SQLAlchemy.

__init__(async_session_maker: async_sessionmaker[AsyncSession]) → None[source]¶

Initializes SQLAlchemyUnitOfWork.

Parameters:: async_session_maker¶ – session factory.

async mersal_sqlalchemy.sqlalchemy_unit_of_work.default_sqlalchemy_close_action(_: MessageContext, uow: SQLAlchemyUnitOfWork) → None[source]¶: Helper function for SQLAalchemyUnitOfWork close

async mersal_sqlalchemy.sqlalchemy_unit_of_work.default_sqlalchemy_commit_action(_: MessageContext, uow: SQLAlchemyUnitOfWork) → None[source]¶: Helper function for SQLAalchemyUnitOfWork commit

async mersal_sqlalchemy.sqlalchemy_unit_of_work.default_sqlalchemy_rollback_action(_: MessageContext, uow: SQLAlchemyUnitOfWork) → None[source]¶: Helper function for SQLAalchemyUnitOfWork rollback