U ÷Õ/eoã@s~UddlmZddlmZddlmZGdd„deƒZGdd„deƒZGdd „d eƒZd eifd eifd eifgZ d e d<dS)é)Ú annotations)ÚRequestHandler)Ú log_errorsc@seZdZdd„ZdS)Ú CountsJSONcCs|j}d}d}d}d}d}d}d}d} | ¡} |j ¡D]F} | jdk rP|d7}n| jdkrb|d7}| jrp|d7}| jr8| d7} q8|j ¡D]4} || j 7}|t | j ƒ7}|| j 7}|t | j ƒ7}qŠ|t |jƒ||t |jƒt |jƒ|||t |jƒt |jƒt |jƒ|| t |jƒ| dœ} | | ¡dS)NréÚreleased)ÚbytesÚclientsZcoresÚerredÚhostsÚidleÚmemoryÚ processingrÚ saturatedÚtasksÚ unrunnableÚwaitingÚ waiting_dataÚworkersÚdesired_workers)ÚserverZadaptive_targetrÚvaluesZexception_blameÚstateZ waiting_onÚwaitersrÚnthreadsÚlenZhas_whatÚnbytesrr Z host_infor rrÚwrite)ÚselfZ schedulerr rrr rrrrrÚtsÚwsÚresponse©r"úC/tmp/pip-unpacked-wheel-g426oqom/distributed/http/scheduler/json.pyÚgetsT      ðzCountsJSON.getN©Ú__name__Ú __module__Ú __qualname__r$r"r"r"r#rsrc@seZdZdd„ZdS)Ú IdentityJSONcCs| |j ¡¡dS)N)rrÚidentity)rr"r"r#r$9szIdentityJSON.getNr%r"r"r"r#r)8sr)c@seZdZedd„ƒZdS)Ú IndexJSONcCs*dd„tDƒ}|jd|ddœ|j—ŽdS)NcSs(g|] \}}}| d¡r|dd…‘qS)z.jsonéN)Úendswith)Ú.0ÚurlÚ_r"r"r#Ú @s z!IndexJSON.get..újson-index.htmlzIndex of JSON routes)ÚroutesÚtitle)r2)r3ÚrenderÚextra)rÚrr"r"r#r$>sÿÿÿz IndexJSON.getN)r&r'r(rr$r"r"r"r#r+=sr+zjson/counts.jsonzjson/identity.jsonzjson/index.htmlz list[tuple]r3N) Ú __future__rZdistributed.http.utilsrZdistributed.utilsrrr)r+r3Ú__annotations__r"r"r"r#Ús   1 ý