minos.saga.executions.executors.request

Classes

RequestExecutor

Request Executor class.

class RequestExecutor

Bases: Executor

Request Executor class.

This class has the responsibility to publish command on the corresponding broker’s queue.

__init__(*args, user, broker_publisher, **kwargs)

Parameters

• user (Optional[UUID]) –

• broker_publisher (BrokerPublisher) –

async exec(operation, context)

Exec method, that perform the publishing logic run an pre-callback function to generate the command contents.

Parameters

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

• context (SagaContext) – Execution context.

Returns

A saga context instance.

Return type

SagaContext

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