temporalio.bridge.worker

module documentation
(source)

Worker using SDK Core. (unstable)

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

Class FixedSizeSlotSupplier Python representation of the Rust struct for a fixed-size slot supplier.
Class ResourceBasedSlotSupplier Python representation of the Rust struct for a resource-based slot supplier.
Class ResourceBasedTunerConfig Python representation of the Rust struct for configuring a resource-based tuner.
Class TunerHolder Python representation of the Rust struct for a tuner holder.
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
Type Alias SlotSupplier 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↵
]
SlotSupplier: TypeAlias = (source)

Undocumented

Value
Union[FixedSizeSlotSupplier, ResourceBasedSlotSupplier]
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.