`prefect_redis.cleanup_queue`

Classes

Settings for the Redis-backed worker cleanup queue.

Redis-backed cleanup queue storage. Methods:

ack(self) -> CleanupQueueOperationResult

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