o
    ȕh                     @   s@   d dl Z d dlZd dlZd dlmZ eeZG dd dZdS )    N)partialc                   @   s2   e Zd ZdZdd ZdddZdd Zd	d
 ZdS )	Inspector)statsactive_queues
registered	scheduledactivereservedrevokedconfc                 C   s"   || _ || _|| _tt| _d S N)io_loopcapptimeoutcollectionsdefaultdictdictworkers)selfr   r   r    r   M/var/www/Befach/backend/venv/lib/python3.10/site-packages/flower/inspector.py__init__   s   zInspector.__init__Nc              
   C   s2   g }| j D ]}|| jd t| j|| q|S r   )methodsappendr   run_in_executorr   _inspect)r   
workernamefeuturesmethodr   r   r   inspect   s   
 zInspector.inspectc                 C   s"   | j | }|||< t |d< d S )N	timestamp)r   time)r   r   r   responseinfor   r   r   
_on_update   s   
zInspector._on_updatec           	      C   s   |r|gnd }| j jj| j|d}td| t }|dkr%t|| nt||dd}td|t |  |d u s@d|v rHtd| d S |	 D ]\}}|d ur`| j
t| j||| qLd S )	N)r   destinationzSending %s inspect commandr   T)safez)Inspect command %s took %.2fs to completeerrorzInspect method %s failed)r   controlr   r   loggerdebugr!   getattrwarningitemsr   add_callbackr   r$   )	r   r   r   r%   r   startresultworkerr"   r   r   r   r      s"   zInspector._inspectr   )__name__
__module____qualname__r   r   r   r$   r   r   r   r   r   r   	   s    
r   )	r   loggingr!   	functoolsr   	getLoggerr2   r)   r   r   r   r   r   <module>   s    
