Function clear_jobs

python/celery/worker/store.py:72–80

()

def clear_jobs() -> int:
    job_ids = r.zrange(JOBS_SET, 0, -1)
    if job_ids:
        pipe = r.pipeline()
        for jid in job_ids:
            pipe.delete(JOB_KEY.format(jid))
        pipe.delete(JOBS_SET)
        pipe.execute()
    return len(job_ids)