ChiSrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK r SSK J r SSK J r Jr SSKJrJr SSKJr SSKJrJrJr SSKrSSKJr SS KJr SS KJr SrS rS r"S S5r "SS5r!"SS\5r"g)z.Wrappers for forwarding stdout/stderr over zmqN)b2a_hex) defaultdictdeque)StringIO TextIOBase)local)AnyCallableOptional)extract_header)IOLoop) ZMQStreamic\rSrSrSrSSjrSrSrSrSr \ S5r S r S r S rS rS rSrSrSrSr\ S5rSrSrSrSrg) IOPubThread(zAn object for sending IOPub messages in a background thread Prevents a blocking main thread from delaying output from threads. IOPubThread(pub_socket).background_socket is a Socket-API-providing object whose IO is always run in a thread. chXlSUl[U5Ul[R "5UlX l[SS9Ul U(aUR5 [R"5Ul [5Ul0Ul[R""5UlSUlSUlUR+5 [R,"UR.SS9UlSUR0lSUR0lSUR0lSUR0lg)zCreate IOPub thread Parameters ---------- socket : zmq.PUB Socket the socket on which messages will be sent. pipe : bool Whether this process should listen for IOPub messages piped from subprocesses. F) make_current NIOPub)targetnameT)socket_stoppedBackgroundSocketbackground_socketosgetpid _master_pid _pipe_flagr io_loop_setup_pipe_in threadingr_localr_events _event_pipesLock_event_pipe_gc_lock_event_pipe_gc_seconds_event_pipe_gc_task_setup_event_pipeThread _thread_mainthreaddaemonpydev_do_not_traceis_pydev_daemon_threadr)selfrpipes eC:\Users\julio\OneDrive\Documentos\Trabajo\Ideas Frescas\venv\Lib\site-packages\ipykernel/iostream.py__init__IOPubThread.__init__1s  !1$!799;51     !oo' 27' 9;3<>>3C -/#@D   &&d.?.?gN ! )- &-1 *" c^U4SjnTRRU5 TR(dTRR5 TRbMU4SjnTR(dTRRU5 OTRR 5 TRR SS9 g)z.The inner loop that's actually run in a threadcX>[R"TR55TlgN)asyncio ensure_future_run_event_pipe_gcr*r2sr4_start_event_gc1IOPubThread._thread_main.._start_event_gcTs'.'<'# TRR5 g7fr:)r*cancelr>sr4_cancel)IOPubThread._thread_main.._cancel`s((//1sT)all_fds)r!run_syncrstartr*rBclose)r2r?rCs` r4r-IOPubThread._thread_mainQs X o.}} LL    # # / 2== %%g.((//1 4(r7cURRnUR[R5nSUl[ [ R"S55RS5nSU-=o@l URU5 [X R5Ul URRUR5 g)zLCreate the PULL socket listening for events that should fire in this thread.rasciiz inproc://%sN)rcontextzmqPULLlingerrrurandomdecode_event_interfacebindrr! _event_pulleron_recv _handle_event)r2ctxpipe_in_uuidifaces r4r+IOPubThread._setup_event_pipejskk!!**SXX& 2'..w7(5(==% U&w = ""4#5#56r7c# [R"UR5IShvN UR5IShvN MCNN![a%n[ SU3[ RS9 SnAN0SnAff=f7f)z&Task to run event pipe gc continuouslyNz)Exception in IOPubThread._event_pipe_gc: file)r;sleepr)_event_pipe_gc Exceptionprintsys __stderr__)r2es r4r=IOPubThread._run_event_pipe_gcvsj-- ; ;< < < \))+++ <+ \A!ECNN[ \sJ%A=AA=A A A A= A A:A50A=5A::A=c<# UR(dgUR [URR55H9upUR 5(aMUR 5 URU M; SSS5 g!,(df  g=f7f)z.run a single garbage collection on event pipesN)r&r(listitemsis_aliverH)r2r.rs r4raIOPubThread._event_pipe_gcsj    % %"&t'8'8'>'>'@"A((LLN))&1#B& % %s"Bs r4rIOPubThread._is_master_processyy{d....r7cfUR(aUR5(a[$[$)z8check for forks, and switch to zmq pipeline if necessary)r rMASTERCHILDr>s r4_check_mp_modeIOPubThread._check_mp_modes!$"9"9";";M r7cSURlURR5 [R"UR 5 g)zStart the IOPub threadrN)r.rrGatexitregisterstopr>s r4rGIOPubThread.starts0"    "r7cSUlURR5(dgURR URR 5 URR SS9 URR5(a Sn[U5eURR5Hup#UR5 M g)zStop the IOPub threadTN)timeoutz,IOPub thread did not terminate in 30 seconds) rr.rkr! add_callbackrjoin TimeoutErrorr&rjrH)r2ry_threadrns r4rIOPubThread.stops {{##%%  !!$,,"3"34 $ ;;   ! !@Cs# #$(#4#4#:#:#< G    $=r7cjUR(agURR5 SUlg)zClose the IOPub thread.N)closedrrHr>s r4rHIOPubThread.closes# ;;   r7cURSL$r:)rr>s r4rIOPubThread.closeds{{d""r7cURR5(a7URRU5 URR S5 gU"5 g)zdSchedule a function to be called in our IO thread. If the thread is not running, call immediately. r7N)r.rkr%appendrssend)r2fs r4scheduleIOPubThread.schedulesB ;;   ! ! LL   "    ! !# & Cr7c8^^^TRUUU4Sj5 g)z|send_multipart schedules actual zmq send in my thread. If my thread isn't running (e.g. forked process), send immediately. c(>TR"T0TD6$r:) _really_send)argskwargsr2sr4,IOPubThread.send_multipart..sd//@@r7N)rr2rrs```r4rIOPubThread.send_multiparts @Ar7cHUR(agUR5nU[:wa!URR"U/UQ70UD6 gUR 5upVUR"UR /UQ/UQ70UD6 UR5 UR5 g)z)The callback that actually sends messagesN) rrrrrrrrHterm)r2ryrrmp_moderXrs r4rIOPubThread._really_sends ;; %%' e  KK & &s Wrapper around IOPub thread that provides zmq send[_multipart]NcXlg)zInitialize the socket.N io_thread)r2rs r4r5BackgroundSocket.__init__/s"r7c>URS5(a%URS5(a[TU] U5 URce[ URR U5(a@[R"SUSU3[SS9 [URR U5$[TU] U5$)z2Wrap socket attr access for backward-compatibility__zAccessing zmq Socket attribute O on BackgroundSocket is deprecated since ipykernel 4.3.0 use .io_thread.socket.rr) startswithendswithsuper __getattr__rhasattrrrrDeprecationWarninggetattr)r2attr __class__s r4rBackgroundSocket.__getattr__3s ??4 T]]4%8%8 G  %~~))) 4>>(($ / / MM1$8**.1#  4>>00$7 7w"4((r7c(>US:Xd,URS5(a&URS5(a[TU] X5 g[R "SUSU3[ SS9 URce[URRX5 g)zSet an attribute on the socket.rrzSetting zmq Socket attribute rrrN) rrr __setattr__rrrrsetattrr)r2rvaluers r4rBackgroundSocket.__setattr__Ds ; 4??4#8#8T]]4=P=P G  , MM/v6**.1#  >>- -- DNN))4 7r7c0UR"U//UQ70UD6$)zSend a message to the socket.)r)r2ryrrs r4rBackgroundSocket.sendSs""C5:4:6::r7cXURceURR"U0UD6$)zSchedule send in IO thread)rrrs r4rBackgroundSocket.send_multipartWs,~~)))~~,,d=f==r7r) rrrrrrr5rrrrr __classcell__)rs@r4rr*s)HI#)" 8;>>r7rc"\rSrSr%SrSrSrSrSrSr \ \ \ S'Sr S rS$S S S .S jjr\S5r\R$S5rSrSrSrSrSr\S5rSrSrSrS\S\ \4SjrSrSr Sr!Sr"\S 5r#S!r$S"r%S#r&g)% OutStreami]zhA file like object that publishes the stream to a 0MQ PUB socket. Output is handed off to an IO Thread rg?NzUTF-8_exccf[USS5b UR$Sn[R"U5e)zN Things like subprocess will peak and write to the fileno() of stderr/stdout. _original_stdstream_copyNfileno)rrioUnsupportedOperationrs r4rOutStream.filenols6 43T : F00 0%%c**r7c[R"UR[5nU(aUR(aUR UR SS95 [R "URU5 [R"UR[5nU(aUR(aM~gggg![a [R"5Ul gf=f)a: We've redirected standards streams 0 and 1 into a pipe. We need to watch in a thread and redirect them to the right places. 1) the ZMQ channels to show in notebook interfaces, 2) the original stdout/err, to capture errors in terminals. We cannot schedule this on the ioloop thread, as this might be blocking. replace)errorsN) rread_fidPIPE_BUFFER_SIZE _should_watchwriterRrrbrdexc_infor)r2btss r4_watch_pipe_fdOutStream._watch_pipe_fdus '''$))%56C$,, 3::Y:7866<ggdii)9:$,,,#,# ' DI 'sB9C$C('C(TF)watchfdisattyc\Ub[R"S[SS9 Xl[ U[ 5(d8[R"SU-[SS9 [ U5nUR 5 X lX0lSUR5-Ul [R"S5Ul URR05 0Ul0Ul0Ul[$R&"5UlSUlSUlUR.Ul[2R4"5Ul[9[:5UlSUl[AU5Ul!SUl"[G5Ul$U(a\[JRLROS 5(d$[JRLROS 5(aS [$RP;dUS :XaS Ul"URSU5 U(a[UUS5(a[UUS5(apURD(aXURW5nUbDXRZ:Xa5[\R^"[\R`"URbS55nXPlgSn [eU 5eg![Xa SnNjf=f)a Parameters ---------- session : object the session object pub_thread : threading.Thread the publication thread name : str {'stderr', 'stdout'} the name of the standard stream to replace pipe : object the pipe object echo : bool whether to echo output watchfd : bool (default, True) Watch the file descriptor corresponding to the replaced stream. This is useful if you know some underlying code will write directly the file descriptor by its number. It will spawn a watching thread, that will swap the give file descriptor for a pipe, read from the pipe, and insert this into the current Stream. isatty : bool (default, False) Indication of whether this stream has terminal capabilities (e.g. can handle colors) NzKpipe argument to OutStream is deprecated and ignored since ipykernel 4.2.3.rrzISince IPykernel 4.3, OutStream should be created with IOPubThread, not %rsstream. parent_headerFlinuxdarwinPYTEST_CURRENT_TESTforceTrrwz(echo argument must be a file-like object)3rrrsession isinstancerrG pub_threadrencodetopic contextvars ContextVar_parent_headerset_thread_to_parent_thread_to_parent_header_parent_header_globalrrr_flush_pending_subprocess_flush_pendingr!_io_loopr#RLock _buffer_lockrr_buffersechobool_isattyrrr$rdplatformrenviron_setup_stream_redirectsrrrb_original_stdstream_fdr TextIOWrapperFileIOr ValueError) r2rrrr3rrrecho_fdrys r4r5OutStream.__init__s4D   MM]"   *k22 MM&(23"   %Z0J    $ $++-/ FQF\F\ G  #!#(*%%'"99;#).&"** %OO-#H-  F| "g  ((11S\\5L5LX5V5V*"**<'!!%D   ( ( . tV$$w)?)?%%'"&++-*w:U:U/U "//II $ = = #  ! @ o%- %'"&'s0J J+*J+cPURR5$![a [R"5R nXR ;a UR UnXR ;aM URUs$![a URss$f=ff=fr:) r get LookupErrorr#rridentrrKeyErrorr)r2identitys r4rOutStream.parent_headers 2&&**, , 2 2$335;;"8"88#55h?H"8"8844X>> 2111 2 2s3 B%A B5BB%B!B% B!!B%cDXlURRU5$r:)rr r )r2rs r4rr) s%*"""&&u--r7cUR$)zXReturn a bool indicating whether this is an 'interactive' stream. Returns: Boolean )rr>s r4rOutStream.isattys ||r7c[R"5up#[[U5R 5=o@l[R "U5Ul[R"X45 X l SUl [R"URS9UlSURlURR!5 g)N)rT)rr3rrdrrduprdup2rrr#r,rwatch_fd_threadr/rG)r2rprpwfnos r4r!OutStream._setup_stream_redirectss,3C,>,E,E,GG)(*s %   (//t7J7JK&*# ""$r7cF[R"5UR:H$r:rr>s r4rOutStream._is_master_process&rr7c$[U5Ulg)zSet the parent header.N)r r)r2parents r4 set_parentOutStream.set_parent)s+F3r7cUR(aSUl[R"URS5 URR 5 [R "URUR5 [R"UR5 UR(a&URupn[R"XU5 SUl g)zClose the stream.FN) rrrrr0rr/rrHr tracebackprint_exceptionr)r2etypertbs r4rHOutStream.close-s   !&D  HHT00% 8  % % ' GGD1143N3N O HHT22 3 99#yy E"  % %eB 7r7cURSL$r:)rr>s r4rOutStream.closed=s$&&r7cz^TR(agSTlU4SjnTRRU5 g)zeschedule a flush in the IO thread call this on write, to indicate that flush should be called soon. NTcf>TRRTRTR5 gr:)r call_laterflush_interval_flushr>sr4_schedule_in_thread6OutStream._schedule_flush.._schedule_in_threadKs! MM $ $T%8%8$++ Fr7)rrr)r2rIs` r4_schedule_flushOutStream._schedule_flushAs4    " G   !45r7c~UR(GaURRGbURRR5(aURRR[R "5R:waURR UR5 [R"5nURR UR5 URUR5(d[S[RS9 ggUR5 g)zCtrigger actual zmq send send will happen in the background thread NzIOStream.flush timed outr^)rr.rkr&r#rrrrHEventr wait flush_timeoutrcrdre)r2evts r4flushOutStream.flushPs OOO&&2&&//11&&,, 0H0H0J0P0PP OO $ $T[[ 1//#C OO $ $SWW -88D..//0s~~F0 KKMr7cSUlSUlURbURR5 UR5Hup#U(dM[R"5URl URUS.nURRSXBS9nURHnU"U5nUbM g URR!UR"UUR$S9 M g![aCnUR[ R La[SU3[ R S9 SnAGNSnAff=f) zThis is where the actual send happens. _flush should generally be called in the IO thread, unless the thread has been destroyed (e.g. forked subprocess). FNzFlush failed: r^)rtextstream)r8)r&)rrrrROSErrorrdrerc_flush_buffersrrrpidrry_hooksrrr )r2rfr8datacontentryhooks r4rHOutStream._flushhs $).& 99  E ! !//1LFt$&99;  #'99d;ll&&x&H !KKDs)C{(  !!OO**"#2  E99CNN2N1#.S^^D EsC77 E8D??Estringreturnc>URn[U[5(dS[U53n[ U5eUR bUR R U5 URc Sn[U5eUR5(+nUR UR[!UR#55R U5 SSS5 U(a?UR$(agSUlURR'UR(5 OUR+5 [-U5$![aCnUR [RLa[SU3[RS9 SnAGN"SnAff=f!,(df  N=f)zWrite to current stream after encoding if necessary Returns ------- len : int number of items from input parameter written to stream. z"write() argument must be str, not NzWrite failed: r^I/O operation on closed fileT)rrstrtype TypeErrorrrrWrdrercrr rrr frozensetrjrrrHrKrv)r2r_r8ryrfis_childs r4rOutStream.writes:##&#&&6tF|nECC. 99  E ' ?? "0CS/ !..00    MM)FLLN3 4 : :6 B ---1D * OO $ $T[[ 1  "6{/ E99CNN2N1#.S^^D E s$ D>6F> F 8FF  FclURc Sn[U5eUHnURU5 M g)zWrite lines to the stream.Nrb)rr r)r2sequenceryr_s r4 writelinesOutStream.writeliness1 ?? "0CS/ !F JJv r7cg)z$Test whether the stream is writable.Trr>s r4writableOutStream.writablesr7c## UR5nUR5H4up#UR5nUR5 [ U5U4v M6 g7f)z   --K'1DM s !8 Ac[URS5(d/URlURR$)Nhooks)rr$r|r>s r4rZOutStream._hookss/t{{G,, "DKK {{   r7c:URRU5 g)a Registers a hook with the thread-local storage. Parameters ---------- hook : Any callable object Returns ------- Either a publishable message, or `None`. The hook callable must return a message from the __call__ method if they still require the `session.send` method to be called after transformation. Returning `None` will halt that execution path, and session.send will not be called. N)rZrr2r]s r4 register_hookOutStream.register_hooks" 4 r7c\URRU5 g![a gf=f)z Un-registers a hook with the thread-local storage. Parameters ---------- hook : Any callable object which has previously been registered as a hook. Returns ------- bool - `True` if the hook was removed, `False` if it wasn't found. TF)rZremover rs r4unregister_hookOutStream.unregister_hooks.  KK  t $  s  ++)rrrrrrrr$rrrr rrrrrrrrrrr r0)NN)'rrrrrrPrGr encodingrr r __annotations__rrr5rrsetterrrrr9rHrrKrRrHrcintrrkrnrXrqrZrrrrr7r4rr]sMN EHD(3-+'6  l&l&\22$.. %/4 '' 60%N)C)HSM)V,!! !&r7r)#rr;rr rrrdr#r=rbinasciir collectionsrrrrrtypingr r r rNjupyter_client.sessionr tornado.ioloopr zmq.eventloop.zmqstreamrrrrrrrrr7r4rs{4   *#** 1!-  D0>0>fd dr7