Documentation Index
Fetch the complete documentation index at: https://docs.prefect.io/llms.txt
Use this file to discover all available pages before exploring further.
prefect.server.utilities.worker_channel
Functions
work_pool_update_triggers_snapshot
work_pool_update_triggers_snapshot(update_values: Mapping[str, Any]) -> bool
close_worker_channel
close_worker_channel(websocket: WebSocket, close_reason: WorkerChannelCloseReason) -> None
build_worker_channel_work_pool_snapshot
build_worker_channel_work_pool_snapshot(session: AsyncSession, work_pool: ORMWorkPool) -> WorkPoolSnapshot
publish_snapshot_invalidation
publish_snapshot_invalidation(invalidation: WorkerChannelSnapshotInvalidation) -> None
parse_snapshot_invalidation
parse_snapshot_invalidation(message: messaging.Message) -> WorkerChannelSnapshotInvalidation
Classes
WorkerChannelSnapshotInvalidation
Methods:
model_validate_list
model_validate_list(cls, obj: Any) -> list[Self]
reset_fields
reset_fields(self: Self) -> Self
_reset_fields set.
Returns:
- A new instance of the model with the reset fields.
targets
WorkerChannelConnection
Methods:
close
close(self, close_reason: WorkerChannelCloseReason) -> None
queue_snapshot
queue_snapshot(self, invalidation: WorkerChannelSnapshotInvalidation) -> None
run
run(self, ready: WorkerReadyFrame, consumer_kwargs: Mapping[str, Any]) -> None
