work_pool_update_triggers_snapshot(update_values: Mapping[str, Any]) -> bool

close_worker_channel(websocket: WebSocket, close_reason: WorkerChannelCloseReason) -> None

build_worker_channel_work_pool_snapshot(session: AsyncSession, work_pool: ORMWorkPool) -> WorkPoolSnapshot

publish_snapshot_invalidation(invalidation: WorkerChannelSnapshotInvalidation) -> None

parse_snapshot_invalidation(message: messaging.Message) -> WorkerChannelSnapshotInvalidation

model_validate_list(cls, obj: Any) -> list[Self]

reset_fields(self: Self) -> Self

targets(self) -> bool

cleanup_enabled(self) -> bool

close(self, close_reason: WorkerChannelCloseReason) -> None

dispatch_one_cleanup_message(self) -> bool

has_cleanup_capacity(self) -> bool

queue_snapshot(self, invalidation: WorkerChannelSnapshotInvalidation) -> None

run(self, ready: WorkerReadyFrame, consumer_kwargs: Mapping[str, Any]) -> None