o
    ›¨Êhê
  ã                   @   s  d Z ddlZddlmZ ddlZddlmZmZmZm	Z	 ddl
mZmZmZ d)dd„Zd	d
„ Z			d*dd„Zdd„ Zejed�ejddeddd�ejddedd�ejddeddd�ejdddededd�ejd d!edd�ejd"d#d$eedd%d&�eje	d'd(„ ƒƒƒƒƒƒƒƒƒZdS )+zThe ``celery events`` program.é    N)Úpartial)Ú	LOG_LEVELÚCeleryDaemonCommandÚCeleryOptionÚhandle_preload_options)ÚdetachedÚset_process_titleÚstrargvÚ c                 C   s,   d  d| ¡} |› dttjƒ› �}t| |d�S )Nz{}:{}zcelery eventsú )Úinfo)Úformatr	   ÚsysÚargvr   )Úprogr   © r   úC/var/www/html/env/lib/python3.10/site-packages/celery/bin/events.pyÚ_set_process_status   s   r   c                 C   s   ddl m} tdƒ || d�S )Nr   )ÚevdumpÚdump©Úapp)Úcelery.events.dumperr   r   )r   r   r   r   r   Ú_run_evdump   s   
r   Fc	                 K   sz   ddl m}
 tdƒ ||	d< t|
| f||dœ|	¤Ž}|r:t||||||ƒ� |ƒ W  d   ƒ S 1 s3w   Y  d S |ƒ S )Nr   )ÚevcamÚcamr   )ÚlogfileÚpidfile)Úcelery.events.snapshotr   r   r   r   )Úcamerar   r   r   ÚuidÚgidÚumaskÚworkdirÚdetachÚkwargsr   r   r   r   r   Ú
_run_evcam   s   ÿÿ$ÿr&   c              
   C   s\   zddl m} tdƒ || d�W S  ty- } z|jdkr"t d¡‚W Y d }~d S d }~ww )Nr   )ÚevtopÚtopr   Ú_cursesz/The curses module is required for this command.)Úcelery.events.cursesmonr'   r   ÚModuleNotFoundErrorÚnameÚclickÚ
UsageError)r   r'   Úer   r   r   Ú
_run_evtop'   s   

þ€ÿr0   )Úclsz-dz--dumpTÚDumper)r1   Úis_flagÚ
help_groupz-cz--cameraÚSnapshot)r1   r4   z--detachz-Fz--frequencyz--freqg      ð?)ÚtypeÚdefaultr1   r4   z-rz	--maxratez-lz
--loglevelÚWARNINGzLogging level.)r7   r1   r6   r4   Úhelpc           	      K   s<   | j j}|r
t|ƒS |rt|f|||||dœ|¤ŽS t|ƒS )zEvent-stream utilities.)r   ÚfreqÚmaxrateÚloglevelr$   )Úobjr   r   r&   r0   )	Úctxr   r   r$   Ú	frequencyr;   r<   r%   r   r   r   r   Úevents2   s   "þýr@   )r
   )NNNNNNF)Ú__doc__r   Ú	functoolsr   r-   Úcelery.bin.baser   r   r   r   Úcelery.platformsr   r   r	   r   r   r&   r0   ÚcommandÚoptionÚfloatÚpass_contextr@   r   r   r   r   Ú<module>   sh    

þ
üýü
üþú