@@ -720,17 +720,13 @@ def send_with_metadata(
720
720
kernel_kwargs ["control_thread" ] = control_thread = ControlThread (
721
721
daemon = True
722
722
)
723
- if ipykernel .version_info >= (7 ,):
724
- kernel_kwargs ["shell_socket" ] = zmq .asyncio .Socket (shell_socket )
725
- kernel_kwargs ["control_socket" ] = zmq .asyncio .Socket (control_socket )
726
- else :
727
- # Kernel.start starts control thread in kernel 7
728
- control_thread .start ()
729
- kernel_kwargs ["control_stream" ] = zmqstream .ZMQStream (
730
- control_socket , control_thread .io_loop
731
- )
732
723
733
- kernel_kwargs ["shell_streams" ] = [zmqstream .ZMQStream (shell_socket )]
724
+ control_thread .start ()
725
+ kernel_kwargs ["control_stream" ] = zmqstream .ZMQStream (
726
+ control_socket , control_thread .io_loop
727
+ )
728
+
729
+ kernel_kwargs ["shell_streams" ] = [zmqstream .ZMQStream (shell_socket )]
734
730
735
731
self .kernel = Kernel .instance (
736
732
parent = self ,
@@ -954,12 +950,7 @@ def initialize(self, argv=None):
954
950
self .forward_logging ()
955
951
956
952
def init_signal (self ):
957
- if ipykernel .version_info >= (7 ,):
958
- # ipykernel 7 changes SIGINT handling
959
- # to the app instead of the kernel
960
- self .kernel_app .init_signal ()
961
- else :
962
- signal .signal (signal .SIGINT , self ._signal_sigint )
953
+ signal .signal (signal .SIGINT , self ._signal_sigint )
963
954
signal .signal (signal .SIGTERM , self ._signal_stop )
964
955
965
956
def _signal_sigint (self , sig , frame ):
0 commit comments