Skip to content

Commit 04e2e8a

Browse files
author
Florian Perucki
committed
fix cleaning logic
1 parent f5e3cf0 commit 04e2e8a

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

mrq/basetasks/cleaning.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -140,7 +140,7 @@ def run(self, params):
140140
if check_mongo:
141141
has_job = connections.mongodb_jobs.mrq_jobs.find_one({"queue": queue})
142142

143-
if size == 0 and (not check_mongo or has_job):
143+
if size == 0 and (not check_mongo or not has_job):
144144
removed_queues.append(queue)
145145
print("Removing empty queue '%s' from known queues ..." % queue)
146146
if not pretend:

0 commit comments

Comments
 (0)