`prefect.server.worker_communication.cleanup_queue.memory`

Classes

Singleton in-memory cleanup queue storage for a single server process. Methods:

ack(self) -> CleanupQueueOperationResult

clear(self) -> None

enqueue(self) -> CleanupQueueMessage

expire_leases(self) -> CleanupQueueLeaseExpiryResult

read_dead_letter(self) -> CleanupQueueDeadLetter | None

read_message(self) -> CleanupQueueMessage | None

read_wakeup_sequence(self, work_pool_id: UUID) -> int

release(self) -> CleanupQueueOperationResult

renew(self) -> CleanupQueueOperationResult

reserve(self) -> CleanupQueueReservation | None

wait_for_wakeup(self, work_pool_id: UUID) -> CleanupQueueWakeup | None

wake_dispatchers(self, work_pool_id: UUID) -> CleanupQueueWakeup