Run black. (#1067)

Author: janiversen

examples/common/updating_server.py

@@ -86,10 +86,7 @@ async def run_updating_server():
     # ----------------------------------------------------------------------- #
     log.debug("Start server")
     await StartTcpServer(
-        context,
-        identity=identity,
-        address=("localhost", 5020),
-        defer_start=False
+        context, identity=identity, address=("localhost", 5020), defer_start=False
     )
     log.debug("Done")
 

examples/server_async.py

@@ -163,7 +163,7 @@ async def run_server(args=None):
             # broadcast_enable=False,  # treat unit_id 0 as broadcast address,
             # TBD timeout=1,  # waiting time for request to complete
             # TBD strict=True,  # use strict timing, t1.5 for Modbus RTU
-            defer_start=defer_start  # Only define server do not activate
+            defer_start=defer_start,  # Only define server do not activate
         )
     elif server_id == "udp":
         server = await StartUdpServer(
@@ -178,7 +178,7 @@ async def run_server(args=None):
             # broadcast_enable=False,  # treat unit_id 0 as broadcast address,
             # TBD timeout=1,  # waiting time for request to complete
             # TBD strict=True,  # use strict timing, t1.5 for Modbus RTU
-            defer_start=defer_start  # Only define server do not activate
+            defer_start=defer_start,  # Only define server do not activate
         )
     elif server_id == "serial":
         # socat -d -d PTY,link=/tmp/ptyp0,raw,echo=0,ispeed=9600 PTY,
@@ -199,7 +199,7 @@ async def run_server(args=None):
             # ignore_missing_slaves=True,  # ignore request to a missing slave
             # broadcast_enable=False,  # treat unit_id 0 as broadcast address,
             # strict=True,  # use strict timing, t1.5 for Modbus RTU
-            defer_start=defer_start  # Only define server do not activate
+            defer_start=defer_start,  # Only define server do not activate
         )
     elif server_id == "tls":
         server = await StartTlsServer(
@@ -221,10 +221,11 @@ async def run_server(args=None):
             # broadcast_enable=False,  # treat unit_id 0 as broadcast address,
             # TBD timeout=1,  # waiting time for request to complete
             # TBD strict=True,  # use strict timing, t1.5 for Modbus RTU
-            defer_start=defer_start  # Only define server do not activate
+            defer_start=defer_start,  # Only define server do not activate
         )
     return server
 
+
 # --------------------------------------------------------------------------- #
 # Extra code, to allow commandline parameters instead of changing the code
 # --------------------------------------------------------------------------- #

examples/server_sync.py

@@ -162,7 +162,7 @@ def run_server(args=None):
             # broadcast_enable=False,  # treat unit_id 0 as broadcast address,
             # TBD timeout=1,  # waiting time for request to complete
             # TBD strict=True,  # use strict timing, t1.5 for Modbus RTU
-            defer_start=defer_start  # Only define server do not activate
+            defer_start=defer_start,  # Only define server do not activate
         )
     elif server_id == "udp":
         server = StartUdpServer(
@@ -179,7 +179,7 @@ def run_server(args=None):
             # broadcast_enable=False,  # treat unit_id 0 as broadcast address,
             # TBD timeout=1,  # waiting time for request to complete
             # TBD strict=True,  # use strict timing, t1.5 for Modbus RTU
-            defer_start=defer_start  # Only define server do not activate
+            defer_start=defer_start,  # Only define server do not activate
         )
     elif server_id == "serial":
         # socat -d -d PTY,link=/tmp/ptyp0,raw,echo=0,ispeed=9600 PTY,
@@ -200,7 +200,7 @@ def run_server(args=None):
             # ignore_missing_slaves=True,  # ignore request to a missing slave
             # broadcast_enable=False,  # treat unit_id 0 as broadcast address,
             # strict=True,  # use strict timing, t1.5 for Modbus RTU
