Linter changes

Author: dieriver

examples/new-sdk/classical-client-server/example_client_bob.py

@@ -6,6 +6,7 @@
 from simulaqron.sdk.protocol import SimulaQronClassicalClient
 from simulaqron.settings.network_config import NodeConfigType
 
+
 async def client_code(reader: StreamReader, writer: StreamWriter):
     data = "Hello World!".encode("utf-8")
     writer.write(data)
@@ -14,6 +15,7 @@ async def client_code(reader: StreamReader, writer: StreamWriter):
     print(f"Client received message: '{result.decode("utf-8")}'")
     writer.close()
 
+
 if __name__ == "__main__":
     # This is "Bob" - the client
     # Load the file network configuration file
@@ -28,4 +30,4 @@ async def client_code(reader: StreamReader, writer: StreamWriter):
 
     # Run the client. The given function will be called once the connection with
     #m the given server was established
-    client.run_client("Alice", client_code)
+    client.run_client("Alice", client_code)

examples/new-sdk/classical-client-server/example_server_alice.py

@@ -6,13 +6,15 @@
 from simulaqron.sdk.protocol import SimulaQronClassicalServer
 from simulaqron.settings.network_config import NodeConfigType
 
+
 async def connection_handler(reader: StreamReader, writer: StreamWriter):
     result = await reader.read(255)
     print(f"Server received message: '{result.decode("utf-8")}'")
     writer.write(result)
     print(f"Server send message: '{result.decode("utf-8")}'")
     writer.close()
 
+
 if __name__ == "__main__":
     # This is "Alice" - the server
     # Load the file network configuration file
@@ -30,4 +32,4 @@ async def connection_handler(reader: StreamReader, writer: StreamWriter):
     server.register_client_handler(connection_handler)
 
     # Start serving the clients
-    server.start_serving()
+    server.start_serving()

examples/new-sdk/teleport/teleport-alice.py

@@ -33,7 +33,7 @@ async def run_alice(reader: StreamReader, writer: StreamWriter):
     # *after* the connection is closed (or after flushing the connection, untested)
     m1_val = int(m1)
     m2_val = int(m2)
-    message = f"{m1_val}:{m2_val}"
+    message = f"{m1_val}:{m2_val}"  # noqa: E231
     writer.write(message.encode("utf-8"))
     return m1_val, m2_val
 

examples/new-sdk/teleport/teleport-bob.py

@@ -31,6 +31,7 @@ async def run_bob(reader: StreamReader, writer: StreamWriter):
     meas_val = int(meas)
     print(f"Bob measurement: {meas_val}")
 
+
 if __name__ == "__main__":
     # Load the file network configuration file
     network_config_file = Path("simulaqron_network.json")

simulaqron/sdk/protocol.py

@@ -27,7 +27,6 @@ async def _run_client(self, hostname: str, port: int, callback: Coroutine[Any, A
         writer.close()
         return result
 
-
     def run_client(self, server_name: str, callback: Coroutine[Any, Any, _T]) -> _T:
         """
         Runs a function implementing a client that connects to the node with the given name.
@@ -92,9 +91,13 @@ async def _build_server(self):
         if self._connection_handler is None:
             print("No connection handler - Did you forget to register it?")
             return
-        server = await asyncio.start_server(self._connection_handler, self._sockets_data.hostname, self._sockets_data.port)
+        server = await asyncio.start_server(
+            self._connection_handler,
+            self._sockets_data.hostname,
+            self._sockets_data.port
+        )
         print(f"BOB INFO: === {self._node_name} Server ===")
-        print(f"BOB DEBUG: Listening on {self._sockets_data.hostname}:{self._sockets_data.port}")
+        print(f"BOB DEBUG: Listening on {self._sockets_data.hostname}:{self._sockets_data.port}")  # noqa: E231
         async with server:
             await server.serve_forever()