This document describes the current stable version of Celery (4.2). For development docs, go here.
celery.bin.purge
¶
The celery purge
program, used to delete messages from queues.
-
class
celery.bin.purge.
purge
(app=None, get_app=None, no_color=False, stdout=None, stderr=None, quiet=False, on_error=None, on_usage_error=None)[source]¶ Erase all messages from all known task queues.
Warning
There’s no undo operation for this command.
-
fmt_empty
= u'No messages purged from {qnum} {queues}'¶
-
fmt_purged
= u'Purged {mnum} {messages} from {qnum} known task {queues}.'¶
-
warn_prelude
= u'{warning}: This will remove all tasks from {queues}: {names}.\n There is no undo for this operation!\n\n(to skip this prompt use the -f option)\n'¶
-
warn_prompt
= u'Are you sure you want to delete all tasks'¶
-