minos.saga.executions.commit

Classes

TransactionCommitter

Transaction Committer class.

class TransactionCommitter[source]

Bases: object

Transaction Committer class.

__init__(execution_uuid, executed_steps, broker_publisher, broker_pool=None, pool_factory=None, **kwargs)[source]

Parameters

execution_uuid (UUID) –
executed_steps (list[minos.saga.executions.steps.abc.SagaStepExecution]) –
broker_publisher (BrokerPublisher) –
broker_pool (Optional[BrokerClientPool]) –
pool_factory (Optional[PoolFactory]) –

async commit(**kwargs)[source]

Commit the transaction.

Parameters: kwargs – Additional named arguments.
Returns: This method does not return anything.
Return type: None

async reject()[source]

Reject the transaction.

Returns: This method does not return anything.
Return type: None

transactions

Get the list of transactions used during the saga execution.

Returns: A list of tuples in which the first value is the identifier of the transaction and the second one is the name of the microservice in which the saga was executed.