ó Ýà‹]c@sAdZddlmZddlmZddlmZyddlmZWn!ek rmddl mZnXddl Z ddl Z ddl Z ddl mZddlmZdd lmZd d lmZy e jZWnek rûe j ZnXyeWnek reZnXd „Zd efd„ƒYZdS(seImplements a fully blocking kernel client. Useful for test suites and blocking terminal interfaces. iÿÿÿÿ(tprint_function(tpartial(tgetpass(tEmptyN(tType(t HBChannel(t KernelClienti(tZMQSocketChannelcs…‡fd†}ˆjs|Sˆjjddƒ\}}|jƒg}d|krb|jdƒn|jdƒdj|ƒ|_|S(NcsS|jdtƒ}|jddƒ}ˆ|||Ž}|s@|S|j|d|ƒS(Ntreplyttimeout(tpoptFalsetNonet _recv_reply(tselftargstkwargsRR tmsg_id(tmeth(s=lib/python2.7/site-packages/jupyter_client/blocking/client.pytwrapped(s sReturns it Parameterss/ Parameters ---------- sŠ reply: bool (default: False) Whether to wait for and return reply timeout: float or None (default: None) Timeout to use when waiting for a reply Returns ------- msg_id: str The msg_id of the request sent, if reply=False (default) reply: dict The reply message for this request, if reply=True s (t__doc__tsplittstriptappendtjoin(RRtbasedoct_tparts((Rs=lib/python2.7/site-packages/jupyter_client/blocking/client.pytreqrep's    tBlockingKernelClientc BsûeZdZdd„ZeeƒZeeƒZeeƒZ ee ƒZ dd„Z e ejƒZe ejƒZe ejƒZe ejƒZe ejƒZe ejƒZe ejƒZd„Zd„Zd„Zeeddedddd„ZRS(sÊA KernelClient with blocking APIs ``get_[channel]_msg()`` methods wait for and return messages on channels, raising :exc:`queue.Empty` if no message arrives within ``timeout`` seconds. cCs{|d krtdƒ}ntjƒ|}ddlm}t|j|ƒs•xE|jƒs‘tjƒ|krtd|ƒ‚ntj dƒqPWnxžt r5y|j j dt ddƒ}Wnt k rÐn"X|d d krò|j|ƒPn|jƒs td ƒ‚ntjƒ|kr˜td |ƒ‚q˜q˜Wx>t rvy|jj dt ddƒ}Wq9t k rrPq9Xq9Wd S(sHWaits for a response when a client is blocked - Sets future time for timeout - Blocks on shell channel until a message is received - Exit if the kernel has died - If client times out before receiving a message from the kernel, send RuntimeError - Flush the IOPub channel tinfi(t KernelManagers?Kernel didn't respond to heartbeats in %d seconds and timed outgš™™™™™É?tblockR itmsg_typetkernel_info_replys*Kernel died before replying to kernel_infos#Kernel didn't respond in %d secondsN(R tfloatttimetmanagerR t isinstancetparenttis_alivet RuntimeErrortsleeptTruet shell_channeltget_msgRt_handle_kernel_info_replyt iopub_channel(RR t abs_timeoutR tmsg((s=lib/python2.7/site-packages/jupyter_client/blocking/client.pytwait_for_readyTs4       cCs¨|dk rtƒ|}nx…tr£|dk rJtd|tƒƒ}ny|jd|ƒ}Wntk rtdƒ‚nX|djdƒ|krŸqn|SWdS(s0Receive and return the reply for a given requestiR sTimeout waiting for replyt parent_headerRN(R t monotonicR,tmaxt get_shell_msgRt TimeoutErrortget(RRR tdeadlineR((s=lib/python2.7/site-packages/jupyter_client/blocking/client.pyR Œs    cCsÄ|d}|jdtƒr%t}ntjdkr=t}nt}y||dƒ}Wn8tk rpd}n"tk r‘tj j dƒdSX|j j ƒp­|j j ƒsÀ|j|ƒndS( sHandle an input requesttcontenttpassworditpromptss N(i(R9R Rtsyst version_infot raw_inputtinputtEOFErrortKeyboardInterrupttstdouttwritet stdin_channelt msg_readyR-(RR2R;R=traw_data((s=lib/python2.7/site-packages/jupyter_client/blocking/client.pyt_stdin_hook_default¦s      cCs­|dd}|d}|dkrKtt|dƒ}|j|dƒn^|dkrztjj|d jd d ƒƒn/|d kr©td j|dƒdtjƒndS(s/Default hook for redisplaying plain-text outputtheaderR"R;tstreamtnamettextt display_datatexecute_resulttdatas text/plaintterrors t tracebacktfileN(RNRO(tgetattrR>RERDR9tprintRtstderr(RR2R"R;RK((s=lib/python2.7/site-packages/jupyter_client/blocking/client.pyt_output_hook_default¾s   # cCsK|dd}|d kr:|j|||dd|ƒn |j|ƒdS( s]Output hook when running inside an IPython kernel adds rich output support. RJR"RNRORRR;R(N(RNRORR(tsendRX(RtsessiontsocketR4R2R"((s=lib/python2.7/site-packages/jupyter_client/blocking/client.pyt_output_hook_kernelÊs  c  Csý|jjƒstdƒ‚n|dkr6|j}n|r[|jjƒ r[tdƒ‚n|j|d|d|d|d|d|ƒ} | dkr |j} n|dkrdtj krd d l m } | ƒ} t | d t ƒ} | rt|j| jj| jj| jjƒ}qqn|dkr7|j}n|dk rStƒ|}nd}tjƒ}|jj}|j|tjƒ|r¬|jj}|j|tjƒnd}xtrÄ|dk rêtd |tƒƒ}d |}nt|j|ƒƒ}|stdƒ‚n||krE|jj dd ƒ}| |ƒqµn||krWqµn|jj dd ƒ}|dj!dƒ| kr‹qµn||ƒ|dddkrµ|dddkrµPqµqµW|dk rêtd |tƒƒ}n|j"| d|ƒS(s!Execute code in the kernel interactively Output will be redisplayed, and stdin prompts will be relayed as well. If an IPython kernel is detected, rich output will be displayed. You can pass a custom output_hook callable that will be called with every IOPub message that is produced instead of the default redisplay. .. versionadded:: 5.0 Parameters ---------- code : str A string of code in the kernel's language. silent : bool, optional (default False) If set, the kernel will execute the code as quietly possible, and will force store_history to be False. store_history : bool, optional (default True) If set, the kernel will store command history. This is forced to be False if silent is True. user_expressions : dict, optional A dict mapping names to expressions to be evaluated in the user's dict. The expression values are returned as strings formatted using :func:`repr`. allow_stdin : bool, optional (default self.allow_stdin) Flag for whether the kernel can send stdin requests to frontends. Some frontends (e.g. the Notebook) do not support stdin requests. If raw_input is called from code executed from such a frontend, a StdinNotImplementedError will be raised. stop_on_error: bool, optional (default True) Flag whether to abort the execution queue, if an exception is encountered. timeout: float or None (default: None) Timeout to use when waiting for a reply output_hook: callable(msg) Function to be called with output messages. If not specified, output will be redisplayed. stdin_hook: callable(msg) Function to be called with stdin_request messages. If not specified, input/getpass will be called. Returns ------- reply: dict The reply message for this request s/IOPub channel must be running to receive outputs,stdin channel must be running to allow inputtsilentt store_historytuser_expressionst allow_stdint stop_on_errortIPythoniÿÿÿÿ(t get_ipythontkernelig@@sTimeout waiting for outputR R4RRJR"tstatusR;texecution_statetidleN(#R0R)R*R R`RFtexecuteRIR>tmodulesRbRcRUR RR\t display_pubRZt pub_socketR4RXR5tzmqtPollerR[tregistertPOLLINR,R6tdicttpollR8R.R9R (RtcodeR]R^R_R`RaR t output_hookt stdin_hookRRctipt in_kernelR:t timeout_mstpollert iopub_sockett stdin_socketteventstreqR2((s=lib/python2.7/site-packages/jupyter_client/blocking/client.pytexecute_interactiveÕsx:                        N(t__name__t __module__RR R3RRtshell_channel_classtiopub_channel_clasststdin_channel_classRthb_channel_classR RRRhthistorytcompletetinspectt kernel_infot comm_infotshutdownRIRXR\R R,R}(((s=lib/python2.7/site-packages/jupyter_client/blocking/client.pyRMs( 2        (Rt __future__Rt functoolsRRtqueueRt ImportErrortQueueR>R%Rlt traitletsRtjupyter_client.channelsRtjupyter_client.clientRtchannelsRR5tAttributeErrorR8t NameErrorR*RR(((s=lib/python2.7/site-packages/jupyter_client/blocking/client.pyts0          &