prefect_redis.cleanup_queue

Classes

RedisWorkerCleanupQueueSettings ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-redis/prefect_redis/cleanup_queue.py#L73" 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#L142" 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#L309" 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#L161" 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#L356" 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#L419" 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#L407" 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#L444" 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#L323" 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#L342" 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#L241" 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#L448" 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#L431" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

wake_dispatchers(self, work_pool_id: UUID) -> CleanupQueueWakeup