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 PollerBehavior Undocumented
Type Alias SlotSupplier Undocumented
Type Alias WorkerVersioningStrategy Undocumented
Class _Visitor Undocumented
async def decode_activation(act: temporalio.bridge.proto.workflow_activation.WorkflowActivation, codec: temporalio.converter.PayloadCodec, decode_headers: bool): (source)

Decode the given activation with the codec.

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

Recursively encode the given completion with the codec.

PollerBehavior: TypeAlias = (source)

Undocumented

Value
PollerBehaviorSimpleMaximum | PollerBehaviorAutoscaling
SlotSupplier: TypeAlias = (source)

Undocumented

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

Undocumented

Value
WorkerVersioningStrategyNone | WorkerDeploymentOptions | WorkerVersioningStrategyLegacyBuildIdBased