^h$%SrSSKJr SSKrSSKrSSKrSSKrSSKrSSKrSSK r SSK r SSK r SSK r SSKrSSKrSSKJr SSKJr SSKJr SSKJr SSKJrJrJrJrJr S S KJr \ R<S :waSS KJr OS rSSK J!r" SSK$r$SSK%r%SSK&J'r' SSK J(r( SSK)J*r* SSK+J,r,J-r- SSK.J/r/ SSK0J1r1J2r2J3r3J4r4J5r5J6r6J7r7J8r8J9r9J:r: SSK;Jr> S SK?J@r@ S SKAJBrB S SKCJDrD SrES\FS'SrG"SS\/5rHg!\#a \RDr"Nf=f) z9Base class for a kernel that talks to frontends over 0MQ.) annotationsN)Mapping) ContextVar)datetime)partial)SIGINTSIGTERMSignalsdefault_int_handlersignal)CONTROL_THREAD_NAMEwin32)SIGKILLzwindown-SIGKILL-sentinel)utcnowStdinNotImplementedError)Session)ioloop)Queue QueueEmpty)SingletonConfigurable) AnyBoolDictFloatInstanceIntegerListUnicodedefaultobserve) ZMQStream) json_clean)kernel_protocol_version) OutStream)LazyDictaaFor consistency across implementations, it is recommended that `{func_name}` either be a coroutine function (`async def`) or return an awaitable object (like an `asyncio.Future`). It might become a requirement in the future. Coroutine functions and awaitables have been supported since ipykernel 6.0 (2021). {target} does not seem to return an awaitablestr_AWAITABLE_MESSAGEcT[R"U5Rn[R US5nUHknUR U5nU=(a% UR URUR4;=(d [SUR555X4'Mm U$)NFc3R# UHoRUR:Hv M g7fN)kind VAR_KEYWORD).0ps N/home/james-whalen/.local/lib/python3.13/site-packages/ipykernel/kernelbase.py &_accepts_parameters..UsF2EQ1==(2Es%') inspect signature parametersdictfromkeysgetr- KEYWORD_ONLYPOSITIONAL_OR_KEYWORDanyvalues)meth param_namesr6acceptsparam param_specs r1_accepts_parametersrCLs""4(33JmmK/G^^E*  _J$;$;Z=]=]#^^GF*2C2C2EF F  Nc^\rSrSr%Sr\"S5r0rS\S'\ "S5S5r \ "\ SS 9r \ "S SS 9r\ "\SS 9r\"S S 9rS \S'S\S'S\S'S\S'\"S5S5r\ "S5S5r\ "\SS 9r\"5r\"5r\"5r\"5r\"5r\"5r\ "\R<SS 9rS\S'\ "S5r!\""5r#\"S5S5r$0r%S\S'\"5r&S\S'\'"SSS 9RQSS9r)\'"SS S 9RQSS9r*\'"S!5r+\,"05r-S"\S#'S$r.S%\S&'S'\S('S)\S*'S+\S,'S-\S.'\/S/5r0\1"S05RQSS9r2\1"S15RQSS9r3\1"S2SS3S49r4Sr5\,"5r6S5r7\ "\8Rr5r:/S6Qr;/\;QS7PS8PS9PS:PS;PrS>r?S?r@SSS@jjrASArBSBrCSCrDSDrESSEjrFSFrG\"SGS 9rH\"SH5SI5rISJrJSKrKSLrLSMrMSSNjrNSOrOSPrPSSQjrQSSRjrRSSrSSSTjrTSSUjrUSSVjrVSWrWSXrXSYrYSSSSZ.S[jjrZS\r[S]r\S^r]SS_jr^S`r_SSajr`Sbra\/Sc5rbSdrcSerdSfreSgrfShrgSirhSjriSkrjSlrkSSmjrlSnrmSornSSpjroSSqjrpSSrjrqSsrr\'"S!5rsSStjrtSSSujjruSvrvSwrwSSxjrxSSyjrySSzjrzS{r{S|r|S}r}S~r~\/S5rSrU=r$)KernelZzThe base kernel class.Nzdict[str, psutil.Process] processes eventloopc[RR5nURbUR UR 5 gg)z&schedule call to eventloop from IOLoopN)rIOLoopcurrentnew add_callbackenter_eventloop)selfchangeloops r1_update_eventloopKernel._update_eventloopfs9}}$$& :: !   d22 3 "rDT) allow_nonez"IPython.core.profiledir.ProfileDirzDeprecated shell_streams alias. Use shell_stream .. versionchanged:: 6.0 shell_streams is deprecated. Use shell_stream. )helpz List[t.Any] shell_streamsr(implementationimplementation_versionbannercn[R"S[SS9 URb UR/$/$)NLKernel.shell_streams is deprecated in ipykernel 6.0. Use Kernel.shell_stream stacklevel)warningswarnDeprecationWarning shell_streamrPs r1_shell_streams_defaultKernel._shell_streams_default}s9 Z     (%%& & rDc[R"S[SS9 [UR5S:a[R"S[ SS9 UR(aURSUlgg)Nr\r]r^r zJKernel only supports one shell stream. Additional streams will be ignored.r)r`rarblenrMRuntimeWarningrc)rPrQs r1_shell_streams_changedKernel._shell_streams_changeds\ Z  vzz?Q  MM\  :: & 1 D  rDzlogging.Loggerlogidentc>[[R"55$r,)r(uuiduuid4rds r1_default_identKernel._default_idents4::<  rDzdict[str, object] language_infozList[dict[str, str]] help_linkszSSet to False if you want to debug python standard and dependent libraries. )configzhWhether to use appnope for compatibility with OS X App Nap. Only affects OS X >= 10.9. FzDict[str, t.Any]_control_parentrDbytes_control_parent_identzContextVar[dict[str, Any]] _shell_parentzContextVar[bytes]_shell_parent_identzMapping[str, bytes] _parent_identz asyncio.Lock_main_asyncio_lockcV[R"S[SS9 UR5$)NzEKernel._parent_header is deprecated in ipykernel 6. Use .get_parent()r]r^)r`rarb get_parentrds r1_parent_headerKernel._parent_headers& S    rDgMb@?{Gz?atime (in seconds) to wait for messages to arrive when aborting queued requests after an error. Requests that arrive within this window after an error will be cancelled. Increase in the event of unusually slow network causing significant delays, which can manifest as e.g. "Run all" in a notebook aborting some, but not all, messages after an error. )rvrVr) execute_requestcomplete_requestinspect_requesthistory_requestcomm_info_requestkernel_info_requestconnect_requestshutdown_requestis_complete_requestinterrupt_request debug_request usage_requestcreate_subshell_requestdelete_subshell_requestlist_subshell_requestc >^[TT]"S 0UD6 [RTl[R Tl0TlTRHn[TU5TRU'M 0Tl TRHn[TU5TRU'M [TRSS/5Tl0TlSTl[#S5TlTR$R'05 [#S5TlTR(R'S5 [+U4SjU4SjS.5Tl[.R0"5Tlg ) zInitialize the kernel. cell_metacell_idrD shell_parentshell_parent_identc>TR$r,)ryrdsr1!Kernel.__init__..Hs 4#=#=rDc8>TRR5$r,)r{r9rdsr1rrIs!9!9!=!=!?rD)controlshellN)super__init__sysstdout_stdoutstderr_stderrshell_handlers msg_typesgetattrcontrol_handlerscontrol_msg_typesrC do_execute_do_exec_accepted_paramsrwryrrzsetr{r'r|asyncioLockr})rPkwargsmsg_type __class__s` r1rKernel.__init__$s' "6" .1ZZ -0ZZ !H,3D(,CD   )'!#..H.5dH.ED ! !( +/)< OOk95) % "%("'7 r"#-.B#C    $$S)&=?  #*,,.rDc# URIShvN URU5IShvN SSS5IShvN gN.NN !,IShvN (df  g=f7f)zMDispatch a control request, ensuring only one message is processed at a time.N) _control_lockprocess_controlrPmsgs r1dispatch_controlKernel.dispatch_controlOsC%%%&&s+ + +&%% +&%%%sQA"AA"AAA A"AA"AA"AA  AA"c# UR(dgURRUSS9up!URRUSSS9nURR SU5 URX!S S 9 URS S 5 US nUS nURRUS5nUcURR SU5 O9U"URX!5n[R"U5(a UIShvN [Rb[RR!5 [R"b[R"R!5 UR%SS UR5 g![a URR SSS9 gf=fN![a URR SSS9 Nf=f7f)zdispatch control requestsNFcopyTcontentrzInvalid Control Messageexc_infozControl received: %srchannelbusyheaderrz UNKNOWN CONTROL MESSAGE TYPE: %rzException in control handler:idle)sessionfeed_identities deserialize Exceptionrlerrordebug set_parent_publish_statusrr9control_streamr4 isawaitablerrflushr_publish_status_and_flush)rPridentsrrhandlerresults r1rKernel.process_controlUs|| ll223U2C  ,,**35*IC -s3 Y7 VY/X*%''++Hd; ? HHNN=x H O !4!4fB&&v.. LL :: ! JJ    :: ! JJ    &&vy$:M:MN9  HHNN4tN D  (! O>N Os`/GF BG3F2F0F2 Aa URRS5 GN+f=f![a URR1SSS 9 GNEf=f!URA5 f![a URR1SSS 9 ff=f=f7f)zdispatch shell requestsr r stop abortingNFrTrzInvalid Messagerrrrrr subshell_idrrz *** MESSAGE TYPE:%s***z Content: %s ---> rzNot handling %s:%smsg_idzUnknown message type: %rz%s: %sz%Unable to signal in pre_handler_hook:zException in message handler:z#KeyboardInterrupt caught in kernel.z&Unable to signal in post_handler_hook:)%rhbuffer _abortingshell_channel_threadmanagerset_subshell_abortingr_supports_kernel_subshells threadingcurrent_threadcontrol_threadrrrrlrrrr9$get_subshell_to_shell_channel_socketrcget_subshell_aborting_send_abort_replyrrrr4rrwarningpre_handler_hookKeyboardInterruptpost_handler_hookrrrr) rPrrrrrabortingrrrs r1dispatch_shellKernel.dispatch_shells# s8q=SV]].>> "!& ))11GG UZ[ ||   * *++-##))6  ll223U2C  ,,**35*IC W5 VW-x=,8}  /;>>>  * *..66[[F&&F ( (">>44<<RRS^_&&vF;..vwG 18< 5s9~F262D2DVRX2Y   } - -"//M  * *67F C HHNN/x=;L;LX;V W %%))(D9 ? HH  7 B HHNN8X 3 W%%' \ 5&&v.. LL\**, :: ! JJ    :: ! JJ    &&vw?O  HHNN,tN <  J0 WFQUV W ! O>N$ FDE F !\HHNN#KVZN[\\**, \HHNN#KVZN[\sCR?N(#ER??OB%R?&O7)P P!P&Q6A2R?($O R?OR?$O=9R?<O==R?P$Q&Q?)$Q Q?QQ?$Q<8R?;Q<<R??R<RR<$R96R<8R99R<<R?c6[[[5Ulg)z.Hook to execute before calling message handlerN)r rr saved_sigint_handlerrds r1rKernel.pre_handler_hooks%+63F$G!rDc8[[UR5 g)z-Hook to execute after calling message handlerN)r rrrds r1rKernel.post_handler_hooksvt001rDc^^^^TRRSTR5 TRmTcTRRS5 gUUU4SjmUU4SjmT"5 g)zenter eventloopzEntering eventloop %sNz Exiting as there is no eventloopc># TRTLaTRRST5 gTRR 5(a#TRR S5 T"5 gTRR ST5 T"T5 TRTLaT"5 gg![ a TRRS5 N?f=f7f)Nzexiting eventloop %sz*Delaying eventloop due to waiting messageszAdvancing eventloop %sz"KeyboardInterrupt caught in kernel)rIrlinfo msg_queueqsizerrr)rI schedule_nextrPsr1advance_eventloop1Kernel.enter_eventloop..advance_eventloops~~Y. 4i@~~##%%KL HHNN3Y ? E$~~*+% ECD Es*B CB/C/%CCCCc>TRRS5 TRRS[ TR T55 g)z*Schedule the next advance of the eventloopzScheduling eventloop advancegMbP?N)rlrio_loop call_laterrschedule_dispatch)rrPsr1r-Kernel.enter_eventloop..schedule_next s8 HHNN9 : LL # #E743I3IK\+] ^rD)rlrrI)rPrrIrs`@@@r1rOKernel.enter_eventloopsO  -t~~>NN   HHMM< =  ( _ rDc# UR(a+UR(dURR5 URSS9IShvN gN7f)zProcess a single shell message Any pending control messages will be flushed as well .. versionchanged:: 5 This is now a coroutine F)waitN)rcrr process_onerds r1do_one_iterationKernel.do_one_iterationsA   T%D%D    # # %E***sAAAAc# U(a&URR5IShvN up#nOURR5up#nUR cUR b[R"S5IShvN UR R5 UR RnUR"S5(aQ[R"S5IShvN UR R5 UR"S5(aMQU"U6IShvN gGN![R[4a gf=fNNjN,7f)z=Process one request Returns None if no message was handled. Nrr ) rr9 get_nowaitrrrrsleeprsocketpoll)rPrtdispatchargsr s r1rKernel.process_one(s &*nn&8&8&: : A $(NN$=$=$?!T    &4+>+>+J--" " "    % % '((//F++a..mmA&&&##))+++a..o'!;&& 3   # ' si%ED,ED/3EEA$E&E'5EE&E'E/E  E E  EEEc# UR5IShvN MN![a URRS5 N+f=f7f)zCoroutine to preserve order of message handling Ensures that only one message is processing at a time, even when the handler is async NzError in message handler)rrrl exceptionrds r1dispatch_queueKernel.dispatch_queueCsJ ?&&(((( ?""#=> ?s1A !!A !%A A A  A z&Monotonic counter of messages _message_counterc,[R"5$r,) itertoolscountrds r1_message_counter_defaultKernel._message_counter_defaultUs  rDc[UR5nURRUUU45 URR S5 g)zschedule a message for dispatchcgr,rrrDr1r*Kernel.schedule_dispatch..es$rDN)nextrr put_nowaitrrN)rPrridxs r1rKernel.schedule_dispatchYsF4(() !!   !!,/rDc@# [R"5Ulg7fr,)rrrrds r1_create_control_lockKernel._create_control_lockgs$\\^sc[RR5Ul[ 5UlUR (d%URRUR5 UR(a$URRURSS9 UR(aD[RS:a0URRRUR5 O[ R""5UlUR&(aUR (aTUR R(R+UR,5 UR&RUR.SS9 O8UR&R[1UR2UR45SS9 UR7SS5 g)z register dispatchers for streamsFr) startingrN)rrKrLrrrrrNrron_recvrrr version_infor%rrrrcrset_on_recv_callback shell_mainshell_channel_thread_mainrrrrrds r1start Kernel.startksG}},,. ',w(( LL % %d&9&9 :       ' '(=(=E ' J   3#3#3g#=    ' ' 4 4T5N5N O!(D    (())11FFtW!!))$*H*Hu)U!!))..++ * Z1rDc# [R"5UR:XdeURRIShvN URcSSS5IShvN gURR USS9up#URR USSS9nUSRS5nURRnURU5nUceUR"USS9 SSS5IShvN gNN![a URRSSS 9 N;f=fN3!,IShvN (df  g=f7f) z;Handler for shell messages received on shell_channel_threadNFrrrrzInvalid messageTr)rrr asyncio_lockrrrr9r$get_shell_channel_to_subshell_socketsend_multipartrrlr)rPr_msg2msg3rsubshell_managerr s r1r/ Kernel.shell_channel_thread_mains'')T-F-FFFF,,999||#:99 ll223U2CGA A||//e%/P"8n00? $(#<#<#D#D )NN{[)))%%c6:99  A04@ A!:999sAE DE D0 E  D!E &D0A,D/ E :D.;E E $D+(D0*D++D0.E 0E6D9 7 EE c# UR(aUc;[R"5[R"5:XdeURnO[R"5UR [R"54;deUR R RU5nO?Ube[R"5[R"5:XdeURnUceUIShvN URX!S9IShvN SSS5IShvN gN,NN !,IShvN (df  g=f7f)z/Handler of shell messages for a single subshellN)r) rrr main_threadr}rrget_subshell_asyncio_lockr)rPrrr3s r1r.Kernel.shell_mains  * *" //1Y5J5J5LLLL#66  //1--))+: $88@@ZZ  & &&++-1F1F1HH HH22L '''<%%c%C C C << C <<++o.  rDc UR(dgURRURSSU0U=(d URU5UR S5S9 g)z send status (busy/idle) on IOPubNstatusexecution_staterHrrJrKrrL)rPrPrrIs r1rKernel._publish_statussT||        '5T__W5++h'  rDcURXU5 U(aD[US5(a2UR(d UR[R 5 gggg)zfsend status on IOPub and flush specified stream to ensure reply is sent before handling the next replyrN)rhasattrrrzmqPOLLOUT)rPrPrrrIs r1r Kernel._publish_status_and_flushsD Vf5 gfg..t7V7V LL %8W.6rDc UR(dgURRURSUUR5UR S5S9 g)N debug_eventrHrR)rPevents r1_publish_debug_eventKernel._publish_debug_eventsH||       ??$++m,  rDcUS:Xa XlX lgURRU5 URRU5 g)zSet the current parent request Side effects (IOPub messages) and replies are associated with the request that caused them via the parent_header. The parent identity is used to route input_request messages on the stdin channel. rN)ryrwr{rrz)rPrnrIrs r1rKernel.set_parents@ i ). &#)  $ $ ( ( /    " "6 *rDcUc,[R"5R[:XaSnOSnUS:Xa UR$UR R 5$)aGet the parent request associated with a channel. .. versionadded:: 6 Parameters ---------- channel : str the name of the channel ('shell' or 'control') Returns ------- message : dict the parent message for the most recent request on the channel. rr)rrnamerrwrzr9)rPrs r1rKernel.get_parentsT ?'')..2EE#! i '' '!!%%''rDc UR(dgURRUUUURU 5UUUUU5 $)zSend a response to the message we're currently processing. This accepts all the parameters of :meth:`jupyter_client.session.Session.send` except ``parent``. This relies on :meth:`set_parent` having been called for the current message. N)rrJr) rPr msg_or_typerrnbufferstrackrmetadatars r1 send_responseKernel.send_responsesI(||||     OOG $       rDcS[50$)zBInitialize metadata. Run at the beginning of execution requests. started)now)rPrIs r1 init_metadataKernel.init_metadataAs su  rDcU$)zHFinish populating metadata. Run after completing an execution request. r)rPrIrg reply_contents r1finish_metadataKernel.finish_metadataLs rDc 4# UR(dgUSnUSnURSS5nURSU(+5nURS05nURSS5n URS 05n U RS 5n URS S5n UR U5n U(d1U=R S- slURXSUR 5 UUUUU S.nURS(aXS'URS(aXS'USRS5nUR"S0UD6n[R"U5(a UIShvN nO6[R"[RSURS9[ SS9 ["R$b["R$R'5 ["R(b["R(R'5 UR*(a [,R."UR*5 [1U5nUR3X=U5n URR5USUUU US9nURR7S U5 U(d;USSS:Xa.U (a&USRS5nUR9U5 gggg![a: URR S 5 URR S U5 gf=fGN7f)zhandle an execute_requestNrrFsilentF store_historyuser_expressions allow_stdinrgcellIdz Got bad msg: %s stop_on_errorTr )rFrtrurvrwrrrrr func_nametargetr^ execute_reply)rgrnrPrr)rr9rrlrrmrGrMrrr4rr`rar)formatPendingDeprecationWarningrrrr_execute_sleeptimer r$rqrJr _abort_queues)rPrrnrIrrFrtrurvrwrrrzrgdo_execute_argsrrp reply_msgs r1rKernel.execute_requestSs||  Y'G6?D[[51F#KKVDM&{{+=rB !++mU;K :r2ImmH-G  OT: %%f-  A %  ' 'd6J6J K* 0&    ( ( 5+4K (  ( ( 3)0I &X&**=9 :/:   } - -"//M MM"))L)Y)  :: ! JJ    :: ! JJ       JJt** +#=1 ''-H&*ll&7&7     '8'  tY')I.x8GC  *..}=K   { +IVCvK  HHNN? + HHNN4 (  F0s8LA:KCL)L*E$LALLLL)rrc[e)z4Execute user code. Must be overridden by subclasses.NotImplementedError)rPrFrtrurvrwrrs r1rKernel.do_executes "!rDc~# UR(dgUSnUSnUSnURXV5n[R"U5(a UIShvN nO6[R "[ RSURS9[SS9 [U5nURRUS XsU5 gNe7f) zHandle a completion request.NrrF cursor_pos do_completer{r r^complete_reply) rrr4rr`rar)rrr$rJ)rPrrnrIrrFrmatchess r1rKernel.complete_requests|| #v\* ""44   w ' '#mG MM"))M$JZJZ)[)  W% &"2GUK$sAB=B;A&B=c/UU0SS.$)+Override in subclasses to find completions.ok)r cursor_end cursor_startrgrPr)rPrFrs r1rKernel.do_completes$&   rDc # UR(dgUSnURUSUSURSS5[URS/555n[R "U5(a UIShvN nO6[ R"[RSURS 9[S S 9 [U5nURRUS XSU5nURRS U5 gN7f)zHandle an inspect request.NrrFr detail_levelr omit_sections do_inspectr{r r^ inspect_replyry)rrr9rr4rr`rar)rrr$rJrlrrPrrnrIrrprs r1rKernel.inspect_requests|| # FO L ! KK *  OR0 1    } - -"//M MM"))L)Y) #=1 llPUV tS!0sA;D=C?>BDcS00SS.$)z.Override in subclasses to allow introspection.rF)rPdatargfoundr)rPrFrrrs r1rKernel.do_inspectsUKKrDc# UR(dgUSnUR"S 0UD6n[R"U5(a UIShvN nO6[R "[ RSURS9[SS9 [U5nURRUSXSU5nURRSU5 gN7f) zHandle a history request.Nr do_historyr{r r^ history_replyryr) rrr4rr`rar)rrr$rJrlrrs r1rKernel.history_requests|| #2'2   } - -"//M MM"))L)Y)  #=1 llPUV tS!0sA C C BCc  S/S.$)z)Override in subclasses to access history.r)rPhistoryr) rPhist_access_typeoutputrawrr0stopnpatternuniques r1rKernel.do_historys2..rDc# UR(dgUR(aURR5O0nSUS'URRUSXCU5nURR SU5 g7f)zHandle a connect request.NrrP connect_replyry)rr@rrJrlrrPrrnrIrrs r1rKernel.connect_requestsc|| 151E1E$&&++-2 ll%P tS!sBBcSSKJn /nUR(aURS5 U(aURS5 [UR UR URURURUS.$)Nr )_is_debugpy_availablezkernel subshellsdebugger)protocol_versionrXrYrtrZrusupported_features) rrrappendr%rXrYrtrZru)rPrrs r1 kernel_infoKernel.kernel_info so3(*  * *  % %&8 9  % %j 1!8"11&*&A&A!//kk//"4  rDc# UR(dgSS0nURUR5 URRUSXCU5nURR SU5 g7f)zHandle a kernel info request.NrPrkernel_info_replyry)rupdaterrJrlrrs r1rKernel.kernel_info_request4sX|| T"t''(ll(;WeT tS!sA-A/c # UR(dgUSnURSS5n[US5(a`URRR 5VVs0sH.upgUR U:XdUbMU[UR S9_M0 nnnO0n[USS9n URRUSXU5n URRS U 5 gs snnf7f) zHandle a comm info request.Nr target_name comm_manager)rr)commsrPcomm_info_replyry) rr9rUrritemsrr7rJrlr) rPrrnrIrrkvrrprs r1rKernel.comm_info_request=s|| #kk-6  4 ( (#//55;;==FQ==K/;34AMM22= E E56 ll(9=RWX tS!sA"C*$C$C$AC*c[RS:XaURRS5 g[R"5n[R "U5nU(a7X!:Xa2[ [S5(a[R"U[5 g[R"U[5 g![a [R"U[5 ef=f)Nntz*Interrupt message not supported on Windowskillpg) osrarlrgetpidgetpgidrUrrOSErrorkill)rPpidpgids r1_send_interrupt_childrenKernel._send_interrupt_childrenQs 77d? HHNNG H))+C::c?D H(=(=IIdF+ V$ GGC(s >B66'Cc<# UR(dgSS0nUR5 URRUSXCUS9 g![aHnSSKnSUR 5[ [ U5R5[ U5S.nSnANjSnAff=f7f) zHandle an interrupt request.NrPrrr)rP tracebackenameevalueinterrupt_replyrn) rrrr format_stackr(type__name__rJ)rPrrnrIrerrrs r1rKernel.interrupt_requestbs|| %-t$4   ) ) + &"3WER  "&335T#Y//0c( G s-BAB B>BBBBc# UR(dgURUSS5n[R"U5(a UIShvN nO6[R "[ RSURS9[SS9 URRUSXCUS 9 URRSXC5Ul UR5IShvN URRS 5 UR(a1URR nUR#UR$5 URRS 5 UR R#UR R$5 UR&(aWUR&R UR :wa2UR&R nUR#UR$5 gggGNGN7f) zHandle a shutdown request.Nrrestart do_shutdownr{r r^shutdown_replyrzStopping control ioloopzStopping shell ioloop)rrr4rr`rar)rrrJr_shutdown_message _at_shutdownrlrrrrNrrc)rPrrnrIrcontrol_io_loop shell_io_loops r1rKernel.shutdown_requestvsz|| ""6)#4Y#?@   w ' '#mG MM"))M$JZJZ)[)  &"2G5Q!%!1!12BG!T!!! 01   "1199O  ( ()=)= > ./ !!$,,"3"34   !2!2!:!:dll!J --55M  & &}'9'9 :"K )$ "s&A G3 G- B G3G0DG30G3c SUS.$)zMOverride in subclasses to do things when the frontend shuts down the kernel. r)rPrr)rPrs r1rKernel.do_shutdowns733rDc# UR(dgUSnUSnURU5n[R"U5(a UIShvN nO6[R "[ RSURS9[SS9 [U5nURRUSXcU5nURRS U5 gN7f) zHandle an is_complete request.NrrFdo_is_completer{r r^is_complete_replyry) rrr4rr`rar)rrr$rJrlr)rPrrnrIrrFrprs r1rKernel.is_complete_requests|| #v++D1   } - -"//M MM"))4DTM`M`)a)  #=1 LL%%f.A=Z_`  tY'0sACCBCc SS0$)rrPunknownr)rPrFs r1rKernel.do_is_completes )$$rDc# UR(dgUSnURU5n[R"U5(a UIShvN nO6[R "[ RSURS9[SS9 [U5nURRUSXSU5nURRSU5 gN7f) zHandle a debug request.Nrdo_debug_requestr{r r^ debug_replyry) rrr4rr`rar)rrr$rJrlr)rPrrnrIrrprs r1rKernel.debug_requests|| #--g6   } - -"//M MM"))09N9N**  #=1 LL%%fm]TYZ  tY'0sA C C  BCcd[X5"5nUb [XC5$U$![a gf=f)zGet the process metric value.r)r BaseException)rPprocessra attribute metric_values r1get_process_metric_valueKernel.get_process_metric_values? "713L$|77   s"" //c *# UR(dg[R"5[R"5S.n[ R "5nU/URSS9QnUVs0sH4nURURRURU5_M6 snUl [URR5Vs/sHnURUSS5PM sn5US'[UR5S5(aSOSn[URR5Vs/sHnURUS U5PM sn5US '[ R "5n U b U S :waXS '[ R""SS 9US'[%[ R&"5R)55US'URR+USXCU5n UR,R/SU 5 gs snfs snfs snf7f)zHandle a usage request.N)hostnamerT recursive cpu_percent kernel_cpupssrssmemory_full_info kernel_memoryrhost_cpu_percent)logical cpu_counthost_virtual_memory usage_replyry)rr  gethostnamerrpsutilProcesschildrenrrHr9sumr=rrUrrr r7virtual_memory_asdictrJrlr) rPrrnrIrpcurrent_process all_processesr mem_info_typerrs r1rKernel.usage_requests|| %+%7%7%9"))+N  ..*(T?+C+Cd+C+ST ) ( KK++GKKA A( '* $~~446 6G--g}dK6 ' l# "))I)I)KU!S!SY^ ), $~~446 6G--g7I=Y6 * o& ((*   "{c'90;, -%+%5%5d%C k"/3F4I4I4K4S4S4U/V +,LL%%fm]TYZ  tY'3   s,A)H+;H&)HH ,AH:HB# TRRS5 STlg7f)NzFinishing abortF)rlrrrdsr1 stop_aborting+Kernel._abort_queues..stop_abortingns HHMM+ ,"DNs$'_schedule_exitr)rrrrrlrrrNr6rcrrrrstop_on_error_timeoutrrIrUr<)rPrr:schedule_stop_abortings` r1rKernel._abort_queuesVs#  !DN  % % - - C CKQU V  &'  $ $  % % - - : :66      T%D%D    # # % #"))?)?!O  % % LL # #D$>$>@V W ~~)gdnnFV.W.W--d.H.H4.OP/X) # $rDc bUR(dgURRSUSSUSS5 USSRSS5SS -nS S 0nUR U5nUR X&U5nUR U5 URRUUUUUUS 9 g) z"Send a reply to an aborted requestNzAborting %s: %srrrr6r r_replyrPaborted)rgrrIrn)rrlrrsplitrmrqrrJ)rPrrr reply_typerPmds r1rKernel._send_abort_replys||   'Xx)@#h-PZB[\]:.55c1=a@8K I&    $  ! !#6 2 &     rDcSn[U5e)zHRaise StdinNotImplementedError if active frontend doesn't support stdin.z?raw_input was called, but this frontend does not support stdin.rrs r1 _no_raw_inputKernel._no_raw_inputsP&s++rDcUR(d Sn[U5eUbSSKnUR"S[SS9 UR UUR R5URS5SS 9$) zoForward getpass to frontends Raises ------ StdinNotImplementedError if active frontend doesn't support stdin. zFgetpass was called, but this frontend does not support input requests.NrzTThe `stream` parameter of `getpass.getpass` will have no effect when using ipykernelr]r^rTpassword) _allow_stdinrr`ra UserWarning_input_requestr{r9r)rPpromptrrr`s r1getpassKernel.getpasssy  ZC*3/ /    MMf  ""   $ $ ( ( * OOG $ #  rDcUR(d Sn[U5eUR[U5URR 5UR S5SS9$)zqForward raw_input to frontends Raises ------ StdinNotImplementedError if active frontend doesn't support stdin. zHraw_input was called, but this frontend does not support input requests.rFrK)rMrrOr(r{r9r)rPrPrs r1 raw_inputKernel.raw_inputs]  \C*3/ /"" K  $ $ ( ( * OOG $ #  rDc[Rb[RR5 [Rb[RR5 URR [ R5 M,![ Ra)nUR[ R:XaSnAO eSnAff=fURce[[XS95nURRURSXcUS9 [ R"UR//UR/S5upxn U(dU (a/URR!UR5up*X*4S:waODOA!["a Sn [#U 5Se[$a UR&R)SSS 9 Of=fMU S S n O.![$a! UR&R+S U5 S n Of=fU S:Xa[,eU $)NT)rPrL input_requestrr)NNzInterrupted by userzInvalid Message:rrvaluezBad input_reply: %s)rrrr stdin_socketrecv_multipartrVNOBLOCKZMQErrorerrnoEAGAINrr$r7rJselectrecvrrrlrrEOFError) rPrPrnrIrLerrlistr6xlistr$rrXs r1rOKernel._input_requests :: ! JJ    :: ! JJ    !!00=<< 77cjj(  ||'''TCD $++_gUZ[ D#&**d.?.?-@"tGXGXFY[_"`%E#'<<#4#4T5F5F#GLE~5$ 7+',$6 D  !3d C D#( )$W-E  HHNN0& 9E  F?N sC!)B C  CCC A.F;GG G(G=<G=cN[U5<nUR5HinURRSX#5 U[:XaUR 5 M<U[ :XaUR5 MXURU5 Mk g![Ra Mf=f)zs Send a signal to all our children Like `killpg`, but does not include the current process (or possible parents). zSending %s to subprocess %sN) r _process_childrenrlrr terminaterr send_signalr  NoSuchProcess)rPsignumsig_repr0s r1_signal_childrenKernel._signal_childrensV_''')A HHNN8' E W$KKMw&FFHMM&)*''  sB B 6B  B$#B$cN[R"5nURSS9n[RS:XaU$[R "5n/nUH<n[R "UR5nXc:XaURU5 M<M> U$![a MOf=f)zRetrieve child processes in the kernel's process group Avoids: - including parents and self with killpg - including all children that may have forked-off a new group Trr) r rrrragetpgrprrrr)rPkernel_process all_children kernel_pgidprocess_group_childrenchild child_pgids r1riKernel._process_childrens )%...> 77d? jjl !#!E 9ZZ 2 ,*11%8- "&%   s B B$#B$c# SnUR5(dURRS5 g[[4HnUHnUR5nU(dURRS5 gUR U5 URRSUU5 [ R"U5IShvN M M gN 7f)N)rgQ?g?g333333?r r(r)zKernel has no children.z.No more children, continuing shutdown routine.z?Will sleep %s sec before checking for children and retrying. %s)rirlrr rrorr )rPsleepsrmdelayrs r1%_progressively_terminate_all_children,Kernel._progressively_terminate_all_children's1%%'' HHNN4 5 (F113HHNN#ST%%f-U mmE*** )+sCCCCc # UR5IShvN URbuUR (adUR R URURURS5S9 URRSUR5 UR(a*URR[R5 ggN![a&nURRSU5 SnANSnAff=f!URbuUR (adUR R URURURS5S9 URRSUR5 UR(a*URR[R5 ff=f7f)zCActions taken at shutdown by the kernel, called by python's atexit.Nz,Exception during subprocesses termination %sshutdownrry)r}rrlrrrrJrKrLrrrrVrW)rPrds r1rKernel._at_shutdown<s] 7<<> > > %%1dll !!%%**++j1" tT%;%;<""##))#++6# ? R HH  Mq Q Q R%%1dll !!%%**++j1" tT%;%;<""##))#++6#sKGCCCB>GC D &DDD  DB?GGcURSL$r,)rrds r1r!Kernel._supports_kernel_subshellsNs((44rD)rrrwryrr}r|r@rzr{rrrrrrrHrrrcr,)r str | None)T)r)NNNFNNN)TNF)rr)NNNNNF)returnNone)rrrr)rYN)rY)F)r __module__ __qualname____firstlineno____doc__rrIrH__annotations__r"rSrrr profile_dirr#rcrrWr!rerjrdebug_shell_socketrrrK iopub_threadr[loggingLoggerrlrint_idr rnrrrtrurtagdebug_just_my_code_darwin_app_naprMrrwrypropertyrrr_poll_intervalr=rr@rGrrrrrrrrrrrrrOrrrrrrr%r0r/r.rBrMrrr\rrrhrmrqrrrrrrrrrrrrrrrrrrrrrrrrrrLrr6rrrHrQrTrOrorir}rr__static_attributes__ __classcell__)rs@r1rFrFZs D I+-I(- [44 w40G?DQKI$7L!% "M; K _ _ . .iD9NUN55L5L5L"7>>dCCCR[F IE W!! (*M$)(,vJ$-    cc     cc ;L(,RO%0#&5&--**'&%$ !!6]&&d&3N 4[__D_1N!   *fOOW\\*M I   "  "  )1V, #OJ `@DH 2(T +6 ?    !!! 0, 2DA.D6%    &  + (>  D  T,t " "L* "4L"2   /"  &""(%"(;<4 ((%(( "(H"Q(Q8O2, U I %,%\ (,  2 "2h(&.+*7$55rDrF)Ir __future__rrr4rrrr rrrtypingrrpr`collections.abcr contextvarsrr functoolsrr rr r r threadrplatformrjupyter_client.sessionrrl ImportErrorr rVIPython.core.errorrrtornadortornado.queuesrrtraitlets.config.configurablertraitlets.traitletsrrrrrrrr r!r"zmq.eventloop.zmqstreamr#ipykernel.jsonutilr$_versionr%iostreamr&utilsr'r)rrCrFrrDr1rs?#   #"HH'<<7(G4  7*,?   .)-KC v5 "v5m ,,CsC::DD