Ë
    —V.j0
  ã                   ó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     úRC:\xampp\htdocs\tradingbinance\backend\.venv\Lib\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   øè ø€ ÐB¹E°5™6 $¨×.¹Eùs   ƒ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=      sg  ù€ ð< �'‰'�+‰+€CÜ�Ò1˜3Ÿ8™8Ÿ?™?×/Ñ/Ó1Ó2€FÜ˜Ò-¨2Ó.€NØ�^Ñ#€EÜˆu‹:€DâÜŸ.™.¨¨wÓ7ˆÙØŸ)™)¤F¨5£MÓ2ˆKÜ�M‰M˜SŸW™WŸ]™]¨9¸˜]Ó?Ð@ð A=à,Ð-¨R°¨}ð =GðGð !%õ&ò	ð ×%Ñ%Ô'¨4ÜÔB¹EÓBÓBˆH÷ (ñ Ü $§¡¨x¸Ó CÐØ�G‰G�L‰L˜7 8 *¨AÐ.?Ð-@ÀØ ˜6 ¨oÐ->¸aðAõ Bð �G‰G�L‰LÐ3°D°6¸¸?Ð:KÈ1ÐMÕNð5 ÷$ (Ð'ú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   