∋d U d dl mZ d dlZd dlmZ ej e Z d dlm Z G d de Z
n3# e $ r+ e d G d dej
Z
Y nw xY wd Zd
e
i fgZd ed < dS )
) annotationsN)web) ProxyHandlerc Z e Zd ZdZd
dZd Zd Zd Zd Zd Z d Z
d
Z d Z fd Z
xZS )GlobalProxyHandlerzx
A tornado request handler that proxies HTTP and websockets
from a port to any valid endpoint'.
Nc & || _ |pi | _ d S N) schedulerextraself dask_serverr s 6lib/python3.11/site-packages/distributed/http/proxy.py
initializez GlobalProxyHandler.initialize s (DN "DJJJ c " K || _ d| d| }|| j _ d|z }| j d| }t | j | s1d|z }| d | | d S | || d {V S )Nz/proxy//z/%s:zWorker <%s> does not existi )hostrequesturi check_worker_dashboard_exitsr
set_statusfinishproxy)r
portr proxied_pathr workermsgs r http_getzGlobalProxyHandler.http_get s DI 2D11<11C "DL !</L **D**F/GG
2V;$$$ C D,77777777 7r c @ K | ||| d {V S r )
proxy_open)r
r r r s r openzGlobalProxyHandler.open+ s. t\BBBBBBBB Br c . | || S r r r
r r s r postzGlobalProxyHandler.post/ ::dL11 1r c . | || S r r% r& s r putzGlobalProxyHandler.put2 r( r c . | || S r r% r& s r deletezGlobalProxyHandler.delete5 r( r c . | || S r r% r& s r headzGlobalProxyHandler.head8 r( r c . | || S r r% r& s r patchzGlobalProxyHandler.patch; r( r c . | || S r r% r& s r optionszGlobalProxyHandler.options> r( r c T t | j || S r )superr r )r
r r __class__s r r zGlobalProxyHandler.proxyA s! 77==D,?? ?r NN)__name__
__module__ __qualname____doc__r r r# r' r* r, r. r0 r2 r
__classcell__)r5 s @r r r s
% % % % 8 8 8* C C C 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 @ @ @ @ @ @ @ @ @r r zzTo route to workers diagnostics web server please install jupyter-server-proxy: python -m pip install jupyter-server-proxyc e Zd ZdZddZd ZdS )r z@Minimal Proxy handler when jupyter-server-proxy is not installedNc & || _ |pi | _ d S r )serverr r s r r z GlobalProxyHandler.initializeP s %DK "DJJJr c p | d| d| }d || }| | d S )Nr r a
Try navigating to {} for your worker dashboard
Dask tried to proxy you to that page through your
Scheduler's dashboard connection, but you don't have
jupyter-server-proxy installed. You may want to install it
with either conda or pip, and then restart your scheduler.
conda install jupyter-server-proxy -c conda-forge
python -m pip install jupyter-server-proxy
The link above should work though if your workers are on a
sufficiently open network. This is common on single machines,
but less common in production clusters. Your IT administrators
will know more
)formatwrite)r
r r r
worker_urlr s r getzGlobalProxyHandler.getT sS 88488,88J& '
.
JJsOOOOOr r6 )r7 r8 r9 r: r rC r r r r M s= NN % % % % r c | d \ }}t | j }|D ]>}|j dd }||j k r|t | k r dS ?dS )zCheck addr:port exists as a worker in scheduler list
Parameters
----------
worker : str
addr:port
Returns
-------
bool
r dashboard TF)splitlistworkersvaluesservicesrC r str)r
r addrr rJ w
bokeh_ports r r r p s c""JD$9$++--..G
Z^^K44
16>>dc*oo 5 544 5r zproxy/(\d+)/(.*?)/(.*)z list[tuple]routes)
__future__r loggingtornador getLoggerr7 logger jupyter_server_proxy.handlersr r ImportErrorinfoRequestHandlerr rQ __annotations__rD r r r\ s; " " " " " " " 8 $ $d ::::::8@ 8@ 8@ 8@ 8@\ 8@ 8@ 8@ 8@t ' ' '
KK 5 S / ' T * 23ErJK K K K K K Ks 8 -A('A(