minos.saga.executions.executors.response

Classes

ResponseExecutor

Response Executor class.

class ResponseExecutor

Bases: Executor

Response Executor class.

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

Execute the operation.

Parameters

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

• context (SagaContext) – Actual execution context.

• response (SagaResponse) – SagaResponse containing the response content.

• 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