temporalio.worker._nexus

module documentation
(source)

Nexus worker

Class _ContextPropagatingExecutor Undocumented
Class _NexusMiddlewareForInterceptors Undocumented
Class _NexusOperationHandlerForInterceptor Undocumented
Class _NexusOperationInboundInterceptorImpl Undocumented
Class _NexusPayloadSerializer Undocumented
Class _NexusTaskCancellation Undocumented
Class _NexusWorker No class docstring; 0/10 instance variable, 5/10 methods documented
Class _PayloadTransformVisitor Adapts a payload-sequence transform for use with PayloadVisitor.
Class _RunningNexusTask Undocumented
Function _exception_to_handler_error Undocumented
Function _is_payload_validation_error Whether err is a non-retryable ApplicationError whose type is exactly _PAYLOAD_VALIDATION_ERROR_TYPE.
Constant _P Undocumented
Constant _PAYLOAD_VALIDATION_ERROR_TYPE temporalio.exceptions.ApplicationError.type a data converter uses to say that it understood a Nexus operation's input but considers it invalid.
Constant _TEMPORAL_FAILURE_PROTO_TYPE Undocumented
Type Variable _T Undocumented
def _exception_to_handler_error(err: BaseException) -> nexusrpc.HandlerError: (source)

Undocumented

def _is_payload_validation_error(err: BaseException) -> TypeGuard[ApplicationError]: (source)

Whether err is a non-retryable ApplicationError whose type is exactly _PAYLOAD_VALIDATION_ERROR_TYPE.

_P = (source)

Undocumented

Value
ParamSpec('_P')
_PAYLOAD_VALIDATION_ERROR_TYPE: str = (source)

temporalio.exceptions.ApplicationError.type a data converter uses to say that it understood a Nexus operation's input but considers it invalid.

When non-retryable, such an error is reported as a nexusrpc.HandlerErrorType.BAD_REQUEST handler error rather than as a handler-side nexusrpc.HandlerErrorType.INTERNAL error.

Value
'PayloadValidationError'
_TEMPORAL_FAILURE_PROTO_TYPE: str = (source)

Undocumented

Value
'temporal.api.failure.v1.Failure'
_T = (source)

Undocumented

Value
TypeVar('_T')