Format: application/x-python-code
1 o
2
3 �h� � @ s� d Z ddlZddlZddlmZ ddlmZ ddlmZm Z m
4 Z
5 m Z m Z m
6 Z
7 ddlmZ ddlmZ ddlmZ d d
8 lmZmZmZ d d lmZ d d
9 lmZ G dd� de�Z G dd� de�Z e� e � dS )zAn in-process kernel� N)�contextmanager)�InteractiveShellABC)�Any�Enum�Instance�List�Type�default)�
10 IPythonKernel)�
11 json_clean)�ZMQInteractiveShell� )�BackgroundSocket� IOPubThread� OutStream� )�
12 INPROCESS_KEY)� DummySocketc sJ e Zd ZU dZeeddd��Zeddd�Ze � Z
13 e � Z e � Z e
14 dd�Zeed�Zee�Zeed < eed�Zed �d
15 d � �Zee�Zeed < ed �d
16 d� �Zeed�Z� fdd�Z� fdd�Z dd� Z dd� Z dd� Z d/dd�Z e!d d � �Z"d d � Z#ed �d!d"� �Z$ed#�d$d%� �Z%ed&�d'd(� �Z&ed)�d*d+� �Z'ed,�d-d.� �Z(� Z)S )0�InProcessKernelzAn in-process kernel.z0ipykernel.inprocess.client.InProcessKernelClientT��
17 allow_none)ZtkZgtkZwxZqtZqt4�inliner )�
18 default_value� � iopub_threadc C s t | j�}|�� |S �N)r �_underlying_iopub_socket�start)�self�threadr r �Rc:\Users\shubh\Videos\agent\nova\Lib\site-packages\ipykernel/inprocess/ipkernel.py�_default_iopub_thread8 s
19 z%InProcessKernel._default_iopub_thread� iopub_socketc C s | j jS r )r Zbackground_socket�r r r r �_default_iopub_socket@ s z%InProcessKernel._default_iopub_socketc s< t � jdi |�� | jj| jdgd� | jr | | j_dS dS )zInitialize the kernel.Z message_sent)�namesNr )�super�__init__r Zobserve� _io_dispatch�shell�kernel)r Ztraits�� __class__r r r' F s
20 �zInProcessKernel.__init__c � sF �| � � � t� �|||�I dH W d � dS 1 s w Y dS )z&Override for temporary IO redirection.N)�_redirected_ior& �execute_request)r �stream�ident�parentr+ r r r. N s �
21 "�z InProcessKernel.execute_requestc C s | j r d| j _dS dS )z1Override registration of dispatchers for streams.FN)r) Zexit_nowr# r r r r S s �zInProcessKernel.startc C s dS )z-The in-process kernel doesn't abort requests.Nr r# r r r �
22 _abort_queuesX s z InProcessKernel._abort_queuesc � s �dS )z.No need to flush control queues for in-processNr r# r r r �_flush_control_queue[ s z$InProcessKernel._flush_control_queueFc C s� d | _ tj�� tj�� tt||d��}| jd us J �| j�d||�}| j D ]}|d us/J �|jj|d d krA|j
23 � |� nq't �
24 d� dS | j d u rX|j
25 �� | j d u sN| j S )N)�prompt�passwordZ
26 input_request�header�sessionz'No frontend found for raw_input request� )�
27 raw_input_str�sys�stderr�flush�stdoutr �dictr7 �msg� frontendsZ
28 stdin_channel�
29 call_handlers�logging�errorZprocess_events)r r4 r0 r1 r5 �contentr? �frontendr r r �_input_request^ s$
30
31
32 �
33
34
35
36 �z InProcessKernel._input_requestc c sN � t jt j}}z| j| jt _t _dV W ||t _t _dS ||t _t _w )z&Temporarily redirect IO to the kernel.N)r: r= r; )r Z
37 sys_stdoutZ
38 sys_stderrr r r r- z s �"z InProcessKernel._redirected_ioc C s` | j jdusJ �| jdusJ �| jj| j jjdd�\}}| jD ]}|dus'J �|j�|� q dS )z/Called when a message is sent to the IO socket.NF)�copy)r" Z io_threadr7 �recv�socketr@ Z
39 iopub_channelrA )r Zchanger0 r? rE r r r r( � s
40 �z InProcessKernel._io_dispatch�logc C s
41 t �t�S r )rB � getLogger�__name__r# r r r � _default_log� s
42 z InProcessKernel._default_logr7 c C s ddl m} || td�S )Nr )�Session)r1 �key)Zjupyter_client.sessionrN r )r rN r r r �_default_session� s z InProcessKernel._default_session� shell_classc C s t S r )�InProcessInteractiveShellr# r r r �_default_shell_class� s z$InProcessKernel._default_shell_classr= c C � t | j| jddd�S )Nr= F�Zwatchfd�r r7 r r# r r r �_default_stdout� � z InProcessKernel._default_stdoutr; c C rT )Nr; FrU rV r# r r r �_default_stderr� rX z InProcessKernel._default_stderr)F)*rL �
43 __module__� __qualname__�__doc__r r r@ r �guir r9 r= r; r rQ r r r r �__annotations__Z shell_streamr r! r r" r$ Z stdin_socketr' r. r r2 r3 rF r r- r( rM rP rS rW rY �
44 __classcell__r r r+ r r sH
45
46
47
48
49
50
51
52
53
54
55
56
57 r c sP e Zd ZU dZeddd�Zeed< ddd�Zd� fd d
58 � Z d� fd d
59 � Z
60 � Z S )rR z An in-process interactive shell.z,ipykernel.inprocess.ipkernel.InProcessKernelTr r* Nc C s |s| j j}|| _dS )z&Enable GUI integration for the kernel.N)r* r] Zactive_eventloop�r r] r r r �
61 enable_gui� s
62 z$InProcessInteractiveShell.enable_guic s |s| j j}t� �|�S )z-Enable matplotlib integration for the kernel.)r* r] r& �enable_matplotlibr` r+ r r rb � s z+InProcessInteractiveShell.enable_matplotlibFc s |s| j j}t� �|||�S )z"Activate pylab support at runtime.)r* r] r& � enable_pylab)r r] Z
63 import_allZwelcome_messager+ r r rc � s z&InProcessInteractiveShell.enable_pylabr )NTF) rL rZ r[ r\ r r* r r^ ra rb rc r_ r r r+ r rR � s
64 �
65 rR ) r\ rB r: �
66 contextlibr Z IPython.core.interactiveshellr Z traitletsr r r r r r Zipykernel.ipkernelr
67 Zipykernel.jsonutilr Zipykernel.zmqshellr Ziostreamr r r � constantsr rI r r rR �registerr r r r �<module> s