fix linting

src/lava/magma/compiler/channels/pypychannel.py

@@ -145,6 +145,7 @@ def join(self):
             self._ack = None
             self._req = None
 
+
 class CspRecvQueue(Queue):
     """
     Underlying queue which backs the CspRecvPort

src/lava/proc/io/bridge/extractor.py

@@ -148,6 +148,7 @@ def __del__(self) -> None:
         self._multi_processing.stop()
         self._extractor_channel_dst_port.join()
 
+
 @implements(proc=Extractor, protocol=LoihiProtocol)
 @requires(CPU)
 class PyLoihiExtractorModel(PyLoihiProcessModel):

tests/lava/proc/io/test_injector.py

@@ -23,8 +23,8 @@
 
 from lava.magma.runtime.message_infrastructure.multiprocessing import \
     MultiProcessing
-from lava.magma.compiler.channels.pypychannel import PyPyChannel, CspRecvPort, \
-    CspSendPort
+from lava.magma.compiler.channels.pypychannel import (PyPyChannel, CspRecvPort,
+                                                      CspSendPort)
 
 from lava.proc.io.bridge.injector import Injector, PyLoihiInjectorModel
 from lava.proc.io.bridge.utils import ChannelConfig, ChannelSendBufferFull, \
@@ -50,6 +50,7 @@ def __init__(self,
         self.var = Var(shape=(buffer_size, ) + shape, init=0)
         self.in_port = InPort(shape=shape)
 
+
 @implements(proc=Recv, protocol=LoihiProtocol)
 @requires(CPU)
 class PyRecvProcModel(PyLoihiProcessModel):
@@ -62,7 +63,8 @@ def __init__(self, proc_params: dict) -> None :
         self._buffer_size = proc_params["buffer_size"]
 
     def run_spk(self) -> None:
-        self.var[(self.time_step-1) % self._buffer_size] = self.in_port.recv()
+        self.var[
+            (self.time_step - 1) % self._buffer_size] = self.in_port.recv()
 
 
 class TestInjector(unittest.TestCase):
@@ -249,8 +251,8 @@ def thread_2_fn(queue: Queue) -> None:
             injector.send_data(np.ones(data_shape))
             checkpoint_3 = time.perf_counter()
 
-            queue.put(checkpoint_2-checkpoint_1)
-            queue.put(checkpoint_3-checkpoint_2)
+            queue.put(checkpoint_2 - checkpoint_1)
+            queue.put(checkpoint_3 - checkpoint_2)
 
         thread_2 = threading.Thread(target=thread_2_fn,
                                     daemon=True,
@@ -584,5 +586,5 @@ def test_run_continuous(self):
 
         injector.stop()
 
-        np.testing.assert_equal(recv_var_data[:num_send//10],
-                                send_data[:num_send//10])
+        np.testing.assert_equal(recv_var_data[:num_send // 10],
+                                send_data[:num_send // 10])