o Df0 @sdZddlZddlmZmZmZmZddlmZej eddidej dd edd d d ej d deed ddej ddeed ddej eddZ dS)zBThe ``celery purge`` program, used to delete messages from queues.N)COMMA_SEPARATED_LIST CeleryCommand CeleryOptionhandle_preload_options)textallow_extra_argsT)clscontext_settingsz-fz--forcezPurging OptionszDon't prompt for verification.)ris_flag help_grouphelpz-Qz--queuesz-Comma separated list of queue names to purge.)rtyper r z-Xz--exclude-queuesz2Comma separated list of queues names not to purge.c s*|jj}t|p |jj}t|pg}||}t|}|rt|d}|sCd t |} t j |jj dddd|d| dd d d d |tfd d|D} Wdn1sbwY| rt| d} |jd| d| d|d|d dS|jd|d|ddSdS)zvErase all messages from all known task queues. Warning: There's no undo operation for this command. queuez, WARNINGred)fgz!: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|jyYdSw)Nr)default_channel queue_purgechannel_errors)connrrI/home/ubuntu/webapp/venv/lib/python3.10/site-packages/celery/bin/purge.py_purge8s zpurge.._purgec3s|]}|VqdS)Nr).0rrrrr ?szpurge..NmessagezPurged  z from z known task .zNo messages purged from )objappsetamqpqueueskeyslenr pluralizejoinsortedclickconfirmstyleconnection_for_writesumecho) ctxforcer$exclude_queueskwargsr!namesqnumqueues_headline queue_namesmessagesmessages_headlinerrrpurges:    r:) __doc__r*celery.bin.baserrrr celery.utilsrcommandoption pass_contextr:rrrrs>