temporalio.nexus.system.workflow_service._support.nex_gen_support

module documentation
(source)

Undocumented

Function duration_from_proto Undocumented
Function duration_to_proto Undocumented
Function memo_from_proto Undocumented
Function memo_to_proto Undocumented
Function payload_from_proto Undocumented
Function payload_to_proto Undocumented
Function payloads_to_proto Undocumented
Function priority_from_proto Undocumented
Function priority_to_proto Undocumented
Function retry_policy_from_proto Undocumented
Function retry_policy_to_proto Undocumented
Function search_attributes_to_proto Undocumented
Function signal_function_to_proto Undocumented
Function task_queue_from_proto Undocumented
Function task_queue_to_proto Undocumented
Function versioning_override_to_proto Undocumented
Function workflow_function_name Undocumented
Function workflow_id_conflict_policy_from_proto Undocumented
Function workflow_id_conflict_policy_to_proto Undocumented
Function workflow_id_reuse_policy_from_proto Undocumented
Function workflow_id_reuse_policy_to_proto Undocumented
Function workflow_namespace Undocumented
Function workflow_type_to_proto Undocumented
Function _clone_payload Undocumented
Function _payload_to_value Undocumented
Function _value_to_payload Undocumented
def duration_from_proto(proto: google.protobuf.duration_pb2.Duration) -> timedelta: (source)

Undocumented

def duration_to_proto(duration: timedelta) -> google.protobuf.duration_pb2.Duration: (source)

Undocumented

def memo_from_proto(proto: common_pb2.Memo) -> collections.abc.Mapping[str, object]: (source)

Undocumented

def memo_to_proto(memo: collections.abc.Mapping[str, object]) -> common_pb2.Memo: (source)

Undocumented

def payload_from_proto(proto: common_pb2.Payload) -> object: (source)

Undocumented

def payload_to_proto(payload: object) -> common_pb2.Payload: (source)

Undocumented

def payloads_to_proto(values: collections.abc.Sequence[typing.Any]) -> common_pb2.Payloads: (source)

Undocumented

def priority_from_proto(proto: common_pb2.Priority) -> temporalio.common.Priority: (source)

Undocumented

def priority_to_proto(priority: temporalio.common.Priority) -> common_pb2.Priority: (source)

Undocumented

def retry_policy_from_proto(proto: common_pb2.RetryPolicy) -> temporalio.common.RetryPolicy: (source)

Undocumented

def retry_policy_to_proto(retry_policy: temporalio.common.RetryPolicy) -> common_pb2.RetryPolicy: (source)

Undocumented

def search_attributes_to_proto(search_attributes: temporalio.common.TypedSearchAttributes) -> common_pb2.SearchAttributes: (source)

Undocumented

def signal_function_to_proto(value: str | collections.abc.Callable[..., typing.Any]) -> str: (source)

Undocumented

def task_queue_from_proto(proto: taskqueue_pb2.TaskQueue) -> str: (source)

Undocumented

def task_queue_to_proto(task_queue: str) -> taskqueue_pb2.TaskQueue: (source)

Undocumented

def versioning_override_to_proto(versioning_override: temporalio.common.VersioningOverride) -> temporalio.api.workflow.v1.VersioningOverride: (source)

Undocumented

def workflow_function_name(value: str | collections.abc.Callable[..., collections.abc.Awaitable[object]]) -> str: (source)

Undocumented

def workflow_id_conflict_policy_from_proto(policy: workflow_enums_pb2.WorkflowIdConflictPolicy.ValueType) -> temporalio.common.WorkflowIDConflictPolicy: (source)

Undocumented

def workflow_id_conflict_policy_to_proto(policy: temporalio.common.WorkflowIDConflictPolicy) -> workflow_enums_pb2.WorkflowIdConflictPolicy.ValueType: (source)

Undocumented

def workflow_id_reuse_policy_from_proto(policy: workflow_enums_pb2.WorkflowIdReusePolicy.ValueType) -> temporalio.common.WorkflowIDReusePolicy: (source)

Undocumented

def workflow_id_reuse_policy_to_proto(policy: temporalio.common.WorkflowIDReusePolicy) -> workflow_enums_pb2.WorkflowIdReusePolicy.ValueType: (source)

Undocumented

def workflow_namespace() -> str: (source)

Undocumented

def workflow_type_to_proto(workflow_type: str | collections.abc.Callable[..., collections.abc.Awaitable[object]]) -> common_pb2.WorkflowType: (source)

Undocumented

def _clone_payload(payload: common_pb2.Payload) -> common_pb2.Payload: (source)

Undocumented

def _payload_to_value(payload: common_pb2.Payload) -> object: (source)

Undocumented

def _value_to_payload(value: object | common_pb2.Payload) -> common_pb2.Payload: (source)

Undocumented