minos.saga.executions.steps.local module¶

class minos.saga.executions.steps.local.LocalSagaStepExecution(definition, related_services=None, status=SagaStepStatus.Created, already_rollback=False)[source]¶

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

Local Saga Step Execution class.

__init__(definition, related_services=None, status=SagaStepStatus.Created, already_rollback=False)¶

definition: minos.saga.definitions.steps.local.LocalSagaStep¶

async execute(context, *args, **kwargs)[source]¶

Execute the local saga step.

Parameters

context (minos.saga.context.SagaContext) – The execution context.
args – Additional positional arguments.
kwargs – Additional named arguments.

Return type

minos.saga.context.SagaContext

Returns

The new saga 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.

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)[source]¶

Rollback the local saga context.

Parameters

context (minos.saga.context.SagaContext) – The execution context.
args – Additional positional arguments.
kwargs – Additional named arguments.

Return type

minos.saga.context.SagaContext

Returns

The new saga context.