lint

Author: blink1073

jupyter_client/channels.py

@@ -217,7 +217,7 @@ async def _recv(self, **kwargs) -> t.Dict[str, t.Any]:
         return self.session.deserialize(smsg)
 
     async def get_msg(self, timeout: t.Optional[float] = None) -> t.Dict[str, t.Any]:
-        """ Gets a message if there is one that is ready. """
+        """Gets a message if there is one that is ready."""
         assert self.socket is not None
         if timeout is not None:
             timeout *= 1000  # seconds to ms
@@ -230,7 +230,7 @@ async def get_msg(self, timeout: t.Optional[float] = None) -> t.Dict[str, t.Any]
             raise Empty
 
     async def get_msgs(self) -> t.List[t.Dict[str, t.Any]]:
-        """ Get all messages that are currently ready. """
+        """Get all messages that are currently ready."""
         msgs = []
         while True:
             try:
@@ -240,7 +240,7 @@ async def get_msgs(self) -> t.List[t.Dict[str, t.Any]]:
         return msgs
 
     async def msg_ready(self) -> bool:
-        """ Is there a message that has been received? """
+        """Is there a message that has been received?"""
         assert self.socket is not None
         return bool(await self.socket.poll(timeout=0))
 

jupyter_client/session.py

@@ -465,7 +465,7 @@ def _new_auth(self) -> None:
 
     digest_history = Set()
     digest_history_size = Integer(
-        2 ** 16,
+        2**16,
         config=True,
         help="""The maximum number of digests to remember.
 
@@ -504,7 +504,7 @@ def _unpack_changed(self, change):
 
     # thresholds:
     copy_threshold = Integer(
-        2 ** 16,
+        2**16,
         config=True,
         help="Threshold (in bytes) beyond which a buffer should be sent without copying.",
     )

jupyter_client/ssh/tunnel.py

@@ -28,7 +28,6 @@
     class SSHException(Exception):  # type: ignore
         pass
 
-
 else:
     from .forward import forward_tunnel
 

jupyter_client/tests/test_connect.py

@@ -84,7 +84,7 @@ def test_write_connection_file():
 
 
 def test_load_connection_file_session():
-    """test load_connection_file() after """
+    """test load_connection_file() after"""
     session = Session()
     app = DummyConsoleApp(session=Session())
     app.initialize(argv=[])
@@ -101,7 +101,7 @@ def test_load_connection_file_session():
 
 
 def test_load_connection_file_session_with_kn():
-    """test load_connection_file() after """
+    """test load_connection_file() after"""
     session = Session()
     app = DummyConsoleApp(session=Session())
     app.initialize(argv=[])

jupyter_client/tests/test_manager.py

@@ -10,7 +10,7 @@
 
 
 def test_connection_file_real_path():
-    """ Verify realpath is used when formatting connection file """
+    """Verify realpath is used when formatting connection file"""
     with mock.patch("os.path.realpath") as patched_realpath:
         patched_realpath.return_value = "foobar"
         km = KernelManager(

jupyter_client/tests/test_provisioning.py

@@ -261,7 +261,7 @@ def test_get_new(self, kpf):
 
 class TestRuntime:
     async def akm_test(self, kernel_mgr):
-        """Starts a kernel, validates the associated provisioner's config, shuts down kernel """
+        """Starts a kernel, validates the associated provisioner's config, shuts down kernel"""
 
         assert kernel_mgr.provisioner is None
         if kernel_mgr.kernel_name == 'missing_provisioner':

jupyter_client/tests/test_session.py

@@ -185,7 +185,7 @@ def test_tracking(self):
     def test_unique_msg_ids(self):
         """test that messages receive unique ids"""
         ids = set()
-        for i in range(2 ** 12):
+        for i in range(2**12):
             h = self.session.msg_header("test")
             msg_id = h["msg_id"]
             self.assertTrue(msg_id not in ids)

jupyter_client/tests/utils.py

@@ -132,51 +132,51 @@ def wrapped(self, *args, **kwargs):
 class KMSubclass(RecordCallMixin):
     @subclass_recorder
     def start_kernel(self, **kw):
-        """ Record call and defer to superclass """
+        """Record call and defer to superclass"""
 
     @subclass_recorder
     def shutdown_kernel(self, now=False, restart=False):
-        """ Record call and defer to superclass """
+        """Record call and defer to superclass"""
 
     @subclass_recorder
     def restart_kernel(self, now=False, **kw):
-        """ Record call and defer to superclass """
+        """Record call and defer to superclass"""
 
     @subclass_recorder
     def interrupt_kernel(self):
-        """ Record call and defer to superclass """
+        """Record call and defer to superclass"""
 
     @subclass_recorder
     def request_shutdown(self, restart=False):
-        """ Record call and defer to superclass """
+        """Record call and defer to superclass"""
 
     @subclass_recorder
     def finish_shutdown(self, waittime=None, pollinterval=0.1, restart=False):
-        """ Record call and defer to superclass """
+        """Record call and defer to superclass"""
 
     @subclass_recorder
     def _launch_kernel(self, kernel_cmd, **kw):
-        """ Record call and defer to superclass """
+        """Record call and defer to superclass"""
 
     @subclass_recorder
     def _kill_kernel(self):
-        """ Record call and defer to superclass """
+        """Record call and defer to superclass"""
 
     @subclass_recorder
     def cleanup_resources(self, restart=False):
-        """ Record call and defer to superclass """
+        """Record call and defer to superclass"""
 
     @subclass_recorder
     def signal_kernel(self, signum: int):
-        """ Record call and defer to superclass """
+        """Record call and defer to superclass"""
 
     @subclass_recorder
     def is_alive(self):
-        """ Record call and defer to superclass """
+        """Record call and defer to superclass"""
 
     @subclass_recorder
     def _send_kernel_sigterm(self, restart: bool = False):
-        """ Record call and defer to superclass """
+        """Record call and defer to superclass"""
 
 
 class SyncKMSubclass(KMSubclass, KernelManager):
@@ -197,43 +197,43 @@ def _kernel_manager_class_default(self):
 
     @subclass_recorder
     def get_kernel(self, kernel_id):
-        """ Record call and defer to superclass """
+        """Record call and defer to superclass"""
 
     @subclass_recorder
     def remove_kernel(self, kernel_id):
-        """ Record call and defer to superclass """
+        """Record call and defer to superclass"""
 
     @subclass_recorder
     def start_kernel(self, kernel_name=None, **kwargs):
-        """ Record call and defer to superclass """
+        """Record call and defer to superclass"""
 
     @subclass_recorder
     def shutdown_kernel(self, kernel_id, now=False, restart=False):
-        """ Record call and defer to superclass """
+        """Record call and defer to superclass"""
 
     @subclass_recorder
     def restart_kernel(self, kernel_id, now=False):
-        """ Record call and defer to superclass """
+        """Record call and defer to superclass"""
 
     @subclass_recorder
     def interrupt_kernel(self, kernel_id):
-        """ Record call and defer to superclass """
+        """Record call and defer to superclass"""
 
     @subclass_recorder
     def request_shutdown(self, kernel_id, restart=False):
-        """ Record call and defer to superclass """
+        """Record call and defer to superclass"""
 
     @subclass_recorder
     def finish_shutdown(self, kernel_id, waittime=None, pollinterval=0.1, restart=False):
-        """ Record call and defer to superclass """
+        """Record call and defer to superclass"""
 
     @subclass_recorder
     def cleanup_resources(self, kernel_id, restart=False):
-        """ Record call and defer to superclass """
+        """Record call and defer to superclass"""
 
     @subclass_recorder
     def shutdown_all(self, now=False):
-        """ Record call and defer to superclass """
+        """Record call and defer to superclass"""
 
 
 class SyncMKMSubclass(MKMSubclass, MultiKernelManager):