o
    Df
                     @   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   J/home/ubuntu/webapp/venv/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    



