utilities
worker_channel_cleanup
Methods:
Was this page helpful?
Documentation Index
Fetch the complete documentation index at: /llms.txt
Use this file to discover all available pages before exploring further.
prefect.server.utilities.worker_channel_cleanupWorkerCleanupInFlight WorkerCleanupConnectionRegistry dispatch_available dispatch_available(self) -> None
forget_cleanup_reservation forget_cleanup_reservation(self, connection: WorkerChannelConnection) -> bool
has_cleanup_capacity has_cleanup_capacity(self, connection: WorkerChannelConnection, max_cleanup_concurrency: int) -> bool
register register(self, connection: WorkerChannelConnection) -> AsyncIterator[None]
track_cleanup_reservation track_cleanup_reservation(self, connection: WorkerChannelConnection, in_flight: WorkerCleanupInFlight, max_cleanup_concurrency: int) -> bool
update_cleanup_lease update_cleanup_lease(self, connection: WorkerChannelConnection) -> bool
wake_dispatcher wake_dispatcher(self, work_pool_id: UUID) -> None
Was this page helpful?