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 activity_task_poller_behavior Undocumented
Class Variable build_id Undocumented
Class Variable client Undocumented
Class Variable debug_mode Undocumented
Class Variable default_heartbeat_throttle_interval Undocumented
Class Variable deployment_config 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_nexus_tasks 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 nexus_service_handlers Undocumented
Class Variable nexus_task_executor Undocumented
Class Variable nexus_task_poller_behavior 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 workflow_task_poller_behavior Undocumented
Class Variable workflows Undocumented
activities: Sequence[Callable] = (source)

Undocumented

activity_executor: concurrent.futures.Executor | None = (source)

Undocumented

activity_task_poller_behavior: PollerBehavior = (source)

Undocumented

build_id: str | None = (source)

Undocumented

client: temporalio.client.Client = (source)

Undocumented

debug_mode: bool = (source)

Undocumented

default_heartbeat_throttle_interval: timedelta = (source)

Undocumented

deployment_config: WorkerDeploymentConfig | None = (source)

Undocumented

disable_eager_activity_execution: bool = (source)

Undocumented

disable_safe_workflow_eviction: bool = (source)

Undocumented

graceful_shutdown_timeout: timedelta = (source)

Undocumented

identity: str | None = (source)

Undocumented

interceptors: Sequence[Interceptor] = (source)

Undocumented

max_activities_per_second: float | None = (source)

Undocumented

max_cached_workflows: int = (source)

Undocumented

max_concurrent_activities: int | None = (source)

Undocumented

max_concurrent_activity_task_polls: int | None = (source)

Undocumented

max_concurrent_local_activities: int | None = (source)

Undocumented

max_concurrent_nexus_tasks: int | None = (source)

Undocumented

max_concurrent_workflow_task_polls: int | None = (source)

Undocumented

max_concurrent_workflow_tasks: int | None = (source)

Undocumented

max_heartbeat_throttle_interval: timedelta = (source)

Undocumented

max_task_queue_activities_per_second: float | None = (source)

Undocumented

nexus_service_handlers: Sequence[Any] = (source)

Undocumented

nexus_task_executor: concurrent.futures.Executor | None = (source)

Undocumented

nexus_task_poller_behavior: PollerBehavior = (source)

Undocumented

no_remote_activities: bool = (source)

Undocumented

nonsticky_to_sticky_poll_ratio: float = (source)

Undocumented

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

Undocumented

shared_state_manager: SharedStateManager | None = (source)

Undocumented

sticky_queue_schedule_to_start_timeout: timedelta = (source)

Undocumented

task_queue: str = (source)

Undocumented

tuner: WorkerTuner | None = (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: concurrent.futures.ThreadPoolExecutor | None = (source)

Undocumented

workflow_task_poller_behavior: PollerBehavior = (source)

Undocumented

workflows: Sequence[type] = (source)

Undocumented