URU5n[UTR5nU"U0UD6nT"X/UQ70UD6 U$N) get_kernelgetattrr)self kernel_idargskwargskmmethodrfs r#wrappedkernel_method..wrapped!sK __Y 'QZZ( D #F # $+D+F+r") r)t.Anyr*strr+r3r,r3returnzt.Callable | t.Awaitabler)r0r1s` r# kernel_methodr6sJ 1X   # ,1 =B  !   Nr"c|^\rSrSrSr\"\SS9RSS9r\ "\ SS9r \ "SS S9RSS9r \"S 5S:S j5r\"S S9r\"S 5S;Sj5rS;Sjr\"SSS9RSS9r\ "S5r\"S5r\"5r\SU4Sjjr!S?U4Sjjr"S@Sjr#SASjr$SBSjr%SCSjr&SDSjr'SESjr(SFS jr)SGS!jr*SS".SHS#jjr+\,"\+5r-SISJS$jjr.\,"\.5r/\0SKSLS%jj5r1\0SMSNS&jj5r2\0SKSOS'jj5r3SPS(jr4SKSQS)jjr5\,"\55r6SRS*jr7\0SSS+j5r8SKSTS,jjr9\,"\95r:\0SBS-j5r;SRS.jr\0SUSVS1jj5r?\0SWS2j5r@\0SXSYS3jj5rA\0SXSYS4jj5rB\0SXSYS5jj5rC\0SXSYS6jj5rD\0SXSYS7jj5rESZS8jrFS9rGU=rH$)[MultiKernelManager3z&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.UR5Ulgr&)_create_kernel_manager_factorykernel_manager_factory)r)changes r#_kernel_manager_class_changed0MultiKernelManager._kernel_manager_class_changedCs&*&I&I&K#r"z)this is kernel_manager_class after importrBc"UR5$r&)rAr)s r#_kernel_manager_factory_default2MultiKernelManager._kernel_manager_factory_defaultIs2244r"cF^^[TR5mSUU4SjjnU$)Nc>TR(aLTRR(aTR5TlUR STR5 T"U0UD6nU$)Ncontext)shared_contextrLclosed_context_default setdefault)r+r,r-kernel_manager_ctorr)s r#create_kernel_managerPMultiKernelManager._create_kernel_manager_factory..create_kernel_managerPsQ""<<&&#'#8#8#:DL!!)T\\:$d5f5BIr")r+r3r,r3r5r)rr?)r)rRrQs` @r#rA1MultiKernelManager._create_kernel_manager_factoryMs&)$*C*CD  %$r"z4Share a single zmq.Context to talk to all my kernels zmq.ContextFcUR$)z#A shim for backwards compatibility.)_pending_kernelsrGs r#_starting_kernels$MultiKernelManager._starting_kernelsfs$$$r"rLc:SUl[R"5$NT)_created_contextzmqContextrGs r#rO#MultiKernelManager._context_defaultks ${{}r"Nc4>[TU]"U0UD6 0Ulgr&)super__init__kernel_id_to_connection_file)r)r+r, __class__s r#rcMultiKernelManager.__init__us $)&)=?)r"cR>UR(asUR(abURR(dGUR(aURR SU5 URR 5 [ TU]nU"5 g![a gf=f)z:Handle garbage collection. Destroy context if applicable.zDestroying zmq context for %sN) r\rLrNlogdebugdestroyrb__del__AttributeError)r) super_delres r#rkMultiKernelManager.__del__ysq  T\\$,,:M:Mxx>E LL " I K   s B B&%B&cURGb[UR5nUR5(GaUR5Vs/sHo"R 5(dMUPM nn[ UR R55n[ UR R55n[ UR R55H7nXc;dM XERU5nUR U URU M9 UGHnX`R R5;aM#[R"UR55nURR!SU5 SU;aSU;dMrUR#5nX`R U'UR%UURSS9n U R'U5 [)5U lSU lSU lXylUSU lU R4R7S5 XRU'GM [ URR55$s snf![a GMMf=f) z6Return a list of the kernel ids of the active kernels.NzLoading connection file %s kernel_namekeyF)parentrh owns_kernelidler)external_connection_dirris_diriterdiris_filelistrdkeysvaluesindex_kernelsjsonloads read_text Exceptionrhri new_kernel_idrBload_connection_infor last_activityexecution_state connectionsr*rpready set_result) r)rupconnection_fileskvconnection_filer*connection_infor-s r#list_kernel_ids"MultiKernelManager.list_kernel_idss  ' ' 3&*4+G+G&H #&--///F/N/N/P#`/P!T]T]T_A/P #`::??AB::AACD'+D,M,M,T,T,V'WO&>$%ggo&>$?  ==iH MM)4 (X(8O&*K*K*R*R*TT !@D +557A HHNN#?Q)_</AY $ 2 2 4ICR55i@44# HH$)5B ++O<'-xB$)/B&%&BN#,L%4]%CBNHH''-/1MM),9(8@DMM&&())Y$a&%! !s I(I:$I I$#I$c4[UR55$)z%Return the number of running kernels.)lenrrGs r#__len__MultiKernelManager.__len__s4'')**r"cXR;$r&)r}r)r*s r# __contains__MultiKernelManager.__contains__sMM))r"cnURSUR"S0UD65nX0;a[SU-5eUc URn0nUR(aURUS'UR "S[ RRURSU-5UURUS.UD6nXQU4$)Nr*zKernel already exists: %skernel_spec_managerzkernel-%s.json)rrrrhrpr) poprrdefault_kernel_namerrBospathjoinconnection_dirrh)r)rpr,r*constructor_kwargsr-s r#pre_start_kernel#MultiKernelManager.pre_start_kernelsJJ{D,>,>,H,HI  &'BY'NO O  22K   # #8<8P8P 4 5  ( ( GGLL)<)<>NQZ>Z[#  !   ))r"cHX;aURURUS9 gg)z Allow to update the environment of the given kernel. Forward the update env request to the corresponding kernel. .. version-added: 8.5 )envN)r} update_env)r)r*rs r#rMultiKernelManager.update_envs)   MM) $ / /C / 8 r"c# UIShvN X RU'URRUS5 gN/![a%nURR U5 SnAgSnAff=f7fr&)r}rWrrrh exception)r)r*r-kernel_awaitablees r#_add_kernel_when_ready)MultiKernelManager._add_kernel_when_readys` "" " "')MM) $  ! ! % %i 6 # " HH  q ! ! "s7A-;9.;A-; A*A% A-%A**A-c# UIShvN URU5 URRUS5 gN2![a%nURR U5 SnAgSnAff=f7fr&) remove_kernelrWrrrhr)r)r*rrs r#_remove_kernel_when_ready,MultiKernelManager._remove_kernel_when_readysb "" " "   y )  ! ! % %i 6 # " HH  q ! ! "s7A0><1>A0> A-A(#A0(A--A0c[USS5$)zoReturns a boolean; a clearer method for determining if this multikernelmanager is using pending kernels or not use_pending_kernelsF)r(rGs r#_using_pending_kernels)MultiKernelManager._using_pending_kernelsst2E::r")rpcR# URX5up1n[U[5(d<URR SR UR RS95 XBS'[UR"S0UD65n[R"URXCU55nX`RU'UR5(aX0RU'U$UIShvN UR R#5(aUR R#5eU$N?7f)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 isinstancerrhwarningformatr?rer start_kernelasyncio create_taskrrWrr}rr)r)rpr,r-r*startertasks r#_async_start_kernel&MultiKernelManager._async_start_kernels&*%:%:;%O""m,, HH  Zaa!66@@b  ({r889""4#>#>yg#VW+/i(  & & ( ((*MM) $ JJxx!!##hh((** sC#D'%D%&AD'c# URRSU5 XR;abURUnUIShvN URU5n[R "[ RUR5IShvN URU5nURR5(d1URR5(aURU5 g[URX#55n[ R "UR#X55nXpRU'UR%5(dDUIShvN URR5(aURR5eggGNUGN![ Ra GN%[a URU5 gf=fN|7f)zShutdown 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)rhinforWr'tcastrFuturerCancelledErrorrr cancelledrrshutdown_kernel ensure_futurerr)r)r*nowrestartrr-stopperfuts r#_async_shutdown_kernel)MultiKernelManager._async_shutdown_kernel!st"  +Y7 -- -((3D  __Y/ffW^^RXX666 __Y 'xx!!##(:(:(<(<   y ) r11#?@##D$B$B9$VW+.i(**,,IIxx!!##hh((**$-#6))  ""9-  sf;GFFAF F FCGG?GFFG2G5GGGGcg)z,Ask a kernel to shut down by its kernel uuidNrr)r*rs r#request_shutdown#MultiKernelManager.request_shutdownPr"c<URRSU5 g)zDWait for a kernel to finish shutting down, and kill it if it doesn'trNrhr)r)r*waittime pollintervals r#finish_shutdown"MultiKernelManager.finish_shutdownTs  +Y7r"cg)zClean up a kernel's resourcesNrrs r#cleanup_resources$MultiKernelManager.cleanup_resources^rr"c:URRUS5$)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)r}rrs r#r MultiKernelManager.remove_kernelbs}}  D11r"c<# UR5nU[UR5- n[URR 55n[ U5Vs/sHo@R XAS9PM nn[R"U6IShvN UR5(aUHnURIShvN M ggs snfN>N![Ra+ URURR5 Me[a Mqf=f7f)zShutdown all kernels.rN)rryrWr}r{setrrgatherrrrr*cancelr)r)rkidskmskidfutsr-s r#_async_shutdown_all&MultiKernelManager._async_shutdown_allls##% T**++4=='')*EHYOYc++C+9YOnnd###  & & ( (((NN )P# #--A))",,7>>@ s`ADC3D C  D+C:C ;C? D C;D D DDDDcURU5nURR5(d Sn[U5eUR 5nUR R SU5 U$)zzInterrupt (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'rdone RuntimeErrorinterrupt_kernelrhr)r)r*kernelmsgouts r#r#MultiKernelManager.interrupt_kernels[+||  ""CCs# #%%'  . : r"c<URRSX5 g)a Sends 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_kernel MultiKernelManager.signal_kernels  2IFr"c,# URU5nUR5(a,URR5(d Sn[ U5e[ UR US95IShvN URRSU5 gN!7f)aRestart 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'rrrrrrestart_kernelrhr)r)r*rrrs r#_async_restart_kernel(MultiKernelManager._async_restart_kernelsz+  & & ( (1B1B1D1DACs# #600S09:::  ,i8 ;sA.B0B1"Bcg)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_aliveMultiKernelManager.is_aliverr"c*X;a[SU-5eg)zcheck that a kernel id is validzKernel with id not found: %sN)KeyErrorrs r#_check_kernel_id#MultiKernelManager._check_kernel_ids  9IEF F !r"cBURU5 URU$)zGet the single KernelManager object for a kernel by its uuid. Parameters ========== kernel_id : uuid The id of the kernel. )rr}rs r#r'MultiKernelManager.get_kernels! i(}}Y''r"cg)z&add a callback for the KernelRestarterNrr)r*callbackevents r#add_restart_callback'MultiKernelManager.add_restart_callbackrr"cg)z)remove a callback for the KernelRestarterNrrs r#remove_restart_callback*MultiKernelManager.remove_restart_callbackrr"cg)akReturn 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_info&MultiKernelManager.get_connection_inforr"cg)zReturn 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_iopub MultiKernelManager.connect_iopubrr"cg)zReturn 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_shell MultiKernelManager.connect_shellrr"cg)zReturn 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_control"MultiKernelManager.connect_controlrr"cg)zReturn 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_stdin MultiKernelManager.connect_stdin)rr"cg)zReturn 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_hbMultiKernelManager.connect_hb;rr"c >[[R"55$)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 )r4uuiduuid4)r)r,s r#r MultiKernelManager.new_kernel_idMs4::<  r")r\rLrdrB)rCr3r5None)r5 t.Callable)r5dict)r5rU)r+r3r,r3r5r')r5r')r5z list[str])r5int)r*r4r5bool)rp str | Noner,r3r5ztuple[KernelManager, str, str])r*r4rzt.Dict[str, str]r5r')r*r4r-rr t.Awaitabler5r')r*r4rr-r5r')r5r+)rpr,r,r3r5r4)FF)r*r4r bool | Nonerr.r5r')F)r*r4rr.r5r')Ng?)r*r4r float | Nonerr/r5r')r*r4rr+r5r')r*r4r5r)rr+r5r')r*r4r5r')r*r4rr*r5r')r*r4rr+r5r')r)r*r4rr(r r4r5r')r*r4r5zdict[str, t.Any]r&)r*r4rz bytes | Noner5z socket.socket)r,r3r5r4)Irrrr __doc__r rtagrr rrr r?rrDrrBr rHrArrMrLr\r rWpropertyrXrOrrur}rcrkrrrrrrrrrrrrrr6rrrrr shutdown_allrrrrrrr'r r rrrrrr!rr! __classcell__)res@r#r8r83sI0!!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   "!!r"r8c\rSrSr%\"SSSS9r\"SSS9RSS 9r\ "S 5r \ "S 5SS j5r \ RrS \S'\ R"rS \S'\ R&rS \S'\ R*rS \S'Srg)AsyncMultiKernelManageriWz.jupyter_client.ioloop.AsyncIOLoopKernelManagerTzThe kernel manager class. This is configurable to allow subclassing of the AsyncKernelManager for customized behavior. )r=r;FzWhether to make kernels available before the process has started. The kernel has a `.ready` future which can be awaited before connectingr:r<zmq.asyncio.ContextrLcLSUl[RR5$r[)r\r]rr^rGs r#rO(AsyncMultiKernelManager._context_defaulths ${{""$$r"zt.Callable[..., t.Awaitable]rrrr3)r\N)r5r7)rrrr r r?rr1rr rLr rOr8rr__annotations__rrrrrr3r!rr"r#r6r6Ws+8  O cc  ,-G Y%%2D1W1WL.W3E3[3[N0[4F4]4]O1]1C1W1WL.Wr"r6)r0r(r5r(),r0 __future__rrr~rsockettypingrr$ functoolsrpathlibrr] traitletsrrr r r r r rtraitlets.config.configurablertraitlets.utils.importstringrconnectr kernelspecrrmanagerrutilsrrrrrr6r8r6rr"r#rGsv+#   \\\=4)="11 9 *a!,a!HX0Xr"