o

-we0
�@s�dZd
dl
Z
d
dlmZmZmZmZ
d
dlmZ
e
j	eddi
d�e
j
dd	edd
dd�e
j
d
deed
dd�e
j
ddeed
dd�e
jedd��
�
�
�
�
�
ZdS)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--forcezPurging OptionszDon't prompt for verification.)r�is_flag�
help_group�helpz-Qz--queuesz-Comma separated list of queue names to purge.)r�typerrz-Xz--exclude-queuesz2Comma separated list of queues names not to purge.cs*
|jj
}t|p|jj���
}t|pg�
}||}t|�
}|r�t�|d
�}|
sCd�	t
|�
�
}	tj|jj
ddd��d|�d|	�d�d	d
�
dd��|����
t��
fd
d�|D�
�
}
Wd�
n1sbw



Y
|
r�t�|
d�}|j�d|
�d|�d|�d|�d�	�

dS|j�d|�d|�d��

dSdS)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)
�abortcSs*z	|j�
|
�
pd
WS|jy


Yd
Sw)Nr
)�default_channel�queue_purge�channel_errors)�connr�r�I/home/arjun/projects/env/lib/python3.10/site-packages/celery/bin/purge.py�_purge8s




�zpurge.<locals>._purgec
3s�|]}
��
|
�V
qdS)
Nr)�.0r�rrrr�	<genexpr>?s�zpurge.<locals>.<genexpr>N�messagezPurged �
 z from z known task �
.zNo 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_headlinerrr�purges:







���

�


�
��r:)
�__doc__r*�celery.bin.baserrrr�celery.utilsr�command�option�pass_contextr:rrrr�<module>
s>


�




�




�




