Fix Stuck Jobs in RQ Failed Queue

empty-rq-failed-queue.py

# If RQ thinks there are failed jobs
# but they do not exist in Redis
# and RQ-Dashboard cannot remove/requeue them

from redis import Redis
from rq import Queue
from rq.registry import FailedJobRegistry
from rq.exceptions import NoSuchJobError

redis_rq = Redis(host=REDIS_SERVER, port=6379, db=1)

queue = Queue(name="low", connection=redis_rq)
registry = FailedJobRegistry(queue=queue)
print(registry.count)

for job_id in registry.get_job_ids():
    try:
        registry.requeue(job_id)
    except NoSuchJobError:
        registry.remove(job_id)