Skip to content

Commit 61c9442

Browse files
committed
When emptying a queue, also remove from known queues
1 parent 48a250d commit 61c9442

1 file changed

Lines changed: 1 addition & 0 deletions

File tree

mrq/queue.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -387,6 +387,7 @@ def remove_raw_jobs(self, params_list):
387387

388388
def empty(self):
389389
""" Empty a queue. """
390+
self.remove_from_known_queues()
390391
return context.connections.redis.delete(self.redis_key)
391392

392393
def dequeue_jobs(self, max_jobs=1, job_class=None, worker=None):

0 commit comments

Comments
 (0)