temporalio.nexus.system

package documentation
(source)

System Nexus operation helpers.

Warning

This API is experimental and subject to change.

Package workflow_service No package docstring; 0/1 variable, 1/1 function, 0/2 module, 0/3 package documented
Module _payload_visitor No module docstring; 1/1 class documented

From __init__.py:

Function is_system_endpoint Return whether a Nexus endpoint is the Temporal system endpoint.
Constant TEMPORAL_SYSTEM_ENDPOINT Undocumented
Class _SystemNexusOuterPayloadConverter Payload converter for system Nexus outer proto envelopes.
Class _SystemNexusPayloadConverter Payload converter for system Nexus outer envelopes.
Function _current_user_payload_converter Return the active user payload converter for system Nexus model conversion.
Function _get_payload_converter Return the fixed payload converter for system Nexus outer envelopes.
Async Function _maybe_visit_payload Visit nested payloads if the payload is for the Temporal system endpoint.
Function _user_payload_converter_context Set the user payload converter for system Nexus model conversion.
Variable _user_payload_converter Undocumented
def is_system_endpoint(endpoint: str) -> bool: (source)

Return whether a Nexus endpoint is the Temporal system endpoint.

Warning

This API is experimental and subject to change.

TEMPORAL_SYSTEM_ENDPOINT: str = (source)

Undocumented

Value
'__temporal_system'
def _current_user_payload_converter() -> temporalio.converter.PayloadConverter: (source)

Return the active user payload converter for system Nexus model conversion.

def _get_payload_converter(user_payload_converter: temporalio.converter.PayloadConverter) -> temporalio.converter.PayloadConverter: (source)

Return the fixed payload converter for system Nexus outer envelopes.

async def _maybe_visit_payload(endpoint: str, payload: temporalio.api.common.v1.Payload, visitor_functions: VisitorFunctions, skip_search_attributes: bool) -> temporalio.api.common.v1.Payload | None: (source)

Visit nested payloads if the payload is for the Temporal system endpoint.

def _user_payload_converter_context(payload_converter: temporalio.converter.PayloadConverter) -> Iterator[None]: (source)

Set the user payload converter for system Nexus model conversion.

_user_payload_converter: contextvars.ContextVar[temporalio.converter.PayloadConverter | None] = (source)

Undocumented