
    0Fieo                        U d dl mZ d dlmZ d dlmZ  G d de          Z G d de          Z G d d	e          Zd
ei fdei fdei fgZ	de
d<   dS )    )annotations)RequestHandler)
log_errorsc                      e Zd Zd ZdS )
CountsJSONc                D   | j         }d}d}d}d}d}d}d}d}	|                                }
|j                                        D ]7}|j        |dz  }n|j        dk    r|dz  }|j        r|dz  }|j        r|	dz  }	8|j                                        D ]D}||j	        z  }|t          |j                  z  }||j        z  }|t          |j                  z  }Ei d|dt          |j                  d|d|dt          |j                  d	t          |j                  d
|d|d|dt          |j                  dt          |j                  dt          |j                  d|d|	dt          |j                  d|
}|                     |           d S )Nr      releasedbytesclientscoreserredhostsidlememory
processing	saturatedtasks
unrunnablewaitingwaiting_dataworkersdesired_workers)serveradaptive_targetr   valuesexception_blamestate
waiting_onwaitersr   nthreadslenhas_whatnbytesr   r   	host_infor   r   r   write)self	schedulerr   r$   r!   r   r   r
   r   r   r   tswsresponses                 ?lib/python3.11/site-packages/distributed/http/scheduler/json.pygetzCountsJSON.get   s9   K	
#3355/((** 	" 	"B!-
Z''A} 1z "!#**,, 	- 	-B#Hc"+&&&FbiF#bm,,,JJ
V
s9,--
 X
 U	

 S,--
 C	''
 f
 *
 
 Y011
 S))
 #i233
 w
 L
 s9,--
  !
$ 	

8    N__name__
__module____qualname__r-    r.   r,   r   r      s#        - - - - -r.   r   c                      e Zd Zd ZdS )IdentityJSONc                ^    |                      | j                                                   d S )N)r&   r   identity)r'   s    r,   r-   zIdentityJSON.get9   s(    

4;''))*****r.   Nr/   r3   r.   r,   r5   r5   8   s#        + + + + +r.   r5   c                  $    e Zd Zed             ZdS )	IndexJSONc                T    d t           D             } | j        	 d|dd| j         d S )Nc                T    g | ]%\  }}}|                     d           |dd         &S )z.json   N)endswith).0url_s      r,   
<listcomp>z!IndexJSON.get.<locals>.<listcomp>@   s7    FFFaW0E0EFSWFFFr.   json-index.htmlzIndex of JSON routes)routestitle)rB   )rC   renderextra)r'   rs     r,   r-   zIndexJSON.get>   sR    FFfFFF	
&'/E	
 	
IM	
 	
 	
 	
 	
r.   N)r0   r1   r2   r   r-   r3   r.   r,   r9   r9   =   s-        
 
 Z
 
 
r.   r9   zjson/counts.jsonzjson/identity.jsonzjson/index.htmlzlist[tuple]rC   N)
__future__r   distributed.http.utilsr   distributed.utilsr   r   r5   r9   rC   __annotations__r3   r.   r,   <module>rL      s   " " " " " " " 1 1 1 1 1 1 ( ( ( ( ( (. . . . . . . .b+ + + + +> + + +

 
 
 
 
 
 
 
 *b)L"-B'      r.   