-            defer_start=defer_start  # Only define server do not activate
+            defer_start=defer_start,  # Only define server do not activate
         )
     elif server_id == "tls":
         server = StartTlsServer(
@@ -222,7 +222,7 @@ def run_server(args=None):
             # broadcast_enable=False,  # treat unit_id 0 as broadcast address,
             # TBD timeout=1,  # waiting time for request to complete
             # TBD strict=True,  # use strict timing, t1.5 for Modbus RTU
-            defer_start=defer_start  # Only define server do not activate
+            defer_start=defer_start,  # Only define server do not activate
         )
     return server
 

pymodbus/client/async_serial.py

@@ -119,9 +119,7 @@ def protocol_lost_connection(self, protocol):
         if self.connected:
             _logger.info("Serial lost connection.")
             if protocol is not self.protocol:
-                _logger.error(
-                    "Serial: protocol is not self.protocol."
-                )
+                _logger.error("Serial: protocol is not self.protocol.")
 
             self._connected_event.clear()
             self.protocol = None

pymodbus/client/async_tcp.py

@@ -105,8 +105,7 @@ def protocol_lost_connection(self, protocol):
         _logger.info("Protocol lost connection.")
         if protocol is not self.protocol:
             _logger.error(
-                "Factory protocol callback called "
-                "from unexpected protocol instance."
+                "Factory protocol callback called from unexpected protocol instance."
             )
 
         self.connected = False

pymodbus/client/async_tls.py

@@ -14,7 +14,9 @@
 _logger = logging.getLogger(__name__)
 
 
-def sslctx_provider(sslctx=None, certfile=None, keyfile=None, password=None):  # pylint: disable=missing-type-doc
+def sslctx_provider(
+    sslctx=None, certfile=None, keyfile=None, password=None
+):  # pylint: disable=missing-type-doc
     """Provide the SSLContext for ModbusTlsClient.
 
     If the user defined SSLContext is not passed in, sslctx_provider will

pymodbus/client/async_udp.py

@@ -95,9 +95,7 @@ async def close(self):  # pylint: disable=invalid-overridden-method
     def _create_protocol(self, host=None, port=0):
         """Create initialized protocol instance with factory function."""
         protocol = ModbusClientProtocol(
-            use_udp=True,
-            framer=self.params.framer,
-            **self.params.kwargs
+            use_udp=True, framer=self.params.framer, **self.params.kwargs
         )
         protocol.params.host = host
         protocol.params.port = port

pymodbus/client/base.py

@@ -90,7 +90,7 @@ def __init__(
         strict: bool = Defaults.Strict,
         broadcast_enable: bool = Defaults.BroadcastEnable,
         reconnect_delay: int = Defaults.ReconnectDelay,
-        **kwargs: any
+        **kwargs: any,
     ) -> None:
         """Initialize a client instance."""
         self.params = self._params()
@@ -249,12 +249,7 @@ class ModbusClientProtocol(
     transport = None
 
     def __init__(
-        self,
-        host="127.0.0.1",
-        port=502,
-        source_address=None,
-        use_udp=False,
-        **kwargs
+        self, host="127.0.0.1", port=502, source_address=None, use_udp=False, **kwargs
     ):
         """Initialize a Modbus TCP/UDP asynchronous client"""
         super().__init__(**kwargs)
@@ -287,7 +282,9 @@ def connection_made(self, transport):
         self._connection_made()
 
         if self.factory:
-            self.factory.protocol_made_connection(self)  # pylint: disable=no-member,useless-suppression
+            self.factory.protocol_made_connection(  # pylint: disable=no-member,useless-suppression
+                self
+            )
 
     async def close(self):  # pylint: disable=invalid-overridden-method
         """Close connection."""
@@ -304,7 +301,9 @@ def connection_lost(self, reason):
         self._connection_lost(reason)
 
         if self.factory:
-            self.factory.protocol_lost_connection(self)  # pylint: disable=no-member,useless-suppression
+            self.factory.protocol_lost_connection(  # pylint: disable=no-member,useless-suppression
+                self
+            )
 
     def data_received(self, data):
         """Call when some data is received.