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 PollerBehaviorAutoscaling Python representation of the Rust struct for autoscaling poller behavior.
Class PollerBehaviorSimpleMaximum Python representation of the Rust struct for simple poller behavior.
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.
Class WorkerDeploymentOptions Python representation of the Rust struct for configuring a worker deployment options.
Class WorkerDeploymentVersion Python representation of the Rust struct for configuring a worker deployment version.
Class WorkerVersioningStrategyLegacyBuildIdBased Python representation of the Rust struct for configuring a worker versioning strategy legacy Build ID-based.
Class WorkerVersioningStrategyNone Python representation of the Rust struct for configuring a worker versioning strategy None.
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 PollerBehavior Undocumented
Type Alias SlotSupplier Undocumented
Type Alias WorkerVersioningStrategy 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↵
]
PollerBehavior: TypeAlias = (source)

Undocumented

Value
PollerBehaviorSimpleMaximum | PollerBehaviorAutoscaling
SlotSupplier: TypeAlias = (source)

Undocumented

Value
FixedSizeSlotSupplier | ResourceBasedSlotSupplier | BridgeCustomSlotSupplier
WorkerVersioningStrategy: TypeAlias = (source)

Undocumented

Value
WorkerVersioningStrategyNone | WorkerDeploymentOptions | WorkerVersioningStrategyLegacyBuildIdBased
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.