minos.saga.executions.executors.local

Classes

LocalExecutor

Local Executor class.

class LocalExecutor

Bases: Executor

Local Executor class.

async exec(operation, context, *args, **kwargs)

Execute the commit operation.

Parameters

• operation (Optional[SagaOperation[Callable[[SagaContext, ...], Union[SagaContext, None, Awaitable[Optional[SagaContext]]]]]]) – Operation to be executed.

• context (SagaContext) – Actual execution context.

• args – Additional positional arguments.

• kwargs – Additional named arguments.

Returns

An updated context instance.

Return type

SagaContext

__init__(execution_uuid, *args, **kwargs)

Parameters

execution_uuid (UUID) –

async exec_function(func, *args, **kwargs)

Execute a function.

Parameters

• func (Callable) – Function to be executed.

• args – Additional positional arguments to the function.

• kwargs – Additional named arguments to the function.

Returns

The func result.

Return type

Any