a
3`/b @ s U d dl mZ d dlZd dlmZ eeZz d dlm Z G dd de Z
W n. e yz e d G dd dej
Z
Y n0 d d
Zd e
i fgZd ed
< dS ) ) annotationsN)web) ProxyHandlerc sj e Zd ZdZdddZdd Zdd Zd d
Zd d Zd
d Z dd Z
dd Z dd Z fddZ
ZS )GlobalProxyHandlerzx
A tornado request handler that proxies HTTP and websockets
from a port to any valid endpoint'.
Nc C s || _ |p i | _d S N) schedulerextraselfZ dask_serverr r 5lib/python3.9/site-packages/distributed/http/proxy.py
initialize s GlobalProxyHandler.initializec st || _ d| d| }|| j_d| }| j d| }t| j|sbd| }| d | | d S | ||I d H S )Nz/proxy//z/%s:zWorker <%s> does not existi )hostZrequesturi check_worker_dashboard_exitsr Z
set_statusZfinishproxy)r
portr proxied_pathr workermsgr r r http_get s
zGlobalProxyHandler.http_getc s | |||I d H S r )Z
proxy_open)r
r r r r r r open+ s zGlobalProxyHandler.openc C s | ||S r r r
r r r r r post/ s zGlobalProxyHandler.postc C s | ||S r r r r r r put2 s zGlobalProxyHandler.putc C s | ||S r r r r r r delete5 s zGlobalProxyHandler.deletec C s | ||S r r r r r r head8 s zGlobalProxyHandler.headc C s | ||S r r r r r r patch; s zGlobalProxyHandler.patchc C s | ||S r r r r r r options> s zGlobalProxyHandler.optionsc s t | j||S r )superr r r __class__r r r A s zGlobalProxyHandler.proxy)NN)__name__
__module__ __qualname____doc__r
r r r r r r r! r" r
__classcell__r r r$ r r s
r zzTo route to workers diagnostics web server please install jupyter-server-proxy: python -m pip install jupyter-server-proxyc @ s" e Zd ZdZdddZdd ZdS )r z@Minimal Proxy handler when jupyter-server-proxy is not installedNc C s || _ |p i | _d S r )Zserverr r r r r r
P s r c C s. | 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 Z
worker_urlr r r r getT s zGlobalProxyHandler.get)NN)r& r' r( r) r
r- r r r r r M s
c C sT | d\}}t| j }|D ].}|jdd}||jkr |t|kr dS q dS )zCheck addr:port exists as a worker in scheduler list
Parameters
----------
worker : str
addr:port
Returns
-------
bool
r Z dashboard TF)splitlistworkersvaluesZservicesr- r str)r r Zaddrr r1 wZ
bokeh_portr r r r p s r zproxy/(\d+)/(.*?)/(.*)z list[tuple]routes)Z
__future__r loggingZtornador Z getLoggerr& loggerZ jupyter_server_proxy.handlersr r ImportErrorinfoZRequestHandlerr r5 __annotations__r r r r s
: #