bin.purge

The celery purge program, used to delete messages from queues.

Module Contents

Classes

purge() Erase all messages from all known task queues.
class purge

Erase all messages from all known task queues.

Warning:
There’s no undo operation for this command.
add_arguments(parser)
run(force=False, queues=None, exclude_queues=None, **kwargs)
_purge(conn, queue)