minos.saga.executions.executors.response module¶
- class minos.saga.executions.executors.response.ResponseExecutor(execution_uuid, *args, **kwargs)[source]¶
Bases:
minos.saga.executions.executors.abc.ExecutorResponse Executor class.
- __init__(execution_uuid, *args, **kwargs)¶
- async exec(operation, context, response, *args, **kwargs)[source]¶
Execute the operation.
- Parameters
operation (
typing.Optional[minos.saga.definitions.operations.SagaOperation[collections.abc.Callable[minos.saga.context.SagaContext,minos.saga.messages.SagaResponse, …,typing.Union[Exception,minos.saga.context.SagaContext,typing.Awaitable[typing.Union[Exception,minos.saga.context.SagaContext]]]]]]) – Operation to be executed.context (
minos.saga.context.SagaContext) – Actual execution context.response (
minos.saga.messages.SagaResponse) – SagaResponse containing the response content.args – Additional positional arguments.
kwargs – Additional named arguments.
- Return type
- Returns
An updated context instance.
- async exec_function(func, *args, **kwargs)¶
Execute a function.
- Parameters
func (
typing.Callable) – Function to be executed.args – Additional positional arguments to the function.
kwargs – Additional named arguments to the function.
- Return type
typing.Any- Returns
The
funcresult.