Destroying / removing a Queue() in Redis Queue (rq) programmatically

Question

Given:

from redis import Redis
from rq import Queue

yesterday = Queue('yesterday', connection=Redis())
today = Queue('today', connection=Redis())

I would like to programmatically delete the Queue named 'yesterday'

peakxu · Accepted Answer · 2014-08-05 00:55:30Z

4

Try the following (you can validate all of this with redis-cli):

yesterday.empty()  # This will wipe out rq:queue:yesterday and all of its contents
del(yesterday)  # Deletes the variable itself
r = Redis()
r.srem('rq:queues', 'rq:queue:yesterday')  # Removed the entry from rq:queues set. The library unfortunately doesn't seem to clean this up by itself.

answered Aug 5, 2014 at 0:55

peakxu

6,6951 gold badge31 silver badges27 bronze badges

Sign up to request clarification or add additional context in comments.

3 Comments

Carl Sagan Over a year ago

Is there a way to do this within the rq library?

peakxu Over a year ago

@CarlSagan, I poked around quickly in the rq library's public interface. I didn't find anything useful. You may want to just make a rq Queue wrapper that does all this cleanup inside __del__

atripes Over a year ago

The paramter ttl in q.enqueue_call could be used to clear queues of jobs. If it worked, that is.

Collectives™ on Stack Overflow

Destroying / removing a Queue() in Redis Queue (rq) programmatically

1 Answer 1

3 Comments

Your Answer

Linked

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

3 Comments

Your Answer

Sign up or log in

Post as a guest

Linked

Related