Format: application/x-python-code
1 o
2
3 �h�q � @ s~ d Z ddlmZ ddlZddlZddlZddlZddlZddlZddl Z ddl
4 Z ddl m
5 Z
6 ddlmZmZ ddlmZ ddlmZ ddlZddlmZmZmZmZ dd lmZ dd
7 l m Z m Z m Z dd l m!Z! dd l"m#Z#m$Z$m%Z% dd
8 l&m'Z' ddl(m)Z) ddl*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3 ddl4m5Z5 ddl6m7Z7 ddl8m9Z9 ddl:m;Z;m<Z< ddl=m>Z> ddl?m@Z@ ddlAmBZB ddlCmDZD ddlEmFZFmGZG ddlHmIZI eJe�ZKeK�Ldd d d d d d!d"d#�� eJe�ZMeM�Ld$d%d&iid'fd$d(d&iid)fd$d*d+iid,fd-d.d/iid0fd1�� eK�Le � eM�Le � eK�Le$� eM�Le%� d2ZNG d3d$� d$ee e!�ZOeOjPZQd4d5� ZReSd6k�r=eR� dS dS )7z%An Application for launching a kernel� )� annotationsN)�partial)�FileIO�
9 TextIOWrapper)�
10 StreamHandler)�Path)�BaseIPythonApplication� base_aliases�
11 base_flags�catch_config_error)�
12 ProfileDir)�InteractiveShellApp�
13 shell_aliases� shell_flags)�ConnectionFileMixin)�Session�session_aliases�
14 session_flags��jupyter_runtime_dir)�ioloop) �Any�Bool�Dict�DottedObjectName�Instance�Integer�Type�Unicode�default)�filefind)� import_item)� ZMQStream� )�get_connection_info�write_connection_file)�
15 ControlThread)� Heartbeat)� IOPubThread)�
16 IPythonKernel)�ParentPollerUnix�ParentPollerWindows)�ZMQInteractiveShellzIPKernelApp.ipzIPKernelApp.hb_portzIPKernelApp.shell_portzIPKernelApp.iopub_portzIPKernelApp.stdin_portzIPKernelApp.control_portzIPKernelApp.connection_filezIPKernelApp.transport)�ip�hb�shell�iopub�stdin�control�f� transport� IPKernelApp� no_stdoutT�"redirect stdout to the null device� no_stderr�"redirect stderr to the null device�pylab�autoz^Pre-load matplotlib and numpy for interactive use with
17 the default matplotlib backend.ZInteractiveShell� trio_loopFz Enable Trio as main event loop.)z no-stdoutz no-stderrr: z trio-loopa# NOTE: When using the `ipython kernel` entry point, Ctrl-C will not work.
18
19 To exit, you will have to explicitly quit this process, by either sending
20 "quit" from a client, or using Ctrl-\ in UNIX-like environments.
21
22 To read more about this, see https://github.com/ipython/ipython/issues/2049
23
24 c s� e Zd ZU dZdZee�Zee�Z e
25 e e e
26 gZedddd�jdd�Ze� Ze� Zeedd �Ze� Zd
27 ed < e� Ze� Ze� Z e� Z e� Z e� Z e� Z e� Z!e� Z"d d
28 iZ#e$� Z%e&d�dd� �Z'e(dd� �Z)e*ddd�jdd�Z+e*ddd�jdd�Z,e*ddd�jdd�Z-e*ddd�jdd�Z.e/dddd�jdd�Z0e/d d d�jdd�Z1e*dd d�jdd�Z2e3e4e5j6�7d �p�d �d!d�jdd�Z8e3e4e5j6�7d"�p�d �d#d�jdd�Z9d$d%� Z:d&d'� Z;d(d)� Z<d*d+� Z=d,d-� Z>d.d/� Z?d0d1� Z@d2d3� ZAd4d5� ZBd6d7� ZCd8d9� ZDd:d;� ZEd<d=� ZFd>d?� ZGd@dA� ZHdBdC� ZIdDdE� ZJdFdG� ZKdHdI� ZLdJdK� ZMdLdM� ZNdNdO� ZOdPdQ� ZPdRdS� ZQdTdU� ZReSd[� fdWdX� �ZTdYdZ� ZU� ZVS )\r5 z The IPYKernel application class.zipython-kernelz ipykernel.ipkernel.IPythonKernelzipykernel.kernelbase.Kernelz�The Kernel subclass to be used.
29
30 This should allow easy reuse of the IPKernelApp entry point
31 to configure and launch kernels other than IPython's own.
32 )�klass�helpT)�config)�
33 allow_nonezzmq.Context[t.Any] | None�context�install)z0ipykernel.kernelspec.InstallIPythonKernelSpecAppzInstall the IPython kernel�connection_dirc C s t � S �Nr ��self� rG �Ic:\Users\shubh\Videos\agent\nova\Lib\site-packages\ipykernel/kernelapp.py�_default_connection_dir� s z#IPKernelApp._default_connection_dirc C s6 t | j�j| jkr| jrtt t| j��| j �S | jS rD )r �connection_file�namerC �strrE rG rG rH �abs_connection_file� s z IPKernelApp.abs_connection_fileFr7 )r> r9 zSet main event loop.z(Only send stdout/stderr to output streamz ipykernel.iostream.OutStreamz*The importstring for the OutStream factory)r> r@ z$ipykernel.displayhook.ZMQDisplayHookz,The importstring for the DisplayHook factoryz[Attempt to capture and forward low-level output, e.g. produced by Extension libraries.
34 ZJPY_PARENT_PIDr z�kill this process if its parent dies. On Windows, the argument
35 specifies the HANDLE of the parent process, otherwise it is simply boolean.
36 ZJPY_INTERRUPT_EVENTzYONLY USED ON WINDOWS
37 Interrupt this process when the parent is signaled.
38 c C s | j t_ dS )z Initialize the crash handler.N)�
39 excepthook�sysrE rG rG rH �init_crash_handler� s z IPKernelApp.init_crash_handlerc C s t j|||tjd� dS )zHandle an exception.��fileN)� traceback�print_exceptionrO �
40 __stderr__)rF �etype�evalue�tbrG rG rH rN � s zIPKernelApp.excepthookc C sR t jdkr| js | jrt| j| j�| _dS dS | jr%| jdkr't� | _dS dS dS )zInitialize the poller.�win32r# N)rO �platform� interrupt�
41 parent_handler+ �pollerr* rE rG rG rH � init_poller� s
42 � �zIPKernelApp.init_pollerc C s� | j � d| j� �}| j dkr%|dkr|�|�}|S |�d| j|f � |S | j dkr]|dkrOd}d| j|f }t|��� rN|d }d| j|f }t|��� s=nd| j|f }|�d| � |S ) Nz://Ztcpr z tcp://%s:%iZipcr# z%s-%izipc://%s)r4 r- Zbind_to_random_port�bindr �exists)rF �s�portZiface�pathrG rG rH �_try_bind_socket� s&
43
44
45 �
46 � ��z IPKernelApp._try_bind_socketc C s� zt j}W n ty d }Y nw |rdnd}t|�D ]1}z | �||�W S tjyL } z|j t jkr;|j |kr;� ||d krB� W Y d }~qd }~ww d S )Nr# �d )�errnoZ
47 WSAEADDRINUSE�AttributeError�rangerd �zmqZZMQErrorZ
48 EADDRINUSE)rF ra rb Z
49 win_in_useZ max_attempts�attemptZzerG rG rH � _bind_socket� s$
50 � ���zIPKernelApp._bind_socketc
51 C s� | j }t| j| jj| j| j| j| j| j | j
52 d�}t |�� � r@t
53 |dd�}t|t�s+J �t|fi |��}||kr@| j�d|� dS | j�d|� t|fi |�� dS )z"write connection info to JSON file)r- �keyr4 �
54 shell_port�
55 stdin_port�hb_port�
56 iopub_port� control_portT)�unpackz:Connection file %s with current information already existsNzWriting connection file: %s)rM �dictr- �sessionrl r4 rm rn ro rp rq r r` r$ �
57 isinstance�log�debugr% )rF �cfZconnection_infoZexisting_connection_inforG rG rH r% s( �
58 z!IPKernelApp.write_connection_filec C sD | j }| j�d|� zt|��� W n ty Y nw | �� dS )z Clean up our connection file.z Cleaning up connection file: %sN)rM rv rw r �unlink�OSErrorZcleanup_ipc_files)rF rx rG rG rH �cleanup_connection_file" s � z#IPKernelApp.cleanup_connection_filec C s� | j s
59 dt�� | _ z t| j d| jg�| _ W n$ ty: | j�d| j � t| j �j
60 j dddd� t �
61 | j� Y dS w z| �� W dS ty[ | jjd| j dd � | �d
62 � Y dS w ) z Initialize our connection file.zkernel-%s.json�.z Connection file not found: %si� T)�mode�exist_ok�parentsNz"Failed to load connection file: %r��exc_infor# )rJ �os�getpidr rC rz rv rw r rM �parent�mkdir�atexit�registerr{ Zload_connection_file� Exception�error�exitrE rG rG rH �init_connection_file- s$ � ��z IPKernelApp.init_connection_filec C s� | j �dt�� � | jdu sJ d��t�� | _}t�| j � |�
63 tj �| _ d| j _
64 | �| j | j�| _| j �d| j � |�
65 tj �| _d| j_
66 | �| j| j�| _| j �d| j � ttd�rfd | j _| j_| �|� | �|� dS ) z4Create a context, a session, and the kernel sockets.z Starting the kernel at pid: %iNz$init_sockets cannot be called twice!�� z shell ROUTER Channel on port: %iz stdin ROUTER Channel on port: %i�ROUTER_HANDOVERr# )rv �infor� r� rA ri �Contextr� r� �close�socket�ROUTER� shell_socket�lingerrk rm rw � stdin_socketrn �hasattr�router_handover� init_control�
67 init_iopub�rF rA rG rG rH � init_socketsB s
68
69 zIPKernelApp.init_socketsc C s� |� tj�| _d| j_| �| j| j�| _| j�d| j � |� tj �| _
70 d| j
71 _|� tj �| _ d| j _| j
72 �tj�rE| j �| j
73 �tj�� ttd�rNd| j_tdd�| _dS )z Initialize the control channel.r� z"control ROUTER Channel on port: %ir� r# T)�daemonN)r� ri r� �control_socketr� rk rq rv rw ZSTREAM�debugpy_socketZDEALER�debug_shell_socketr� �
74 getsockoptZ
75 LAST_ENDPOINT�connectr� r� r& �control_threadr� rG rG rH r� \ s
76 zIPKernelApp.init_controlc C sj |� tj�| _d| j_| �| j| j�| _| j�d| j � | � � t
77 | jdd�| _ | j � � | j j
78 | _dS )z Initialize the iopub channel.r� z iopub PUB Channel on port: %iT)�pipeN)r� ri ZPUB� iopub_socketr� rk rp rv rw �configure_tornado_loggerr( � iopub_thread�startZbackground_socketr� rG rG rH r� s s
79 zIPKernelApp.init_iopubc C sJ t �� }t|| j| j| jf�| _| jj| _| j� d| j � | j�
80 � dS )zstart the heart beatingz!Heartbeat REP Channel on port: %iN) ri r� r' r4 r- ro � heartbeatrb rv rw r� )rF Zhb_ctxrG rG rH �init_heartbeat s
81
82 zIPKernelApp.init_heartbeatc C s | � � | j�d� | jr| j�d� | jj�� | jr,| j�d� | j�� | j� � | j
83 rD| j
84 � � rD| j�d� | j
85 �� | j
86 � � | j
87 rP| j
88 jsP| j
89 � � | jr\| jjs\| j� � dD ]}| j�d|� t| |d d�}|rx|jsx|� � q^| j�d � | jr�| j�� | j�d
90 � dS ) z'Close zmq sockets in an orderly fashionzCleaning up socketszClosing heartbeat channelzClosing iopub channelzClosing control thread)r/ r2 r1 zClosing %s channel�_socketNzTerminating zmq contextzTerminated zmq context)�reset_iorv r� r� rw rA �termr� �stopr� r� �is_alive�joinr� �closedr� �getattr)rF Zchannelr� rG rG rH r� � s6
91
92
93
94
95
96
97 �
98 zIPKernelApp.closec C s� t | j�j}|| jkstt | j�j�| jkr|}n| j}dd| g}|D ]}| j�|� q$| jsKt | j
99 �t j k rKt
100 ttjd� |D ] }t
101 |tjd� qAt| j| j| j| j| jd�| _dS )z(display connection info, and store portsz.To connect another client to this kernel, use:z --existing %srQ )r/ r0 r1 r. r2 N)r rJ rK rL r� rC rv r� r\ �int� log_level�logging�CRITICAL�print�_ctrl_c_messagerO �
102 __stdout__rs rm rp rn ro rq �_ports)rF �basename�tail�lines�linerG rG rH �log_connection_info� s*
103 � �z IPKernelApp.log_connection_infoc C sH | j s| jr ttjd�}| j r| t_t_| jr"| t_t_ dS dS dS )z/redirects stdout/stderr to devnull if necessary�wN)
104 r6 r8 �openr� �devnullrO �stdoutr� �stderrrU )rF Z blackholerG rG rH �init_blackhole� s �zIPKernelApp.init_blackholec C s& | j rwtt| j ��}tjdurtj�� | jrdntj}| jr!dntj}| j s-t
105 |dd�}|| j | j d|d�t_tj
106 durBtj
107 �� || j | j d|d�t_
108 ttj
109 d�rw| jjD ] }t|t�rv|jj�� dkrv| j�d � tttj
110 jd
111 ��|_qW| jr�tt| j��}|| j | j�| _ | j t_ | � � dS ) z.Redirect input streams and set a display hook.NF)Zwatchfdr� )Zechor� �_original_stdstream_copy� z9Seeing logger to stderr, rerouting to raw filedescriptor.r� ) �outstream_classr! rL rO r� �flush�quietr� rU �capture_fd_outputr rt r� r� r� rv �handlersru r �stream�buffer�filenorw r r r� �displayhook_classr� � displayhook�patch_io)rF Zoutstream_factoryZe_stdoutZe_stderr�handlerZdisplayhook_factoryrG rG rH �init_io� s8
112
113
114
115 ��� zIPKernelApp.init_ioc C s t jt _t jt _t jt _dS )zBrestore original io
116
117 restores state after init_io
118 N)rO r� r� rU r� �__displayhook__r� rE rG rG rH r� � s zIPKernelApp.reset_ioc sv zddl }W n
119 ty Y dS w |j� tjdf� fdd� }||_t|d�r9|j�tjddf�fdd � }||_dS dS )
120 zAPatch important libraries that can't handle sys.stdout forwardingr NTc s � d| |d�|��S )N)rR � all_threadsrG rG )rR r� �kwargs)�faulthandler_enablerG rH �enable s z$IPKernelApp.patch_io.<locals>.enabler� Fc s � | f|||d�|��S )N)rR r� �chainrG )ZsignumrR r� r� r� )�faulthandler_registerrG rH r� s ���z&IPKernelApp.patch_io.<locals>.register)� faulthandler� ImportErrorr� rO rU r� r� )rF r� r� r� rG )r� r� rH r� s �
121
122 �zIPKernelApp.patch_ioc C s t � t jt j� dS )z Initialize the signal handler.N)�signal�SIGINT�SIG_IGNrE rG rG rH � init_signal s zIPKernelApp.init_signalc s� t | j�}t | j| jj�}t | j| jj�}| j�� | jj}|| | j ||| j
123 || j| j | j | j
124 | j| j| jd�
125 � � �dd� | j�� D �� � | _� fdd�| j_dS )z Create the Kernel object itself)
126 r� rt �control_stream�debugpy_streamr� � shell_streamr� r� r� r� rv � profile_dir�user_nsc S s i | ] \}}|d |�qS )Z_portrG )�.0rK rb rG rG rH �
127 <dictcomp>: s z+IPKernelApp.init_kernel.<locals>.<dictcomp>c s � j S rD )Zexecution_countrG ��kernelrG rH �<lambda>> s z)IPKernelApp.init_kernel.<locals>.<lambda>N)r" r� r� r� �io_loopr� r� � kernel_class�instancert r� r� r� r� rv r� r� Z record_portsr� �itemsr� r� Zget_execution_count)rF r� r� r� Zkernel_factoryrG r� rH � init_kernel# s.
128
129 �zIPKernelApp.init_kernelc s` t j�d�s dt jd< | j� � dusJ �� j}z� fdd�}|� _t�| � W |� _dS |� _w )z=Enable GUI event loop integration, taking pylab into account.Z
130 MPLBACKENDz)module://matplotlib_inline.backend_inlineNc s4 t dtjd� � d us
131 J �t � j�|�tjd� d S )Nz-GUI event loop or pylab initialization failedrQ )r� rO r� Z
132 InteractiveTBZstb2text)rV rW Zstb�r/ rG rH �print_tbU s z,IPKernelApp.init_gui_pylab.<locals>.print_tb)r� �environ�getr/ �_showtracebackr
133 �init_gui_pylab)rF r� r� rG r� rH r� @ s
134 zIPKernelApp.init_gui_pylabc C s, t | jdd�| _| jr| jj�| � dS dS )z Initialize the shell channel.r/ N)r� r� r/ Z
135 configurables�appendrE rG rG rH �
136 init_shell_ s �zIPKernelApp.init_shellc C s6 t �d�}t �� }t �t j�}|�|� |�|� dS )a5 Configure the tornado logging.Logger.
137
138 Must set up the tornado logger or else tornado will call
139 basicConfig for the root logger which makes the root logger
140 go to the real sys.stderr instead of the capture streams.
141 This function mimics the setup of logging.basicConfig.
142 �tornadoN)r� � getLoggerr � Formatter� BASIC_FORMAT� setFormatter�
143 addHandler)rF �loggerr� � formatterrG rG rH r� e s
144
145
146 z$IPKernelApp.configure_tornado_loggerc C st t j�d�r4t jdkr6ddl}z
147 ddlm}m} W n
148 ty# Y dS w t|� � �|u r8|�
149 |� � dS dS dS dS )a� set default asyncio policy to be compatible with tornado
150
151 Tornado 6 (at least) is not compatible with the default
152 asyncio implementation on Windows
153
154 Pick the older SelectorEventLoopPolicy on Windows
155 if the known-incompatible default policy is in use.
156
157 Support for Proactor via a background thread is available in tornado 6.1,
158 but it is still preferable to run the Selector in the main thread
159 instead of the background.
160
161 do this as early as possible to make it a low priority and overridable
162
163 ref: https://github.com/tornadoweb/tornado/issues/2608
164
165 FIXME: if/when tornado supports the defaults in asyncio without threads,
166 remove and bump tornado requirement for py38.
167 Most likely, this will mean a new Python version
168 where asyncio.ProactorEventLoop supports add_reader and friends.
169
170 �win)� � r N)� WindowsProactorEventLoopPolicy� WindowsSelectorEventLoopPolicy) rO rZ �
171 startswith� version_info�asyncior r r� �type�get_event_loop_policy�set_event_loop_policy)rF r r r rG rG rH �_init_asyncio_patchs s �� z IPKernelApp._init_asyncio_patchc C s> ddl }ddlm} t|d�r |j|_|j|_|j|_dS dS )z�Replace pdb with IPython's version that is interruptible.
172
173 With the non-interruptible version, stopping pdb() locks up the kernel in a
174 non-recoverable state.
175 r N)�debugger�InterruptiblePdb)�pdbZ IPython.corer r� r
176 ZPdb� set_trace)rF r r rG rG rH �init_pdb� s
177 �zIPKernelApp.init_pdbNc s� | � � t� �|� | jdurdS | �� | �� | �� | �� | �� | � � | �
178 � | � � | � � z| �
179 � W n tyT t| j�tjk rR| jjddd� Y nw | �� | �� | �� | jrp| �� | �� | �� t j � � t j � � dS )zInitialize the application.Nz Unable to initialize signal:Tr� ) r �super�
180 initialize�subappr r� r� r^ r� r� r% r� r� r� r� r� r� r� r� rv r� r� Z init_pathr� r/ r� Zinit_extensionsZ init_coderO r� r� r� )rF �argv�� __class__rG rH r � s:
181 ��
182 zIPKernelApp.initializec C s� | j dur
183 | j �� S | jdur| j�� | j�� tj�� | _| jrEddl m
184 } |� }|� | j| j� z|� � W dS t
185 yD Y dS w z| j�� W dS t
186 yW Y dS w )zStart the application.Nr )�
187 TrioRunner)r r� r] r� r ZIOLoop�currentr� r< Zipykernel.trio_runnerr r �run�KeyboardInterrupt)rF r �trrG rG rH r� � s(
188
189
190
191
192 � �zIPKernelApp.startrD )W�__name__�
193 __module__� __qualname__�__doc__rK r �kernel_aliases�aliases� kernel_flags�flagsr) r, r r �classesr �tagr� r r� r] r r' r� rA �__annotations__r� r� r� r� r� r� r� r� r� � subcommandsr rC r rI �propertyrM r r6 r8 r< r� r r� r� r� r r� r� r� r� r\ r[ rP rN r^ rd rk r% r{ r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r r� �
194 __classcell__rG rG r rH r5 t s�
195 �� �
196
197 ����������
198 $ # %'c C s t �� } | �� | �� dS )z!Run an IPKernel as an applicationN)r5 r� r r� )ZapprG rG rH �main� s r* �__main__)Tr �
199 __future__r r� rf r� r� r� rO rS �typing�t� functoolsr �ior r r �pathlibr ri ZIPython.core.applicationr r r
200 r ZIPython.core.profiledirr ZIPython.core.shellappr
201 r r Zjupyter_client.connectr Zjupyter_client.sessionr r r Zjupyter_core.pathsr r� r Ztraitlets.traitletsr r r r r r r r r Ztraitlets.utilsr Z traitlets.utils.importstringr! Zzmq.eventloop.zmqstreamr" r� r$ r% r2 r& r� r' Ziostreamr( Zipkernelr) Z parentpollerr* r+ Zzmqshellr, rs r �updater" r� r5 Zlaunch_instanceZlaunch_new_instancer* r rG rG rG rH �<module> s� , ��
202
203 �
204 ���
205
206
207
208 x
209
210 