
    h
                        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y)$zThe ``celery events`` program.    N)partial)	LOG_LEVELCeleryDaemonCommandCeleryOptionhandle_preload_options)detachedset_process_titlestrargvc                 |    dj                  d|       } | dt        t        j                         }t	        | |      S )Nz{}:{}zcelery events )info)formatr
   sysargvr	   )progr   s     M/var/www/Befach/backend/env/lib/python3.12/site-packages/celery/bin/events.py_set_process_statusr      s9    >>/40DV1WSXX&'(DT--    c                 6    ddl m} t        d        ||       S )Nr   )evdumpdumpapp)celery.events.dumperr   r   )r   r   s     r   _run_evdumpr      s    +c?r   c	                     ddl m}
 t        d       ||	d<   t        |
| f||d|	}|r!t	        ||||||      5   |       cd d d        S  |       S # 1 sw Y   y xY w)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)      sw     -F5M
% >!7>6<>C gwS%A 	5	 	 u	 	s   AAc                     	 ddl m} t        d        ||       S # t        $ r.}|j                  dk(  rt        j                  d      Y d }~y 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_evtopr4   '   sR    V1E"~ V66Y""#TUU Vs    	A$AA)clsz-dz--dumpTDumper)r5   is_flag
help_groupz-cz--cameraSnapshot)r5   r8   z--detachz-Fz--frequencyz--freqg      ?)typedefaultr5   r8   z-rz	--maxratez-lz
--loglevelWARNINGzLogging level.)r;   r5   r:   r8   helpc           	          | j                   j                  }|rt        |      S |rt        |f|||||d|S t	        |      S )zEvent-stream utilities.)r   freqmaxrateloglevelr'   )objr   r   r)   r4   )	ctxr   r"   r'   	frequencyr@   rA   r(   r   s	            r   eventsrE   2   sY    D ''++C3& $c	7#+!'$ #$ 	$
 c?r   ) )NNNNNNF)__doc__r   	functoolsr   r1   celery.bin.baser   r   r   r   celery.platformsr   r	   r
   r   r   r)   r4   commandoptionfloatpass_contextrE    r   r   <module>rP      sJ   $ 
   ` ` A A. =A-1 V &'d!	#
 d#% d#	%
 dM8#	%
 dK#% d##%   %%%%	%# (@r   