temporalio.worker.WorkerTuner

class documentation

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

WorkerTuners allow for the dynamic customization of some aspects of worker configuration

Class Method create_composite Create a tuner composed of the provided slot suppliers.
Class Method create_fixed Create a fixed-size tuner with the provided number of slots.
Class Method create_resource_based Create a resource-based tuner with the provided options.
Static Method _get_slot_supplier_max Undocumented
Method _get_activities_max Undocumented
Method _get_activity_task_slot_supplier Undocumented
Method _get_local_activity_task_slot_supplier Undocumented
Method _get_nexus_slot_supplier Undocumented
Method _get_nexus_tasks_max Undocumented
Method _get_workflow_task_slot_supplier Undocumented
Method _to_bridge_tuner Undocumented
@classmethod
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.

@classmethod
def create_fixed(cls, *, workflow_slots: int | None = None, activity_slots: int | None = None, local_activity_slots: int | None = None, nexus_slots: int | None = None) -> WorkerTuner: (source)

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

Any unspecified slot numbers will default to 100.

@classmethod
def create_resource_based(cls, *, target_memory_usage: float, target_cpu_usage: float, workflow_config: ResourceBasedSlotConfig | None = None, activity_config: ResourceBasedSlotConfig | None = None, local_activity_config: ResourceBasedSlotConfig | None = None, nexus_config: ResourceBasedSlotConfig | None = None) -> WorkerTuner: (source)

Create a resource-based tuner with the provided options.

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

Undocumented

def _get_activities_max(self) -> int | None: (source)

Undocumented

@abstractmethod
def _get_activity_task_slot_supplier(self) -> SlotSupplier: (source)
overridden in temporalio.worker._tuning._CompositeTuner

Undocumented

@abstractmethod
def _get_local_activity_task_slot_supplier(self) -> SlotSupplier: (source)
overridden in temporalio.worker._tuning._CompositeTuner

Undocumented

@abstractmethod
def _get_nexus_slot_supplier(self) -> SlotSupplier: (source)
overridden in temporalio.worker._tuning._CompositeTuner

Undocumented

def _get_nexus_tasks_max(self) -> int | None: (source)

Undocumented

@abstractmethod
def _get_workflow_task_slot_supplier(self) -> SlotSupplier: (source)
overridden in temporalio.worker._tuning._CompositeTuner

Undocumented

def _to_bridge_tuner(self) -> temporalio.bridge.worker.TunerHolder: (source)

Undocumented