Remove "pragma no cover". (#1935)

janiversen · web-flow · commit a7ca62a6d759 · 2024-01-14T17:23:47.000+01:00
diff --git a/examples/client_async.py b/examples/client_async.py
@@ -137,4 +137,4 @@ async def main(cmdline=None):
 
 
 if __name__ == "__main__":
-    asyncio.run(main(), debug=True)  # pragma: no cover
+    asyncio.run(main(), debug=True)
diff --git a/examples/client_async_calls.py b/examples/client_async_calls.py
@@ -227,4 +227,4 @@ async def main(cmdline=None):
 
 
 if __name__ == "__main__":
-    asyncio.run(main())  # pragma: no cover
+    asyncio.run(main())
diff --git a/examples/client_calls.py b/examples/client_calls.py
@@ -150,7 +150,7 @@ def handle_input_registers(client):
     assert len(rr.registers) == 8
 
 
-def execute_information_requests(client):  # pragma no cover
+def execute_information_requests(client):
     """Execute extended information requests."""
     _logger.info("### Running information requests.")
     rr = client.read_device_information(slave=SLAVE)
@@ -176,7 +176,7 @@ def execute_information_requests(client):  # pragma no cover
     # assert not (rr.event_count + rr.message_count + len(rr.events))
 
 
-def execute_diagnostic_requests(client):  # pragma no cover
+def execute_diagnostic_requests(client):
     """Execute extended diagnostic requests."""
     _logger.info("### Running diagnostic requests.")
     message = b"OK"
@@ -226,4 +226,4 @@ def main(cmdline=None):
 
 
 if __name__ == "__main__":
-    main()  # pragma: no cover
+    main()
diff --git a/examples/client_custom_msg.py b/examples/client_custom_msg.py
@@ -30,7 +30,7 @@
 # --------------------------------------------------------------------------- #
 
 
-class CustomModbusResponse(ModbusResponse):  # pragma no cover
+class CustomModbusResponse(ModbusResponse):
     """Custom modbus response."""
 
     function_code = 55
@@ -78,11 +78,11 @@ def encode(self):
         """Encode."""
         return struct.pack(">HH", self.address, self.count)
 
-    def decode(self, data):  # pragma no cover
+    def decode(self, data):
         """Decode."""
         self.address, self.count = struct.unpack(">HH", data)
 
-    def execute(self, context):  # pragma no cover
+    def execute(self, context):
         """Execute."""
         if not 1 <= self.count <= 0x7D0:
             return self.doException(ModbusExceptions.IllegalValue)
@@ -134,4 +134,4 @@ async def main(host="localhost", port=5020):
 
 
 if __name__ == "__main__":
-    asyncio.run(main())  # pragma: no cover
+    asyncio.run(main())
diff --git a/examples/client_payload.py b/examples/client_payload.py
@@ -143,4 +143,4 @@ async def main(cmdline=None):
 
 
 if __name__ == "__main__":
-    asyncio.run(main())  # pragma: no cover
+    asyncio.run(main())
diff --git a/examples/client_sync.py b/examples/client_sync.py
@@ -95,7 +95,7 @@ def setup_sync_client(description=None, cmdline=None):
             #    stopbits=1,
             #    handle_local_echo=False,
         )
-    elif args.comm == "tls":  # pragma no cover
+    elif args.comm == "tls":
         client = modbusClient.ModbusTlsClient(
             args.host,
             port=args.port,
@@ -146,4 +146,4 @@ def main(cmdline=None):
 
 
 if __name__ == "__main__":
-    main()  # pragma: no cover
+    main()
diff --git a/examples/contrib/solar.py b/examples/contrib/solar.py
@@ -83,4 +83,4 @@ def solar_calls(client):
 
 
 if __name__ == "__main__":
-    main()  # pragma: no cover
+    main()
diff --git a/examples/datastore_simulator.py b/examples/datastore_simulator.py
@@ -180,4 +180,4 @@ async def main(cmdline=None):
 
 
 if __name__ == "__main__":
-    asyncio.run(main(), debug=True)  # pragma: no cover
+    asyncio.run(main(), debug=True)
diff --git a/examples/helper.py b/examples/helper.py
@@ -90,7 +90,7 @@ def get_commandline(server=False, description=None, extras=None, cmdline=None):
             default=10,
             type=float,
         )
