a xd @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|}|r$t|d}|sd t |}t j |jj dddd|d|dd d d d |(tfd d|D} Wdn1s0Y| r t| 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)abortcSs.z|j|pdWS|jy(YdS0dS)Nr)Zdefault_channelZ queue_purgeZchannel_errors)connr rH/var/www/html/Ranjet/env/lib/python3.9/site-packages/celery/bin/purge.py_purge7szpurge.._purgec3s|]}|VqdS)Nr).0r rrrr >zpurge..NmessagezPurged  z from z known task .zNo messages purged from )objappsetZamqpqueueskeyslenrZ pluralizejoinsortedclickZconfirmstyleZconnection_for_writesumZecho) ctxforcerZexclude_queuesrnamesZqnumZqueues_headlineZ queue_namesmessagesZmessages_headlinerrrpurge s6   6  r() __doc__r!Zcelery.bin.baserrrrZ celery.utilsrcommandoptionZ pass_contextr(rrrrs8