File: //home/arjun/projects/env/lib/python3.10/site-packages/flower/__pycache__/inspector.cpython-310.pyc
o
/we� � @ s@ d dl Z d dlZd dlZd dlmZ e�e�ZG dd� d�ZdS )� N)�partialc @ s2 e Zd ZdZdd� Zd dd�Zdd� Zd d
� ZdS ) � 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 �I/home/arjun/projects/env/lib/python3.10/site-packages/flower/inspector.py�__init__
s zInspector.__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
zInspector.inspectc C s" | j | }|||< t�� |d< d S )N� timestamp)r �time)r r r �response�infor r r �
_on_update s
zInspector._on_updatec C s� |r|gnd }| j jj| j|d�}t�d|� t�� }|dkr%t||�� nt||�dd�}t�d|t�� | � |d u s@d|v rHt�d|� d S |� � D ]\}}|d ur`| j
� t | j
|||�� qLd S ) N)r � destinationzSending %s inspect commandr T)�safez)Inspect command %s took %.2fs to complete�errorzInspect 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" �� ��zInspector._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