U ÷Õ/eƒ ã@sDddlmZddlmZddlmZddlmZGdd„deƒZdS)é)Ú annotations)Ú key_split)ÚSchedulerPlugin)Úcolorsc@sZeZdZdZdd„Zdd„Zddd„Zdd d „Zdd d „Zdd d„Z ddd„Z dd„Z dS)ÚWebsocketPluginZ websocketcCs||_||_dS)N)ÚsocketÚ scheduler)Úselfrr©r úE/tmp/pip-unpacked-wheel-g426oqom/distributed/diagnostics/websocket.pyÚ__init__ szWebsocketPlugin.__init__cKs|j di¡dS)z&Run when the scheduler restarts itselfÚrestartN©rÚsend)r rÚkwargsr r r r szWebsocketPlugin.restartNcKs|j dd|i¡dS)z(Run when a new worker enters the clusterÚ add_workerÚworkerNr©r rrrr r r rszWebsocketPlugin.add_workercKs|j dd|i¡dS)z$Run when a worker leaves the clusterÚ remove_workerrNrrr r r rszWebsocketPlugin.remove_workercKs|j dd|i¡dS)zRun when a new client connectsÚ add_clientÚclientNr©r rrrr r r rszWebsocketPlugin.add_clientcKs|j dd|i¡dS)zRun when a client disconnectsÚ remove_clientrNrrr r r r!szWebsocketPlugin.remove_clientcKs|j dd|i¡dS)z0Run when a new graph / tasks enter the schedulerÚ update_graphrNrrr r r r%szWebsocketPlugin.update_graphc Osv||jjkrdS||d<| dg¡}|D]H}t|d}t|ƒtk rL||ƒ}|t|ƒ|dœ||–} |j d| ¡q(dS)a¨Run whenever a task changes state Parameters ---------- key : string start : string Start state of the transition. One of released, waiting, processing, memory, error. finish : string Final state of the transition. *args, **kwargs : More options passed when transitioning This may include worker ID, compute time, etc. NÚkeyÚ startstopsÚaction)rÚnameÚcolorÚ transition) rZtasksÚgetrÚtypeÚstrrrr) r rÚstartÚfinishÚargsrrZ startstoprÚdatar r r r)s     ýûzWebsocketPlugin.transition)NN)NN)NN)NN)N) Ú__name__Ú __module__Ú __qualname__rr r rrrrrrr r r r r s     rN) Ú __future__rZ dask.utilsrZdistributed.diagnostics.pluginrZ#distributed.diagnostics.task_streamrrr r r r Ús