ó ù2¢\c@sFdZddlmZddlmZmZddlmZddlZddlm Z m Z ddl m Z ddl mZmZdd lmZdd lmZdd lmZmZmZmZmZmZmZmZmZmZmZdd l m!Z!m"Z"dd l#m$Z$m%Z%ddl&m'Z'defd„ƒYZ(dS(sfA MultiKernelManager for use in the notebook webserver - raises HTTPErrors - creates REST API models iÿÿÿÿ(t defaultdict(tdatetimet timedelta(tpartialN(tgentweb(tFuture(tIOLooptPeriodicCallback(tSession(tMultiKernelManager( tAnytBooltDicttListtUnicodet TraitErrortIntegertFloattInstancetdefaulttvalidate(t to_os_pathtexists(tutcnowt isoformat(tgetcwdtMappingKernelManagercBseZdZedƒd„ƒZeeƒƒZedeƒZ e ƒZ d&Z eZedƒd„ƒZedƒd„ƒZeddedd ƒZd Zeededd ƒZeededd ƒZeededd ƒZeededdƒZeddeddƒZeƒZedƒd„ƒZe e!ddƒZ"d„Z#d„Z$d„Z%e&j'd&d&d„ƒZ(d„Z)d„Z*d„Z+ed„Z,e&j'd„ƒZ-d„Z.d„Z/d„Z0d „Z1d!„Z2d"„Z3d#„Z4d$„Z5d%„Z6RS('sEA KernelManager that handles notebook mapping and HTTP error handlingtkernel_manager_classcCsdS(Ns)jupyter_client.ioloop.IOLoopKernelManager((tself((sFlib/python2.7/site-packages/notebook/services/kernels/kernelmanager.pyt_default_kernel_manager_class!stconfigtroot_dircCs*y|jjSWntk r%tƒSXdS(N(tparentt notebook_dirtAttributeErrorR(R((sFlib/python2.7/site-packages/notebook/services/kernels/kernelmanager.pyt_default_root_dir/s cCsh|d}tjj|ƒs1tjj|ƒ}nt|ƒ sQtjj|ƒ rdtd|ƒ‚n|S(s'Do a bit of validation of the root dir.tvalues%kernel root dir %r is not a directory(tostpathtisabstabspathRtisdirR(RtproposalR%((sFlib/python2.7/site-packages/notebook/services/kernels/kernelmanager.pyt_update_root_dir6s   ithelpsêTimeout (in seconds) after which a kernel is considered idle and ready to be culled. Values of 0 or lower disable culling. Very short timeouts may result in kernels being culled for users with poor network connections.i,s^The interval (in seconds) on which to check for idle kernels exceeding the cull timeout value.sxWhether to consider culling kernels which have one or more connections. Only effective if cull_idle_timeout > 0.sdWhether to consider culling kernels which are busy. Only effective if cull_idle_timeout > 0.seWhether messages from kernels whose frontends have disconnected should be buffered in-memory. When True (default), messages are buffered and replayed on reconnect, avoiding lost messages due to interrupted connectivity. Disable if long-running kernels will produce too much output while no frontends are connected. i<sÂTimeout for giving up on a kernel (in seconds). On starting and restarting kernels, we check whether the kernel is running and responsive by sending kernel_info_requests. This sets the timeout in seconds for how long the kernel can take before being presumed dead. This affects the MappingKernelManager (which handles kernel restarts) and the ZMQChannelsHandler (which handles the startup). t_kernel_bufferscCs td„ƒS(NcSsigd6dd6id6S(Ntbuffertt session_keytchannels((((sFlib/python2.7/site-packages/notebook/services/kernels/kernelmanager.pytpR0(R(R((sFlib/python2.7/site-packages/notebook/services/kernels/kernelmanager.pyt_default_kernel_buffersnssAThe last activity on any kernel, including shutting down a kernelcKs&tt|ƒj|tƒ|_dS(N(tsuperRt__init__Rtlast_kernel_activity(Rtkwargs((sFlib/python2.7/site-packages/notebook/services/kernels/kernelmanager.pyR6uscCs$|jjd|ƒ|j|ƒdS(snotice that a kernel dieds"Kernel %s died, removing from map.N(tlogtwarningt remove_kernel(Rt kernel_id((sFlib/python2.7/site-packages/notebook/services/kernels/kernelmanager.pyt_handle_kernel_died}scCsQt||jƒ}x8tjj|ƒ rL||jkrLtjj|ƒ}qW|S(s$Turn API path into absolute OS path.(RR R&R'R*tdirname(RR'tos_path((sFlib/python2.7/site-packages/notebook/services/kernels/kernelmanager.pyt cwd_for_path‚s%c+sþˆdkr´|dk r.ˆj|ƒ|d|djƒD],}|jƒsV|jdƒ|j ƒqVqVW|d}|r¹|jj dt |ƒ|dƒndS(sšStop buffering kernel messages Parameters ---------- kernel_id : str The id of the kernel to stop buffering. sClearing buffer for %sNR2R/s&Discarding %s buffered messages for %sR1( R9RIRKR.R[tvaluestclosedRXRCRVRHtlen(RR<RRRYt msg_buffer((sFlib/python2.7/site-packages/notebook/services/kernels/kernelmanager.pyRWös     cCs„|j|ƒ|j|}|jr<|jjƒd|_n|j|ƒ|jj|dƒtƒ|_ t t |ƒj |d|ƒS(sShutdown a kernel by kernel_idtnowN( RKt_kernelst_activity_streamRVRCRWRFR[RR7R5Rtshutdown_kernel(RR<Ratkernel((sFlib/python2.7/site-packages/notebook/services/kernels/kernelmanager.pyRds       c#sˆjˆƒtjttˆƒjˆƒƒVˆjˆƒ‰ˆjƒ‰tƒ‰‡‡‡‡‡fd†‰‡‡‡‡fd†}‡‡‡‡fd†}‡‡‡‡fd†‰ˆj ˆdƒˆj j ˆdƒˆj |ƒt jƒ‰ˆjˆjƒˆj|ƒ‰ˆVdS(sRestart a kernel by kernel_idcs:ˆjƒsˆjƒnˆjˆƒˆjˆdƒdS(s:Common cleanup when restart finishes/fails for any reason.RBN(R^RVtremove_timeouttremove_restart_callback((RPRetloopton_restart_failedttimeout(sFlib/python2.7/site-packages/notebook/services/kernels/kernelmanager.pytfinish%s   cs:ˆjjdˆƒˆƒˆjƒs6ˆj|ƒndS(NsKernel info reply received: %s(R9RItdonet set_result(tmsg(RktfutureR<R(sFlib/python2.7/site-packages/notebook/services/kernels/kernelmanager.pyton_reply,s csCˆjjdˆƒˆƒˆjƒs?ˆjtjdƒƒndS(Ns)Timeout waiting for kernel_info_reply: %ssTimeout waiting for restart(R9R:Rlt set_exceptionRt TimeoutError((RkRoR<R(sFlib/python2.7/site-packages/notebook/services/kernels/kernelmanager.pyt on_timeout2s cs@ˆjjdˆƒˆƒˆjƒs<ˆjtdƒƒndS(NsRestarting kernel failed: %ssRestart failed(R9R:RlRqt RuntimeError((RkRoR<R(sFlib/python2.7/site-packages/notebook/services/kernels/kernelmanager.pyRi8s RBtkernel_info_requestN(RKRRDR5Rtrestart_kernelt get_kernelt connect_shellRRJtsessiontsendRXRtcurrentt add_timeoutttimetkernel_info_timeout(RR<RpRs(( RPRkRoReR<RhRiRRjsFlib/python2.7/site-packages/notebook/services/kernels/kernelmanager.pyRvs      cCs)||jkr%|j|cd7 %s seconds at %s second intervals ...sCulling kernels even if busys+Culling kernels even with connected clientsN(RLtcull_idle_timeoutt_culler_callbackRCRR{t cull_intervalR9R:tcull_interval_defaultRt cull_kernelsRHt cull_busytcull_connectedtstarttTrue(RRh((sFlib/python2.7/site-packages/notebook/services/kernels/kernelmanager.pyRMs"     cCsw|jjd|j|jƒxTt|jƒD]C}y|j|ƒWq,tk rn}|jjd||ƒq,Xq,WdS(Ns9Polling every %s seconds for kernels idle > %s seconds...sYThe following exception was encountered while checking the idle duration of kernel %s: %s( R9RIRR›tlistRbtcull_kernel_if_idlet Exceptiont exception(RR<te((sFlib/python2.7/site-packages/notebook/services/kernels/kernelmanager.pyRŸ¨s  c Cs|j|}|jjd||j|jƒ|jdk rtƒ}||j}|td|jƒk}|j p~|j dk}|j j |dƒ}|j p£| }|r|r|rt|jƒƒ} |jjd|j |j||| ƒ|j|ƒqndS(Ns.kernel_id=%s, kernel_name=%s, last_activity=%stsecondstbusyisRCulling '%s' kernel '%s' (%s) with %d connections due to %s seconds of inactivity.(RbR9RIR†RƒRCRRR›R R„RFtgetR¡tintt total_secondsR:Rd( RR<Retdt_nowtdt_idlet is_idle_timetis_idle_executeR…tis_idle_connectedt idle_duration((sFlib/python2.7/site-packages/notebook/services/kernels/kernelmanager.pyR¥³s    N(7t__name__t __module__t__doc__RRRRt kernel_argvR£R R RFRCRœtFalseRLR$RR,RR›RžRR R¡R RTRR~R R.R4RRR7R6R=R@Rt coroutineRERZR\RWRdRvRR€RˆRŒRKRGRMRŸR¥(((sFlib/python2.7/site-packages/notebook/services/kernels/kernelmanager.pyRsZ              * '   +       ()R¶t collectionsRRRt functoolsRR&ttornadoRRttornado.concurrentRttornado.ioloopRRtjupyter_client.sessionR t!jupyter_client.multikernelmanagerR t traitletsR R R RRRRRRRRtnotebook.utilsRRt notebook._tzRRtipython_genutils.py3compatRR(((sFlib/python2.7/site-packages/notebook/services/kernels/kernelmanager.pyts L