temporalio.worker.WorkerTuner

class WorkerTuner(ABC): (source)

Known subclasses: temporalio.worker._tuning._CompositeTuner

Constructors: WorkerTuner.create_composite(workflow_supplier, activity_supplier, local_activity_supplier, nexus_supplier), WorkerTuner.create_fixed(workflow_slots, activity_slots, local_activity_slots, nexus_slots), WorkerTuner.create_resource_based(target_memory_usage, target_cpu_usage, workflow_config, activity_config, ...)

View In Hierarchy

def create_composite(cls, *, workflow_supplier: SlotSupplier, activity_supplier: SlotSupplier, local_activity_supplier: SlotSupplier, nexus_supplier: SlotSupplier) -> WorkerTuner: (source) ¶

Create a tuner composed of the provided slot suppliers.

Create a fixed-size tuner with the provided number of slots.

Any unspecified slot numbers will default to 100.

Create a resource-based tuner with the provided options.

def _get_slot_supplier_max(slot_supplier: SlotSupplier) -> int | None: (source) ¶

@abstractmethod

def _get_activity_task_slot_supplier(self) -> SlotSupplier: (source) ¶

@abstractmethod

def _get_local_activity_task_slot_supplier(self) -> SlotSupplier: (source) ¶

@abstractmethod

def _get_nexus_slot_supplier(self) -> SlotSupplier: (source) ¶

@abstractmethod

def _get_workflow_task_slot_supplier(self) -> SlotSupplier: (source) ¶