Delete finished jobs from redis. Better than a FLUSHBD

redis_empty.py

import redis

r = redis.StrictRedis(host='redis')
l = r.keys('rq:job:*')
deleted_jobs = 0
total_jobs = len(l)
for j in l:
    if 'dependents' in j:
        continue
    print 'Job {}'.format(j)
    status = r.hget(j, 'status')
    print ' * STATE is {}'.format(status)
    if status == 'finished' or status is None:
        deleted_jobs += 1
        r.delete(j)
        print '    * DELETED'
print('DELETED {} / {} Jobs'.format(deleted_jobs, total_jobs))