h <dZddlZddlmZmZmZmZddlmZej eej ddedd d ej d d eed dej ddeed dej edZ 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.)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   |jj}t|p|jj}t|pg}||z }t |}|r tj|d}|s[d t|}tj |j ddd|d|dd d |5 t fd |D} d d d n #1swxYwY| r>tj| d} |jd| d| d|d|d d S|jd|d|dd Sd S)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)abortc^ |j|pdS#|j$rYdSwxYw)Nr)default_channel queue_purgechannel_errors)connrs L/var/www/html/Sam_Eipo/venv/lib/python3.11/site-packages/celery/bin/purge.py_purgezpurge.._purge7sH +77>>C!C&   qq s  ,,c30K|]}|VdS)N).0rrrs r zpurge..>s/BB566$..BBBBBBNmessagezPurged  z from z known task .zNo messages purged from )objappsetamqpqueueskeyslenr pluralizejoinsortedclickconfirmstyleconnection_for_writesumecho) ctxforcer&exclude_queuesr#namesqnumqueues_headline queue_namesmessagesmessages_headlinerrs @@rpurger; sd8 '+C 138?//11 2 2F-2..N ^ #E u::D O.w77 &))F5MM22K MSW]]9]??GG,GG0;GGG !%  & & & &     % % ' ' C4BBBBBEBBBBBH C C C C C C C C C C C C C C C  O $x C C  GLLA8AA.?AA AA.=AAA B B B B B GLLMDMM?MMM N N N N N5OOs-DDD) __doc__r,celery.bin.baserrrr celery.utilsrcommandoption pass_contextr;rrrrBsdHH CCCCCCCCCCCC=!!! d*3 555 d'*B DDD d '*G III 'O'O II DD 55"!*'O'O'Or