minos.saga.executions.steps.conditional module

class minos.saga.executions.steps.conditional.ConditionalSagaStepExecution(*args, inner=None, **kwargs)

Bases: minos.saga.executions.steps.abc.SagaStepExecution

Conditional Saga Step Execution class.

__init__(*args, inner=None, **kwargs)

definition: ConditionalSagaStep

async execute(context, *args, **kwargs)

Execution the step.

Parameters

• context (minos.saga.context.SagaContext) – The execution context to be used during the execution.

• args – Additional positional arguments.

• kwargs – Additional named arguments.

Return type

minos.saga.context.SagaContext

Returns

The updated context.

static from_definition(step)

Build a SagaStepExecution instance from the SagaStep definition.

Parameters

step (minos.saga.definitions.steps.abc.SagaStep) – The SagaStep definition.

Return type

minos.saga.executions.steps.abc.SagaStepExecution

Returns

A new SagaStepExecution.

classmethod from_raw(raw, **kwargs)

Build a new instance from a raw representation.

Parameters

• raw (typing.Union[dict[str, typing.Any], minos.saga.executions.steps.abc.SagaStepExecution]) – The raw representation of the instance.

• kwargs – Additional named arguments.

Return type

minos.saga.executions.steps.abc.SagaStepExecution

Returns

A SagaStepExecution instance.

inner: Optional[SagaExecution]

property raw: dict[str, typing.Any]

Compute a raw representation of the instance.

Return type

dict[str, typing.Any]

Returns

A dict instance.

async rollback(context, *args, **kwargs)

Revert the executed step.

Parameters

• context (minos.saga.context.SagaContext) – Execution context.

• args – Additional positional arguments.

• kwargs – Additional named arguments.

Return type

minos.saga.context.SagaContext

Returns

The updated execution context.