-    if extras:  # pragma no cover
+    if extras:
         for extra in extras:
             parser.add_argument(extra[0], **extra[1])
     args = parser.parse_args(cmdline)
@@ -119,13 +119,13 @@ def get_certificate(suffix: str):
     delimiter = "\\" if os.name == "nt" else "/"
     cwd = os.getcwd().split(delimiter)[-1]
     if cwd == "examples":
-        path = "."  # pragma no cover
+        path = "."
     elif cwd == "sub_examples":
-        path = "../../examples"  # pragma no cover
+        path = "../../examples"
     elif cwd == "test":
         path = "../examples"
     elif cwd == "pymodbus":
-        path = "examples"  # pragma no cover
+        path = "examples"
     else:
         raise RuntimeError(f"**Error** Cannot find certificate path={cwd}")
     return f"{path}/certificates/pymodbus.{suffix}"
diff --git a/examples/message_generator.py b/examples/message_generator.py
@@ -215,4 +215,4 @@ def generate_messages(cmdline=None):
 
 
 if __name__ == "__main__":
-    generate_messages()  # pragma: no cover
+    generate_messages()
diff --git a/examples/message_parser.py b/examples/message_parser.py
@@ -81,13 +81,13 @@ def decode(self, message):
             print("-" * 80)
             try:
                 decoder.addToFrame(message)
-                if decoder.checkFrame():  # pragma no cover
+                if decoder.checkFrame():
                     slave = decoder._header.get(  # pylint: disable=protected-access
                         "uid", 0x00
                     )
                     decoder.advanceFrame()
                     decoder.processIncomingPacket(message, self.report, slave)
-                else:  # pragma no cover
+                else:
                     self.check_errors(decoder, message)
             except Exception:  # pylint: disable=broad-except
                 self.check_errors(decoder, message)
@@ -97,7 +97,7 @@ def check_errors(self, decoder, message):
         txt = f"Unable to parse message - {message} with {decoder}"
         _logger.error(txt)
 
