fIX*dZddlmZddlZddlZddlZddlZddlZddl Z ddl m Z ddl m Z ddlZddlmZmZmZmZmZmZmZmZddlmZddlmZd d lmZd d lmZm Z d d l!m"Z"d d l#m$Z$m%Z%m&Z&Gdde'Z(ddZ)GddeZ*Gdde*Z+y)z%A kernel manager for multiple kernels) annotationsNwraps)Path)AnyBoolDictDottedObjectNameInstanceUnicodedefaultobserve)LoggingConfigurable) import_item)KernelConnectionInfo)NATIVE_KERNEL_NAMEKernelSpecManager) KernelManager) ensure_asyncrun_syncutcnowc eZdZy)DuplicateKernelErrorN)__name__ __module__ __qualname__\/var/www/cvtools/html/venv/lib/python3.12/site-packages/jupyter_client/multikernelmanager.pyrrsrrcDt dfd }|S)zDdecorator for proxying MKM.method(kernel_id) to individual KMs by IDc|j|}t|j}||i|}||g|i||SN) get_kernelgetattrr)self kernel_idargskwargskmmethodrfs r wrappedzkernel_method..wrapped!sM __Y 'QZZ( D #F # $ +D+F+r) r&t.Anyr'strr(r/r)r/returnzt.Callable | t.Awaitabler)r-r.s` r kernel_methodr2sJ 1X   # ,1 =B  !   Nrc@eZdZdZeedj dZee dZ e ddj dZ e d d8d Zed Zed d9d Zd9dZeddj dZedZedZeZed:dZedd;dZedZeddZeZd<fd Z d=fd Z!d>dZ"d?dZ#d@dZ$ dAdZ%dBdZ& dCdZ' dDdZ(dEd Z)dd!dFd"Z*e+e*Z, dG dHd#Z-e+e-Z.e/dIdJd$Z0e/ dK dLd%Z1e/dIdMd&Z2dNd'Z3dIdOd(Z4e+e4Z5dPd)Z6e/dQd*Z7dIdRd+Z8e+e8Z9e/d@d,Z:dPd-Z;dNd.Ze/dUd1Z?e/ dV dWd2Z@e/ dV dWd3ZAe/ dV dWd4ZBe/ dV dWd5ZCe/ dV dWd6ZDdXd7ZExZFS)YMultiKernelManagerz&A class for managing multiple kernels.z'The name of the default kernel to starthelpTconfig) allow_nonez)jupyter_client.ioloop.IOLoopKernelManagerzThe kernel manager class. This is configurable to allow subclassing of the KernelManager for customized behavior. kernel_manager_classc.|j|_yr#)_create_kernel_manager_factorykernel_manager_factory)r&changes r _kernel_manager_class_changedz0MultiKernelManager._kernel_manager_class_changedCs&*&I&I&K#rz)this is kernel_manager_class after importr=c"|jSr#)r<r&s r _kernel_manager_factory_defaultz2MultiKernelManager._kernel_manager_factory_defaultIs2244rcBtjdfd }|S)NcjrGjjrj_|j dj|i|}|S)Ncontext)shared_contextrEclosed_context_default setdefault)r(r)r*kernel_manager_ctorr&s r create_kernel_managerzPMultiKernelManager._create_kernel_manager_factory..create_kernel_managerPsQ""<<&&#'#8#8#:DL!!)T\\:$d5f5BIr)r(r/r)r/r1r)rr:)r&rKrJs` @r r<z1MultiKernelManager._create_kernel_manager_factoryMs!)$*C*CD %$rz4Share a single zmq.Context to talk to all my kernels zmq.ContextFc|jS)z#A shim for backwards compatibility.)_pending_kernelsrAs r _starting_kernelsz$MultiKernelManager._starting_kernelsfs$$$rrEc8d|_tjSNT)_created_contextzmqContextrAs r rHz#MultiKernelManager._context_defaultks ${{}rNc2t||i|i|_yr#)super__init__kernel_id_to_connection_file)r&r(r) __class__s r rXzMultiKernelManager.__init__us $)&)=?)rc(|jrd|jrX|jjsB|jr|jj d||jj  t |}|y#t$rYywxYw)z:Handle garbage collection. Destroy context if applicable.zDestroying zmq context for %sN) rRrErGlogdebugdestroyrW__del__AttributeError)r& super_delrZs r r_zMultiKernelManager.__del__ysq  T\\$,,:M:Mxx>E LL " I K   s3 B BBc|j t|j}|jr|jDcgc]}|j s|}}t |j j}t |j j}t |j jD]5}||vs||j|}|j |=|j|=7|D]}||j jvr! tj|j}|jj!d|d|vrd|vsj|j#}||j |<|j%||jd} | j'|t)| _d| _d| _|| _|d| _| j4j7d| |j|<t |jjScc}w#t$rYGwxYw) z6Return a list of the kernel ids of the active kernels.NzLoading connection file %s kernel_namekeyF)parentr\ owns_kernelidler)external_connection_dirris_diriterdiris_filelistrYkeysvaluesindex_kernelsjsonloads read_text Exceptionr\r] new_kernel_idr=load_connection_infor last_activityexecution_state connectionsr'rcready set_result) r&rhpconnection_fileskvconnection_filer'connection_infor*s r list_kernel_idsz"MultiKernelManager.list_kernel_idss%  ' ' 3&*4+G+G&H #&--//F/N/N/P#`!TUT]T]T_A#` #`::??AB::AACD'+D,M,M,T,T,V'W5O&.>>$%aggo&>$?  ==iH MM)4 5(82O&$*K*K*R*R*TT !@D +557A HHNN#?Q)_</AY $ 2 2 4ICRD55i@44# HH$)5B ++O<'-xB$)/B&%&BN#,BL%4]%CBNHH''-/1DMM),92@DMM&&())Y$a&%! !sH;H;'#I I  I c4t|jS)z%Return the number of running kernels.)lenrrAs r __len__zMultiKernelManager.__len__s4'')**rc||jvSr#)rpr&r's r __contains__zMultiKernelManager.__contains__sDMM))rcb|jd|jdi|}||vrtd|z| |j}i}|jr|j|d<|j dt jj|jd|z||j|d|}|||fS)Nr'zKernel already exists: %skernel_spec_managerzkernel-%s.json)rrer\rcr) poprurdefault_kernel_namerr=ospathjoinconnection_dirr\)r&rcr)r'constructor_kwargsr*s r pre_start_kernelz#MultiKernelManager.pre_start_kernelsJJ{,>D,>,>,H,HI  &'BY'NO O  22K   # #8<8P8P 4 5 (T ( ( GGLL)<)<>NQZ>Z[#  !  ; ))rcL||vr |j|j|yy)z Allow to update the environment of the given kernel. Forward the update env request to the corresponding kernel. .. version-added: 8.5 )envN)rp update_env)r&r'rs r rzMultiKernelManager.update_envs+   MM) $ / /C / 8 rcK |d{||j|<|jj|dy70#t$r%}|jj |Yd}~yd}~wwxYwwr#)rprNrrtr\ exception)r&r'r*kernel_awaitablees r _add_kernel_when_readyz)MultiKernelManager._add_kernel_when_readysc "" " "')DMM) $  ! ! % %i 6 # " HH  q ! ! "s7A-<:/<A-< A*A% A-%A**A-cK |d{|j||jj|dy72#t$r%}|jj |Yd}~yd}~wwxYwwr#) remove_kernelrNrrtr\r)r&r'rrs r _remove_kernel_when_readyz,MultiKernelManager._remove_kernel_when_readysc "" " "   y )  ! ! % %i 6 # " HH  q ! ! "s7A/><1>A/> A,A'"A/'A,,A/ct|ddS)zReturns a boolean; a clearer method for determining if this multikernelmanager is using pending kernels or not use_pending_kernelsF)r%rAs r _using_pending_kernelsz)MultiKernelManager._using_pending_kernelsst2E::r)rccDK|j||\}}}t|ts?|jj dj |j j||d<t|jdi|}tj|j|||}||j|<|jr||j|<|S|d{|j j#r|j j#|S7:w)zStart a new kernel. The caller can pick a kernel_id by passing one in as a keyword arg, otherwise one will be generated using new_kernel_id(). The kernel ID for the newly started kernel is returned. zHKernel manager class ({km_class}) is not an instance of 'KernelManager'!)km_classr'Nr)r isinstancerr\warningformatr:rZr start_kernelasyncio create_taskrrNrrprzr)r&rcr)r*r'startertasks r _async_start_kernelz&MultiKernelManager._async_start_kernels&*%:%:;%O"K"m, HH  Zaa!66@@b  ({r889""4#>#>y"g#VW+/i(  & & ((*DMM) $ JJxx!!#hh((** sC!D #D$;D cK|jjd|||jvra|j|} |d{|j|}t j t j|jd{|j|}|jjs,|jjr|j|yt|j||}t j |j#||}||j|<|j%s?|d{|jjr|jjyy7B7#t j$rYt$r|j|YywxYw7tw)a3Shutdown a kernel by its kernel uuid. Parameters ========== kernel_id : uuid The id of the kernel to shutdown. now : bool Should the kernel be shutdown forcibly using a signal. restart : bool Will the kernel be restarted? Kernel shutdown: %sN)r\inforNr$tcastrFuturerzCancelledErrorrtr cancelledrrshutdown_kernel ensure_futurerr)r&r'nowrestartrr*stopperfuts r _async_shutdown_kernelz)MultiKernelManager._async_shutdown_kernel!sr"  +Y7 -- -((3D  __Y/ffW^^RXX666 __Y 'xx!!#(:(:(<   y ) r11#w?@##D$B$B9g$VW+.i(**,IIxx!!#hh((**$-#6))  ""9-  sf:GF FAF F F B;G F> :GF F F;GF;8G:F;;Gcy)z,Ask a kernel to shut down by its kernel uuidNrr&r'rs r request_shutdownz#MultiKernelManager.request_shutdownPrc<|jjd|y)zDWait for a kernel to finish shutting down, and kill it if it doesn'trNr\r)r&r'waittime pollintervals r finish_shutdownz"MultiKernelManager.finish_shutdownTs  +Y7rcy)zClean up a kernel's resourcesNrrs r cleanup_resourcesz$MultiKernelManager.cleanup_resources^rrc:|jj|dS)zremove a kernel from our mapping. Mainly so that a kernel can be removed if it is already dead, without having to call shutdown_kernel. The kernel object is returned, or `None` if not found. N)rprrs r rz MultiKernelManager.remove_kernelbs}}  D11rc(K|j}|t|jz }t|jj }t |Dcgc]}|j ||}}tj|d{|jr|D]} |jd{yycc}w777#tj$r*|j|jjYat$rYkwxYww)zShutdown all kernels.rN)rrlrNrprnsetrrgatherrrzrr'cancelrt)r&rkidskmskidfutsr*s r _async_shutdown_allz&MultiKernelManager._async_shutdown_allls##% T**++4=='')*EHYOc++CS+9OOnnd###  & & ( ((NN  )P# #--A))",,7>>@ s`ADB?5D C D'C6C7C; DC:DDD DDDc|j|}|jjs d}t||j }|j j d||S)zInterrupt (SIGINT) the kernel by its uuid. Parameters ========== kernel_id : uuid The id of the kernel to interrupt. z/Kernel is in a pending state. Cannot interrupt.zKernel interrupted: %s)r$rzdone RuntimeErrorinterrupt_kernelr\r)r&r'kernelmsgouts r rz#MultiKernelManager.interrupt_kernelsX+||  "CCs# #%%'  . : rc>|jjd||y)aRSends a signal to the kernel by its uuid. Note that since only SIGTERM is supported on Windows, this function is only useful on Unix systems. Parameters ========== kernel_id : uuid The id of the kernel to signal. signum : int Signal number to send kernel. zSignaled Kernel %s with %sNr)r&r'signums r signal_kernelz MultiKernelManager.signal_kernels  2IvFrcK|j|}|jr'|jjs d}t |t |j |d{|jjd|y7!w)aERestart a kernel by its uuid, keeping the same ports. Parameters ========== kernel_id : uuid The id of the kernel to interrupt. now : bool, optional If True, the kernel is forcefully restarted *immediately*, without having a chance to do any cleanup action. Otherwise the kernel is given 1s to clean up before a forceful restart is issued. In all cases the kernel is restarted, the only difference is whether it is given a chance to perform a clean shutdown or not. z-Kernel is in a pending state. Cannot restart.rNzKernel restarted: %s) r$rrzrrrrestart_kernelr\r)r&r'rrrs r _async_restart_kernelz(MultiKernelManager._async_restart_kernelsu+  & & (1B1B1DACs# #600S09:::  ,i8 ;sA'B )B *"B cy)zIs the kernel alive. This calls KernelManager.is_alive() which calls Popen.poll on the actual kernel subprocess. Parameters ========== kernel_id : uuid The id of the kernel. Nrrs r is_alivezMultiKernelManager.is_aliverrc(||vrtd|zy)zcheck that a kernel id is validzKernel with id not found: %sN)KeyErrorrs r _check_kernel_idz#MultiKernelManager._check_kernel_ids D 9IEF F !rcB|j||j|S)zGet the single KernelManager object for a kernel by its uuid. Parameters ========== kernel_id : uuid The id of the kernel. )rrprs r r$zMultiKernelManager.get_kernels! i(}}Y''rcy)z&add a callback for the KernelRestarterNrr&r'callbackevents r add_restart_callbackz'MultiKernelManager.add_restart_callbackrrcy)z)remove a callback for the KernelRestarterNrrs r remove_restart_callbackz*MultiKernelManager.remove_restart_callbackrrcy)aReturn a dictionary of connection data for a kernel. Parameters ========== kernel_id : uuid The id of the kernel. Returns ======= connection_dict : dict A dict of the information needed to connect to a kernel. This includes the ip address and the integer port numbers of the different channels (stdin_port, iopub_port, shell_port, hb_port). Nrrs r get_connection_infoz&MultiKernelManager.get_connection_inforrcy)a6Return a zmq Socket connected to the iopub channel. Parameters ========== kernel_id : uuid The id of the kernel identity : bytes (optional) The zmq identity of the socket Returns ======= stream : zmq Socket or ZMQStream Nrr&r'identitys r connect_iopubz MultiKernelManager.connect_iopubrrcy)a6Return a zmq Socket connected to the shell channel. Parameters ========== kernel_id : uuid The id of the kernel identity : bytes (optional) The zmq identity of the socket Returns ======= stream : zmq Socket or ZMQStream Nrrs r connect_shellz MultiKernelManager.connect_shellrrcy)a8Return a zmq Socket connected to the control channel. Parameters ========== kernel_id : uuid The id of the kernel identity : bytes (optional) The zmq identity of the socket Returns ======= stream : zmq Socket or ZMQStream Nrrs r connect_controlz"MultiKernelManager.connect_controlrrcy)a6Return a zmq Socket connected to the stdin channel. Parameters ========== kernel_id : uuid The id of the kernel identity : bytes (optional) The zmq identity of the socket Returns ======= stream : zmq Socket or ZMQStream Nrrs r connect_stdinz MultiKernelManager.connect_stdin)rrcy)a3Return a zmq Socket connected to the hb channel. Parameters ========== kernel_id : uuid The id of the kernel identity : bytes (optional) The zmq identity of the socket Returns ======= stream : zmq Socket or ZMQStream Nrrs r connect_hbzMultiKernelManager.connect_hb;rrc <ttjS)z Returns the id to associate with the kernel for this request. Subclasses may override this method to substitute other sources of kernel ids. :param kwargs: :return: string-ized version 4 uuid )r0uuiduuid4)r&r)s r ruz MultiKernelManager.new_kernel_idMs4::<  r)r>r/r1None)r1 t.Callable)r1dict)r1rL)r(r/r)r/r1r)r1r)r1z list[str])r1int)r'r0r1bool)rc str | Noner)r/r1ztuple[KernelManager, str, str])r'r0rzt.Dict[str, str]r1r)r'r0r*rr t.Awaitabler1r)r'r0rrr1r)r1r)rcrr)r/r1r0)FF)r'r0r bool | Nonerrr1r)F)r'r0rrr1r)Ng?)r'r0r float | Nonerrr1r)r'r0rrr1r)r'r0r1r)rrr1r)r'r0r1r)r'r0rrr1r)r'r0rrr1r)r)r'r0rrrr0r1r)r'r0r1zdict[str, t.Any]r#)r'r0rz bytes | Noner1z socket.socket)r)r/r1r0)Grrr__doc__r rtagrr rrr r:rr?rr=r rBr<rrFrErRr rNpropertyrOrHrrhrprXr_rrrrrrrrrrrrrr2rrrrr shutdown_allrrrrrrr$rrrrrrrrru __classcell__)rZs@r r4r43sD0!!J cc##4F+3   cc  #$L%L!&QR %&5'5 % C cc }%GE{v %% YR[N%dt<vH@ 1*f+**%*/4* '*2 9"""/"CN" """0;" "; FJB/0L !$ ++++++ ++  ++Z56O;;"&%( 888# 8  88,,2$/0L  G G9,34N    G (AJ55(25;>5 55 AJ88(28;>8 88   "7;  (4   "7;  (4   "7;  (4   "7;  (4   "7;  (4   "!rr4ceZdZUedddZeddj dZed Z e d dd Z e jZd ed <e j Zd ed<e j$Zd ed<e j(Zd ed<y)AsyncMultiKernelManagerz.jupyter_client.ioloop.AsyncIOLoopKernelManagerTzThe kernel manager class. This is configurable to allow subclassing of the AsyncKernelManager for customized behavior. )r8r6FzWhether to make kernels available before the process has started. The kernel has a `.ready` future which can be awaited before connectingr5r7zmq.asyncio.ContextrEcLd|_tjjSrQ)rRrSrrTrAs r rHz(AsyncMultiKernelManager._context_defaulths ${{""$$rzt.Callable[..., t.Awaitable]rrrrN)r1r )rrrr r:rrrr rEr rHr4rr__annotations__rrrrrrrrr r r Ws+8  O cc  ,-G Y%%2D1W1WL.W3E3[3[N0[4F4]4]O1]1C1W1WL.Wrr )r-rr1r),r __future__rrrqrsockettypingrr functoolsrpathlibrrS traitletsrrr r r r r rtraitlets.config.configurablertraitlets.utils.importstringrconnectr kernelspecrrmanagerrutilsrrrrtrr2r4r rrr rsv+#   \\\=4)="11 9 *a!,a!HX0Xr