Black corrections. (#986)

Author: janiversen

examples/client_sync.py

@@ -134,7 +134,7 @@ def run_sync_client(modbus_calls=None):
     "tcp": ["socket", 5020],
     "udp": ["socket", 5020],
     "serial": ["rtu", "/dev/ptyp0"],
-    "tls": ["tls", 5020]
+    "tls": ["tls", 5020],
 }
 FORMAT = "%(asctime)-15s %(levelname)-8s %(module)-15s:%(lineno)-8s %(message)s"
 logging.basicConfig(format=FORMAT)
@@ -143,7 +143,9 @@ def run_sync_client(modbus_calls=None):
 
 def get_commandline():
     """Read and validate command line arguments"""
-    parser = argparse.ArgumentParser(description="Connect/disconnect a synchronous client.")
+    parser = argparse.ArgumentParser(
+        description="Connect/disconnect a synchronous client."
+    )
     parser.add_argument(
         "--comm",
         choices=["tcp", "udp", "serial", "tls"],
@@ -164,7 +166,7 @@ def get_commandline():
     )
     parser.add_argument(
         "--port",
-        help='the port to use',
+        help="the port to use",
         type=int,
     )
     args = parser.parse_args()

examples/client_sync_extended_calls.py

@@ -105,7 +105,9 @@ def execute_diagnostic_requests(client):
     assert rr and not rr.isError()  # test that calls was OK
 
     _logger.info("Running ForceListenOnlyModeRequest")
-    rr = client.execute(ForceListenOnlyModeRequest(unit=UNIT))  # does not send a response
+    rr = client.execute(
+        ForceListenOnlyModeRequest(unit=UNIT)
+    )  # does not send a response
     assert rr and not rr.isError()  # test that calls was OK
 
     _logger.info("Running ClearCountersRequest")

examples/common/async_asyncio_client.py

@@ -179,9 +179,7 @@ def start_loop(loop):
 def run_with_no_loop():
     """Create a loop."""
     _logger.debug("---------------------RUN_WITH_NO_LOOP-----------------")
-    loop, client = ModbusClient(  # pylint: disable=unpacking-non-sequence
-        port=5020
-    )
+    loop, client = ModbusClient(port=5020)  # pylint: disable=unpacking-non-sequence
     loop.run_until_complete(start_async_test(client.protocol))
     loop.close()
     _logger.debug("--------DONE RUN_WITH_NO_LOOP-------------")

examples/contrib/deviceinfo_showcase_client.py

@@ -95,7 +95,11 @@ def run_sync_client():
         log.debug(rr)
 
     print("Device Information : ")
-    for key in information.keys():  # pylint: disable=consider-iterating-dictionary,consider-using-dict-items
+    for (
+        key
+    ) in (
+        information.keys()
+    ):  # pylint: disable=consider-iterating-dictionary,consider-using-dict-items
         print(key, information[key])
 
     # ----------------------------------------------------------------------- #

examples/modbus_forwarder.py

@@ -60,12 +60,12 @@ def get_commandline():
     )
     parser.add_argument(
         "--port",
-        help='the port to use',
+        help="the port to use",
         type=int,
     )
     parser.add_argument(
         "--port_client",
-        help='the port to use',
+        help="the port to use",
         type=int,
     )
     args = parser.parse_args()

examples/server_sync.py

@@ -103,12 +103,8 @@ def setup_sync_server():
                 ir=datablock,
             ),
             0x03: ModbusSlaveContext(
-                di=datablock,
-                co=datablock,
-                hr=datablock,
-                ir=datablock,
-                zero_mode=True
-            )
+                di=datablock, co=datablock, hr=datablock, ir=datablock, zero_mode=True
+            ),
         }
     else:
         context = ModbusSlaveContext(
@@ -180,7 +176,7 @@ def run_server():
         StartSerialServer(
             context=store,  # Data storage
             identity=identity,  # server identify
-            timeout=.005,  # waiting time for request to complete
+            timeout=0.005,  # waiting time for request to complete
             port=port,  # serial port
             custom_functions=[],  # allow custom handling
             framer=FRAMERS[framer],  # The framer strategy to use
@@ -208,7 +204,7 @@ def run_server():
             handler=None,  # handler for each session
             allow_reuse_address=True,  # allow the reuse of an address
             certfile=None,  # The cert file path for TLS (used if sslctx is None)
-            sslctx=None,    # The SSLContext to use for TLS (default None and auto create)
+            sslctx=None,  # The SSLContext to use for TLS (default None and auto create)
             keyfile=None,  # The key file path for TLS (used if sslctx is None)
             password=None,  # The password for for decrypting the private key file
             reqclicert=False,  # Force the sever request client"s certificate
@@ -233,7 +229,7 @@ def run_server():
     "tcp": ("socket", 5020),
     "udp": ("socket", 5020),
     "serial": ("rtu", "/dev/ptyp0"),
-    "tls": ("tls", 5020)
+    "tls": ("tls", 5020),
 }
 FORMAT = "%(asctime)-15s %(levelname)-8s %(module)-15s:%(lineno)-8s %(message)s"
 logging.basicConfig(format=FORMAT)
@@ -263,7 +259,7 @@ def get_commandline():
     )
     parser.add_argument(
         "--port",
-        help='the port to use',
+        help="the port to use",
         type=int,
     )
     parser.add_argument(
@@ -274,7 +270,7 @@ def get_commandline():
     )
     parser.add_argument(
         "--slaves",
-        help='(server only) number of slaves to respond to',
+        help="(server only) number of slaves to respond to",
         type=int,
     )
     args = parser.parse_args()

pymodbus/client/asynchronous/tls.py

@@ -16,7 +16,7 @@ class AsyncModbusTLSClient:  # pylint: disable=too-few-public-methods
         from pymodbus.client.asynchronous.tls import AsyncModbusTLSClient
     """
 
-    def __new__(  # pylint: disable=too-many-arguments
+    def __new__(
         cls,
         host="127.0.0.1",
         port=Defaults.TLSPort,

pymodbus/client/sync.py

@@ -360,7 +360,7 @@ def _handle_abrupt_socket_close(self, size, data, duration):
 
     def is_socket_open(self):
         """Check if socket is open."""
-        return (self.socket is not None)
+        return self.socket is not None
 
     def __str__(self):
         """Build a string representation of the connection.

pymodbus/datastore/store.py

@@ -88,9 +88,7 @@ def reset(self):
         """Reset the datastore to the initialized default value."""
         self.values = [  # pylint: disable=attribute-defined-outside-init
             self.default_value
-        ] * len(
-            self.values
-        )
+        ] * len(self.values)
 
     def validate(self, address, count=1):
         """Check to see if the request is in range.

pymodbus/diag_message.py

@@ -60,9 +60,7 @@ def decode(self, data):
         (
             self.sub_function_code,  # pylint: disable=attribute-defined-outside-init
             self.message,
-        ) = struct.unpack(
-            ">HH", data
-        )
+        ) = struct.unpack(">HH", data)
 
     def get_response_pdu_size(self):
         """Get response pdu size.