
    `f
                        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Zd Z	 	 	 d%d
Zd Z ej        e           ej        ddedd           ej        dded           ej        ddedd           ej        dddeded           ej        dded           ej        ddd eedd!"          ej        e	d#                                                                                                             ZdS )&zThe ``celery events`` program.    N)partial)	LOG_LEVELCeleryDaemonCommandCeleryOptionhandle_preload_options)detachedset_process_titlestrargv c                     d                     d|           } | dt          t          j                   }t	          | |          S )Nz{}:{}zcelery events )info)formatr
   sysargvr	   )progr   s     C/var/www/html/env/lib/python3.11/site-packages/celery/bin/events.py_set_process_statusr      sE    >>/400D((WSX&&((DT----    c                 D    ddl m} t          d            ||           S )Nr   )evdumpdumpapp)celery.events.dumperr   r   )r   r   s     r   _run_evdumpr      s2    ++++++6c???r   Fc	                     ddl m}
 t          d           ||	d<   t          |
| f||d|	}|r8t	          ||||||          5   |            cd d d            S # 1 swxY w 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   s               r   
_run_evcamr*      s     -,,,,,F5M
% >!7> >6<> >C  gwS%AA 	 	355	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 suus   
AA Ac                     	 ddl m} t          d            ||           S # t          $ r*}|j        dk    rt          j        d          Y d }~d S d }~ww xY w)Nr   )evtoptopr   _cursesz/The curses module is required for this command.)celery.events.cursesmonr,   r   ModuleNotFoundErrornameclick
UsageError)r   r,   es      r   
_run_evtopr5   '   s    V111111E"""u~~~ V V V6Y"#TUUU Vs    # 
AAA)clsz-dz--dumpTDumper)r6   is_flag
help_groupz-cz--cameraSnapshot)r6   r9   z--detachz-Fz--frequencyz--freqg      ?)typedefaultr6   r9   z-rz	--maxratez-lz
--loglevelWARNINGzLogging level.)r<   r6   r;   r9   helpc           	          | j         j        }|rt          |          S |rt          |f|||||d|S t	          |          S )zEvent-stream utilities.)r   freqmaxrateloglevelr(   )objr   r   r*   r5   )	ctxr   r#   r(   	frequencyrA   rB   r)   r   s	            r   eventsrF   2   sn    D '+C  3 $& $c	7#+!'$ $ #$ $ 	$
 c??r   )r   )NNNNNNF)__doc__r   	functoolsr   r2   celery.bin.baser   r   r   r   celery.platformsr   r	   r
   r   r   r*   r5   commandoptionfloatpass_contextrF    r   r   <module>rP      s9   $ $ 



        ` ` ` ` ` ` ` ` ` ` ` ` A A A A A A A A A A. . . .   =A-1    V V V &'''d!	# # #
 d#% % % d#	% % %
 dM8#	% % %
 dK#% % % d##% % %    % %% %% %% %	% %# # ('@  r   