temporalio.worker.WorkerConfig

class documentation

class WorkerConfig(TypedDict): (source)

View In Hierarchy

TypedDict of config originally passed to Worker.

Class Variable activities Undocumented
Class Variable activity_executor Undocumented
Class Variable build_id Undocumented
Class Variable client Undocumented
Class Variable debug_mode Undocumented
Class Variable default_heartbeat_throttle_interval Undocumented
Class Variable disable_eager_activity_execution Undocumented
Class Variable disable_safe_workflow_eviction Undocumented
Class Variable graceful_shutdown_timeout Undocumented
Class Variable identity Undocumented
Class Variable interceptors Undocumented
Class Variable max_activities_per_second Undocumented
Class Variable max_cached_workflows Undocumented
Class Variable max_concurrent_activities Undocumented
Class Variable max_concurrent_activity_task_polls Undocumented
Class Variable max_concurrent_local_activities Undocumented
Class Variable max_concurrent_workflow_task_polls Undocumented
Class Variable max_concurrent_workflow_tasks Undocumented
Class Variable max_heartbeat_throttle_interval Undocumented
Class Variable max_task_queue_activities_per_second Undocumented
Class Variable no_remote_activities Undocumented
Class Variable nonsticky_to_sticky_poll_ratio Undocumented
Class Variable on_fatal_error Undocumented
Class Variable shared_state_manager Undocumented
Class Variable sticky_queue_schedule_to_start_timeout Undocumented
Class Variable task_queue Undocumented
Class Variable tuner Undocumented
Class Variable unsandboxed_workflow_runner Undocumented
Class Variable use_worker_versioning Undocumented
Class Variable workflow_failure_exception_types Undocumented
Class Variable workflow_runner Undocumented
Class Variable workflow_task_executor Undocumented
Class Variable workflows Undocumented
activities: Sequence[Callable] = (source)

Undocumented

activity_executor: Optional[concurrent.futures.Executor] = (source)

Undocumented

build_id: Optional[str] = (source)

Undocumented

client: temporalio.client.Client = (source)

Undocumented

debug_mode: bool = (source)

Undocumented

default_heartbeat_throttle_interval: timedelta = (source)

Undocumented

disable_eager_activity_execution: bool = (source)

Undocumented

disable_safe_workflow_eviction: bool = (source)

Undocumented

graceful_shutdown_timeout: timedelta = (source)

Undocumented

identity: Optional[str] = (source)

Undocumented

interceptors: Sequence[Interceptor] = (source)

Undocumented

max_activities_per_second: Optional[float] = (source)

Undocumented

max_cached_workflows: int = (source)

Undocumented

max_concurrent_activities: Optional[int] = (source)

Undocumented

max_concurrent_activity_task_polls: int = (source)

Undocumented

max_concurrent_local_activities: Optional[int] = (source)

Undocumented

max_concurrent_workflow_task_polls: int = (source)

Undocumented

max_concurrent_workflow_tasks: Optional[int] = (source)

Undocumented

max_heartbeat_throttle_interval: timedelta = (source)

Undocumented

max_task_queue_activities_per_second: Optional[float] = (source)

Undocumented

no_remote_activities: bool = (source)

Undocumented

nonsticky_to_sticky_poll_ratio: float = (source)

Undocumented

on_fatal_error: Optional[Callable[[BaseException], Awaitable[None]]] = (source)

Undocumented

shared_state_manager: Optional[SharedStateManager] = (source)

Undocumented

sticky_queue_schedule_to_start_timeout: timedelta = (source)

Undocumented

task_queue: str = (source)

Undocumented

tuner: Optional[WorkerTuner] = (source)

Undocumented

unsandboxed_workflow_runner: WorkflowRunner = (source)

Undocumented

use_worker_versioning: bool = (source)

Undocumented

workflow_failure_exception_types: Sequence[Type[BaseException]] = (source)

Undocumented

workflow_runner: WorkflowRunner = (source)

Undocumented

workflow_task_executor: Optional[concurrent.futures.ThreadPoolExecutor] = (source)

Undocumented

workflows: Sequence[Type] = (source)

Undocumented