minos.saga.executions.steps.remote

Classes

RemoteSagaStepExecution

Saga Execution Step class.

class RemoteSagaStepExecution

Bases: SagaStepExecution

Saga Execution Step class.

definition: minos.saga.definitions.steps.remote.RemoteSagaStep

async execute(context, response=None, *args, **kwargs)

Execution the remote step.

Parameters

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

• response (Optional[SagaResponse]) – An optional command response instance (to be consumed by the on_success method).

• args – Additional positional arguments.

• kwargs – Additional named arguments.

Returns

The updated context.

Return type

SagaContext

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

Revert the executed remote step.

Parameters

• context (SagaContext) – Execution context.

• args – Additional positional arguments.

• kwargs – Additional named arguments.

Returns

The updated execution context.

Return type

SagaContext

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

Parameters

• definition (SagaStep) –

• related_services (Optional[set[str]]) –

• status (SagaStepStatus) –

• already_rollback (bool) –

static from_definition(step)

Build a SagaStepExecution instance from the SagaStep definition.

Parameters

step (SagaStep) – The SagaStep definition.

Returns

A new SagaStepExecution.

Return type

SagaStepExecution

classmethod from_raw(raw, **kwargs)

Build a new instance from a raw representation.

Parameters

• raw (Union[dict[str, Any], SagaStepExecution]) – The raw representation of the instance.

• kwargs – Additional named arguments.

Returns

A SagaStepExecution instance.

Return type

SagaStepExecution

property raw: dict[str, Any]

Compute a raw representation of the instance.

Returns

A dict instance.