`prefect.server.utilities.worker_channel_cleanup`

Classes

Methods:

dispatch_available(self) -> None

forget_cleanup_reservation(self, connection: WorkerChannelConnection) -> bool

has_cleanup_capacity(self, connection: WorkerChannelConnection, max_cleanup_concurrency: int) -> bool

register(self, connection: WorkerChannelConnection) -> AsyncIterator[None]

track_cleanup_reservation(self, connection: WorkerChannelConnection, in_flight: WorkerCleanupInFlight, max_cleanup_concurrency: int) -> bool

update_cleanup_lease(self, connection: WorkerChannelConnection) -> bool

wake_dispatcher(self, work_pool_id: UUID) -> None

⌘I