
    h0
                     6   d Z ddlZddlmZmZmZmZ ddlmZ  ej                  eddi       ej                  dd	edd
d       ej                  ddeed
d       ej                  ddeed
d      ej                  ed                                           Zy)zBThe ``celery purge`` program, used to delete messages from queues.    N)COMMA_SEPARATED_LISTCeleryCommandCeleryOptionhandle_preload_options)textallow_extra_argsT)clscontext_settingsz-fz--forcezPurging OptionszDon't prompt for verification.)r	   is_flag
help_grouphelpz-Qz--queuesz-Comma separated list of queue names to purge.)r	   typer   r   z-Xz--exclude-queuesz2Comma separated list of queues names not to purge.c                    | j                   j                  }t        |xs$ |j                  j                  j                               }t        |xs g       }||z
  }t        |      }|rt        j                  |d      }|sUdj                  t        |            }	t        j                  | j                   j                  dd       d| d|	 dd	
       d |j                         5 t        fd|D              }
ddd       
r?t        j                  |
d      }| j                   j!                  d|
 d| d| d| d	       y| j                   j!                  d| d| d       yy# 1 sw Y   nxY w)zvErase all messages from all known task queues.

    Warning:

        There's no undo operation for this command.
    queuez, WARNINGred)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                 l    	 | j                   j                  |      xs dS # | j                  $ r Y yw xY w)Nr   )default_channelqueue_purgechannel_errors)connr   s     L/var/www/Befach/backend/env/lib/python3.12/site-packages/celery/bin/purge.py_purgezpurge.<locals>._purge8   s;    ++77>C!C&& s   ! 33c              3   0   K   | ]  } |        y w)N ).0r   r   r   s     r   	<genexpr>zpurge.<locals>.<genexpr>?   s     B56$.Bs   NmessagezPurged  z from z known task .zNo messages purged from )objappsetamqpqueueskeyslenr   	pluralizejoinsortedclickconfirmstyleconnection_for_writesumecho)ctxforcer'   exclude_queueskwargsr$   namesqnumqueues_headlinequeue_namesmessagesmessages_headliner   r   s               @@r   purger=      sr   < ''++C1388??//12F-2.N^#Eu:D..w7))F5M2KMMSWW]]9]?@ A=,-R} =GG !%&	 %%' 	C4BEBBH	C  $x CGGLL78*A.?-@ 6o->aA B GGLL3D6?:K1MN5 $	C 	Cs   ,E//E8)__doc__r-   celery.bin.baser   r   r   r   celery.utilsr   commandoptionpass_contextr=   r       r   <module>rE      s    H  e e  =4  d*35 d'*BD d '*GI 'O  ID5.'OrD   