Skip to content

Commit 366264e

Browse files
Fix passing queues into purge command (celery#6469)
In current wersion calling `celery --app my.celery_app purge -Q queue_name` is failing with following trace: ``` names = (queues or set(app.amqp.queues.keys())) - exclude_queues TypeError: unsupported operand type(s) for -: 'list' and 'list' ``` Becouse code is expecting set and `queues` is actually a list. Here is a fix.
1 parent b038786 commit 366264e

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

celery/bin/purge.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -32,10 +32,10 @@ def purge(ctx, force, queues, exclude_queues):
3232
3333
There's no undo operation for this command.
3434
"""
35-
queues = queues or set()
36-
exclude_queues = exclude_queues or set()
3735
app = ctx.obj.app
38-
names = (queues or set(app.amqp.queues.keys())) - exclude_queues
36+
queues = set(queues or app.amqp.queues.keys())
37+
exclude_queues = set(exclude_queues or [])
38+
names = queues - exclude_queues
3939
qnum = len(names)
4040

4141
if names:

0 commit comments

Comments
 (0)