Overview
Settings reference
REST API
CLI Reference
Python SDK Reference
- artifacts
- automations
- cache_policies
- context
- engine
- exceptions
- filesystems
- flow_engine
- flow_runs
- flows
- futures
- main
- plugins
- results
- schedules
- serializers
- states
- task_engine
- task_runners
- task_runs
- task_worker
- tasks
- transactions
- variables
- prefect.assets
- prefect.blocks
- prefect.cli
- prefect.client
- prefect.concurrency
- prefect.deployments
- prefect.docker
- prefect.events
- prefect.infrastructure
- prefect.input
- prefect.locking
- prefect.logging
- prefect.runner
- prefect.runtime
- prefect.server
  - __init__
  - api
  - database
  - events
  - exceptions
  - logs
  - models
  - orchestration
  - schemas
  - services
  - task_queue
  - utilities
- prefect.settings
- prefect.telemetry
- prefect.testing
- prefect.types
- prefect.utilities
- prefect.workers

On this page

prefect.server.models.task_workers
Functions
observe_worker
forget_worker
get_workers_for_task_keys
get_all_workers
Classes
TaskWorkerResponse
InMemoryTaskWorkerTracker
forget_worker
get_all_workers
get_workers_for_task_keys
observe_worker
reset

`prefect.server.models.task_workers`

Functions

`observe_worker`

observe_worker(task_keys: List[TaskKey], worker_id: WorkerId) -> None

`forget_worker`

forget_worker(worker_id: WorkerId) -> None

`get_workers_for_task_keys`

get_workers_for_task_keys(task_keys: List[TaskKey]) -> List[TaskWorkerResponse]

`get_all_workers`

get_all_workers() -> List[TaskWorkerResponse]

Classes

`TaskWorkerResponse`

`InMemoryTaskWorkerTracker`

Methods:

`forget_worker`

forget_worker(self, worker_id: WorkerId) -> None

`get_all_workers`

get_all_workers(self) -> List[TaskWorkerResponse]

`get_workers_for_task_keys`

get_workers_for_task_keys(self, task_keys: List[TaskKey]) -> List[TaskWorkerResponse]

`observe_worker`

observe_worker(self, task_keys: List[TaskKey], worker_id: WorkerId) -> None

`reset`

reset(self) -> None

Testing utility to reset the state of the task worker tracker

task_runs variables