-    def report(self, message):  # pragma no cover
+    def report(self, message):
         """Print the message information."""
         print(
             "%-15s = %s"  # pylint: disable=consider-using-f-string
@@ -145,7 +145,7 @@ def parse_messages(cmdline=None):
     """Do a helper method to generate the messages to parse."""
     args = get_commandline(cmdline=cmdline)
     _logger.setLevel(args.log.upper())
-    if not args.message:  # pragma no cover
+    if not args.message:
         _logger.error("Missing --message.")
         return
 
@@ -167,4 +167,4 @@ def main(cmdline=None):
 
 
 if __name__ == "__main__":
-    main()  # pragma: no cover
+    main()
diff --git a/examples/modbus_forwarder.py b/examples/modbus_forwarder.py
@@ -1,5 +1,4 @@
 #!/usr/bin/env python3
-# pragma no cover
 """Pymodbus synchronous forwarder.
 
 This is a repeater or converter and an example of just how powerful datastore is.
@@ -82,4 +81,4 @@ async def async_helper():
 
 
 if __name__ == "__main__":
-    asyncio.run(async_helper())  # pragma: no cover
+    asyncio.run(async_helper())
diff --git a/examples/server_async.py b/examples/server_async.py
@@ -229,4 +229,4 @@ async def async_helper():
 
 
 if __name__ == "__main__":
-    asyncio.run(async_helper(), debug=True)  # pragma: no cover
+    asyncio.run(async_helper(), debug=True)
diff --git a/examples/server_callback.py b/examples/server_callback.py
@@ -66,4 +66,4 @@ async def run_callback_server(cmdline=None):
 
 
 if __name__ == "__main__":
-    asyncio.run(run_callback_server(), debug=True)  # pragma: no cover
+    asyncio.run(run_callback_server(), debug=True)
diff --git a/examples/server_hook.py b/examples/server_hook.py
@@ -83,4 +83,4 @@ async def main():
 
 
 if __name__ == "__main__":
-    asyncio.run(main(), debug=True)  # pragma: no cover
+    asyncio.run(main(), debug=True)
diff --git a/examples/server_payload.py b/examples/server_payload.py
@@ -65,4 +65,4 @@ async def main(cmdline=None):
 
 
 if __name__ == "__main__":
-    asyncio.run(main(), debug=True)  # pragma: no cover
+    asyncio.run(main(), debug=True)
diff --git a/examples/server_sync.py b/examples/server_sync.py
@@ -105,7 +105,7 @@ def run_sync_server(args):
             # broadcast_enable=False,  # treat slave_id 0 as broadcast address,
             # strict=True,  # use strict timing, t1.5 for Modbus RTU
         )
-    elif args.comm == "tls":  # pragma no cover
+    elif args.comm == "tls":
         address = ("", args.port) if args.port else None
         server = StartTlsServer(
             context=args.context,  # Data storage
@@ -139,4 +139,4 @@ def sync_helper():
 
 
 if __name__ == "__main__":
-    sync_helper()  # pragma: no cover
+    sync_helper()
diff --git a/examples/server_updating.py b/examples/server_updating.py
@@ -115,4 +115,4 @@ async def main(cmdline=None):
 
 
 if __name__ == "__main__":
-    asyncio.run(main(), debug=True)  # pragma: no cover
+    asyncio.run(main(), debug=True)
diff --git a/examples/simple_async_client.py b/examples/simple_async_client.py
@@ -81,7 +81,7 @@ async def run_async_simple_client(comm, host, port, framer=Framer.SOCKET):
             # password="none",
             server_hostname="localhost",
         )
-    else:  # pragma no cover
+    else:
         print(f"Unknown client {comm} selected")
         return
 
@@ -94,15 +94,15 @@ async def run_async_simple_client(comm, host, port, framer=Framer.SOCKET):
     try:
         # See all calls in client_calls.py
         rr = await client.read_coils(1, 1, slave=1)
-    except ModbusException as exc:  # pragma no cover
+    except ModbusException as exc:
         print(f"Received ModbusException({exc}) from library")
         client.close()
         return
-    if rr.isError():  # pragma no cover
+    if rr.isError():
         print(f"Received Modbus library error({rr})")
         client.close()
         return
-    if isinstance(rr, ExceptionResponse):  # pragma no cover
+    if isinstance(rr, ExceptionResponse):
         print(f"Received Modbus library exception ({rr})")
         # THIS IS NOT A PYTHON EXCEPTION, but a valid modbus message
         client.close()
@@ -114,4 +114,4 @@ async def run_async_simple_client(comm, host, port, framer=Framer.SOCKET):
 if __name__ == "__main__":
     asyncio.run(
         run_async_simple_client("tcp", "127.0.0.1", 5020), debug=True
-    )  # pragma: no cover
+    )
diff --git a/examples/simple_sync_client.py b/examples/simple_sync_client.py
@@ -83,7 +83,7 @@ def run_sync_simple_client(comm, host, port, framer=Framer.SOCKET):
             # password=None,
             server_hostname="localhost",
         )
-    else:  # pragma no cover
+    else:
         print(f"Unknown client {comm} selected")
         return
 
@@ -97,18 +97,18 @@ def run_sync_simple_client(comm, host, port, framer=Framer.SOCKET):
         print(f"Received ModbusException({exc}) from library")
         client.close()
         return
-    if rr.isError():  # pragma no cover
+    if rr.isError():
         print(f"Received Modbus library error({rr})")
         client.close()
         return
-    if isinstance(rr, ExceptionResponse):  # pragma no cover
+    if isinstance(rr, ExceptionResponse):
         print(f"Received Modbus library exception ({rr})")
         # THIS IS NOT A PYTHON EXCEPTION, but a valid modbus message
         client.close()
 
-    print("close connection")  # pragma no cover
-    client.close()  # pragma no cover
+    print("close connection")
+    client.close()
 
 
 if __name__ == "__main__":
-    run_sync_simple_client("tcp", "127.0.0.1", "5020")  # pragma: no cover
+    run_sync_simple_client("tcp", "127.0.0.1", "5020")
diff --git a/examples/simulator.py b/examples/simulator.py
@@ -91,4 +91,4 @@ async def run_simulator():
 
 
 if __name__ == "__main__":
-    asyncio.run(run_simulator(), debug=True)  # pragma no cover
+    asyncio.run(run_simulator(), debug=True)
diff --git a/pymodbus/server/async_io.py b/pymodbus/server/async_io.py
@@ -69,7 +69,7 @@ def callback_connected(self) -> None:
             # schedule the connection handler on the event loop
             self.handler_task = asyncio.create_task(self.handle())
             self.handler_task.set_name("server connection handler")
-        except Exception as exc:  # pragma: no cover pylint: disable=broad-except
+        except Exception as exc:  # pylint: disable=broad-except
             Log.error(
                 "Server callback_connected exception: {}; {}",
                 exc,
@@ -112,7 +112,7 @@ async def inner_handle(self):
 
         # if broadcast is enabled make sure to
         # process requests to address 0
-        if self.server.broadcast_enable:  # pragma: no cover
+        if self.server.broadcast_enable:
             if 0 not in slaves:
                 slaves.append(0)
 
@@ -222,7 +222,7 @@ def send(self, message, addr, **kwargs):
         else:
             Log.debug("Skipping sending response!!")
 
-    async def _recv_(self):  # pragma: no cover
+    async def _recv_(self):
         """Receive data from the network."""
         try:
             result = await self.receive_queue.get()
@@ -497,7 +497,7 @@ class ModbusSerialServer(ModbusBaseServer):
 
     def __init__(
         self, context, framer=Framer.RTU, identity=None, **kwargs
-    ):  # pragma: no cover
+    ):
         """Initialize the socket server.
 
         If the identity structure is not passed in, the ModbusControlBlock
@@ -690,7 +690,7 @@ async def StartAsyncSerialServer(  # pylint: disable=invalid-name,dangerous-defa
     identity=None,
     custom_functions=[],
     **kwargs,
-):  # pragma: no cover
+):
     """Start and run a serial modbus server.
 
     :param context: The ModbusServerContext datastore
diff --git a/pymodbus/transport/transport.py b/pymodbus/transport/transport.py
@@ -65,7 +65,7 @@
 if sys.version_info.minor == 11:
     USEEXCEPTIONS: tuple[type[Any], type[Any]] | type[Any] = OSError
 else:
-    USEEXCEPTIONS = (  # pragma: no cover
+    USEEXCEPTIONS = (
         asyncio.TimeoutError,
         OSError,
     )

Original file line number	Diff line number	Diff line change
`@@ -137,4 +137,4 @@ async def main(cmdline=None):`
`137`	`137`
`138`	`138`
`139`	`139`	`if __name__ == "__main__":`
`140`		`- asyncio.run(main(), debug=True) # pragma: no cover`
	`140`	`+ asyncio.run(main(), debug=True)`
Original file line number	Diff line number	Diff line change
`@@ -227,4 +227,4 @@ async def main(cmdline=None):`
`227`	`227`
`228`	`228`
`229`	`229`	`if __name__ == "__main__":`
`230`		`- asyncio.run(main()) # pragma: no cover`
	`230`	`+ asyncio.run(main())`
Original file line number	Diff line number	Diff line change
`@@ -143,4 +143,4 @@ async def main(cmdline=None):`
`143`	`143`
`144`	`144`
`145`	`145`	`if __name__ == "__main__":`
`146`		`- asyncio.run(main()) # pragma: no cover`
	`146`	`+ asyncio.run(main())`
Original file line number	Diff line number	Diff line change
`@@ -83,4 +83,4 @@ def solar_calls(client):`
`83`	`83`
`84`	`84`
`85`	`85`	`if __name__ == "__main__":`
`86`		`- main() # pragma: no cover`
	`86`	`+ main()`
Original file line number	Diff line number	Diff line change
`@@ -180,4 +180,4 @@ async def main(cmdline=None):`
`180`	`180`
`181`	`181`
`182`	`182`	`if __name__ == "__main__":`
`183`		`- asyncio.run(main(), debug=True) # pragma: no cover`
	`183`	`+ asyncio.run(main(), debug=True)`
Original file line number	Diff line number	Diff line change
`@@ -215,4 +215,4 @@ def generate_messages(cmdline=None):`
`215`	`215`
`216`	`216`
`217`	`217`	`if __name__ == "__main__":`
`218`		`- generate_messages() # pragma: no cover`
	`218`	`+ generate_messages()`