U Z+d @sdZddlZddlmZmZmZmZddlmZej edej ddedd d d ej d d eed ddej ddeed ddej eddZ dS)zBThe ``celery purge`` program, used to delete messages from queues.N)COMMA_SEPARATED_LIST CeleryCommand CeleryOptionhandle_preload_options)text)clsz-fz--forceTzPurging OptionszDon't prompt for verification.)rZis_flag help_grouphelpz-Qz--queuesz-Comma separated list of queue names to purge.)rtyperr z-Xz--exclude-queuesz2Comma separated list of queues names not to purge.c s|jj}t|p|jj}t|p$g}||}t|}|rt|d}|sd t |}t j |jj dddd|d|dd d d d |tfd d|D} W5QRX| rt| d} |jd| d| d|d|d n|jd|d|ddS)zvErase all messages from all known task queues. Warning: There's no undo operation for this command. queuez, WARNINGZred)Zfgz!:This will remove all tasks from z: z. There is no undo for this operation! (to skip this prompt use the -f option) Are you sure you want to delete all tasks?T)abortcSs0z|j|pdWS|jk r*YdSXdS)Nr)Zdefault_channelZ queue_purgeZchannel_errors)connr r4/tmp/pip-unpacked-wheel-ucduq0nd/celery/bin/purge.py_purge7szpurge.._purgec3s|]}|VqdS)Nr).0r rrrr >szpurge..messagezPurged  z from z known task .zNo messages purged from N)objappsetZamqpqueueskeyslenrZ pluralizejoinsortedclickZconfirmstyleZconnection_for_writesumZecho) ctxforcerZexclude_queuesrnamesZqnumZqueues_headlineZ queue_namesmessagesZmessages_headlinerrrpurge s&  $ " (r') __doc__r Zcelery.bin.baserrrrZ celery.utilsrcommandoptionZ pass_contextr'rrrrs8