[pre-commit.ci] auto fixes from pre-commit.com hooks

for more information, see https://pre-commit.ci

Author: pre-commit-ci[bot]

ipykernel/iostream.py

@@ -20,7 +20,7 @@
 from typing import Any
 
 import zmq
-from jupyter_client.session import extract_header, Session
+from jupyter_client.session import extract_header
 from tornado.ioloop import IOLoop
 from zmq.eventloop.zmqstream import ZMQStream
 
@@ -84,7 +84,7 @@ def _setup_xpub_listener(self):
         """Setup listener for XPUB subscription events"""
 
         # Checks the socket is not a DummySocket
-        if not hasattr(self.socket, 'getsockopt'):
+        if not hasattr(self.socket, "getsockopt"):
             return
 
         socket_type = self.socket.getsockopt(zmq.TYPE)
@@ -95,17 +95,17 @@ def _setup_xpub_listener(self):
     def _handle_subscription(self, frames):
         """Handle subscription/unsubscription events from XPUB socket
 
-        XPUB sockets receive: 
+        XPUB sockets receive:
         - subscribe:  single frame with b'\\x01' + topic
         - unsubscribe: single frame with b'\\x00' + topic
         """
 
         for frame in frames:
             event_type = frame[0]
             if event_type == 1:
-                subscription = frame[1:] if len(frame) > 1 else b''
+                subscription = frame[1:] if len(frame) > 1 else b""
                 try:
-                    subscription_str = subscription.decode('utf-8')
+                    subscription_str = subscription.decode("utf-8")
                 except UnicodeDecodeError:
                     continue
                 self._send_welcome_message(subscription_str)
@@ -119,23 +119,21 @@ def _send_welcome_message(self, subscription):
             The subscription topic (UTF-8 decoded)
         """
 
-        content = {
-            'subscription': subscription
-        }
+        content = {"subscription": subscription}
 
-        header = self.session.msg_header('iopub_welcome')
+        header = self.session.msg_header("iopub_welcome")
         msg = {
-            'header': header,
-            'parent_header': {},
-            'metadata': {},
-            'content': content,
-            'buffers': [],
+            "header": header,
+            "parent_header": {},
+            "metadata": {},
+            "content": content,
+            "buffers": [],
         }
 
         msg_list = self.session.serialize(msg)
 
         if subscription:
-            identity = subscription.encode('utf-8')
+            identity = subscription.encode("utf-8")
             full_msg = [identity] + msg_list
         else:
             full_msg = msg_list