prefect_redis.cleanup_queue

Classes

RedisWorkerCleanupQueueSettings ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-redis/prefect_redis/cleanup_queue.py#L62" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

Settings for the Redis-backed worker cleanup queue.

WorkerCleanupQueue ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-redis/prefect_redis/cleanup_queue.py#L131" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

Redis-backed cleanup queue storage.

Methods:

ack ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-redis/prefect_redis/cleanup_queue.py#L284" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

ack(self) -> CleanupQueueOperationResult

enqueue ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-redis/prefect_redis/cleanup_queue.py#L150" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

enqueue(self) -> CleanupQueueMessage

expire_leases ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-redis/prefect_redis/cleanup_queue.py#L331" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

expire_leases(self) -> CleanupQueueLeaseExpiryResult

read_dead_letter ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-redis/prefect_redis/cleanup_queue.py#L394" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

read_dead_letter(self) -> CleanupQueueDeadLetter | None

read_message ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-redis/prefect_redis/cleanup_queue.py#L382" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

read_message(self) -> CleanupQueueMessage | None

read_wakeup_sequence ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-redis/prefect_redis/cleanup_queue.py#L419" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

read_wakeup_sequence(self, work_pool_id: UUID) -> int

release ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-redis/prefect_redis/cleanup_queue.py#L298" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

release(self) -> CleanupQueueOperationResult

renew ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-redis/prefect_redis/cleanup_queue.py#L317" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

renew(self) -> CleanupQueueOperationResult

reserve ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-redis/prefect_redis/cleanup_queue.py#L216" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

reserve(self) -> CleanupQueueReservation | None

wait_for_wakeup ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-redis/prefect_redis/cleanup_queue.py#L423" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

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

wake_dispatchers ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-redis/prefect_redis/cleanup_queue.py#L406" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

wake_dispatchers(self, work_pool_id: UUID) -> CleanupQueueWakeup