temporalio.worker.WorkerConfig

temporalio.worker.WorkerConfig

class documentation

class WorkerConfig(TypedDict): (source)

View In Hierarchy

TypedDict of config originally passed to Worker.

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_payload_error_limit: 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

max_workflow_task_external_storage_concurrency: int = (source)

Undocumented

nexus_service_handlers: Sequence[Any] = (source)

Undocumented

nexus_task_executor: concurrent.futures.ThreadPoolExecutor | 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

plugins: Sequence[Plugin] = (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