temporalio.bridge.worker

module documentation
(source)

Worker using SDK Core. (unstable)

Nothing in this module should be considered stable. The API may change.

Class Worker SDK Core worker.
Class WorkerConfig Python representation of the Rust struct for configuring a worker.
Async Function decode_activation Decode the given activation with the codec.
Async Function encode_completion Recursively encode the given completion with the codec.
Type Alias PayloadContainer Undocumented
Async Function _apply_to_payload Apply API payload callback to payload.
Async Function _apply_to_payloads Apply API payload callback to payloads.
Async Function _decode_payload Decode a payload with the given codec.
Async Function _decode_payloads Decode payloads with the given codec.
Async Function _encode_payload Decode a payload with the given codec.
Async Function _encode_payloads Encode payloads with the given codec.
async def decode_activation(act: temporalio.bridge.proto.workflow_activation.WorkflowActivation, codec: temporalio.converter.PayloadCodec): (source)

Decode the given activation with the codec.

async def encode_completion(comp: temporalio.bridge.proto.workflow_completion.WorkflowActivationCompletion, codec: temporalio.converter.PayloadCodec): (source)

Recursively encode the given completion with the codec.

PayloadContainer: TypeAlias = (source)

Undocumented

Value
google.protobuf.internal.containers.RepeatedCompositeFieldContainer[temporalio.api.common.v1.Payload↵
]
async def _apply_to_payload(payload: temporalio.api.common.v1.Payload, cb: Callable[[Sequence[temporalio.api.common.v1.Payload]], Awaitable[List[temporalio.api.common.v1.Payload]]]): (source)

Apply API payload callback to payload.

async def _apply_to_payloads(payloads: PayloadContainer, cb: Callable[[Sequence[temporalio.api.common.v1.Payload]], Awaitable[List[temporalio.api.common.v1.Payload]]]): (source)

Apply API payload callback to payloads.

async def _decode_payload(payload: temporalio.api.common.v1.Payload, codec: temporalio.converter.PayloadCodec): (source)

Decode a payload with the given codec.

async def _decode_payloads(payloads: PayloadContainer, codec: temporalio.converter.PayloadCodec): (source)

Decode payloads with the given codec.

async def _encode_payload(payload: temporalio.api.common.v1.Payload, codec: temporalio.converter.PayloadCodec): (source)

Decode a payload with the given codec.

async def _encode_payloads(payloads: PayloadContainer, codec: temporalio.converter.PayloadCodec): (source)

Encode payloads with the given codec.