From: autofix-ci[bot] <114827586+autofix-ci[bot]@users.noreply.github.com>
Date: Tue, 25 Jun 2024 19:56:48 +0000 (+0000)
Subject: [autofix.ci] apply automated fixes
X-Git-Tag: v1.3.7~17^2~10
X-Git-Url: https://git.piment-noir.org/?a=commitdiff_plain;h=acf133cd0efc14b1e45719a88dc57fac71bb1c90;p=e-mobility-charging-stations-simulator.git

[autofix.ci] apply automated fixes
---

diff --git a/tests/ocpp-server/server.py b/tests/ocpp-server/server.py
index 98a9d853..cba20092 100644
--- a/tests/ocpp-server/server.py
+++ b/tests/ocpp-server/server.py
@@ -96,7 +96,9 @@ class ChargePoint(ocpp.v201.ChargePoint):
         return ocpp.v201.call_result.MeterValues()
 
     @on(Action.GetBaseReport)
-    async def on_get_base_report(self, request_id: int, report_base: ReportBaseType, **kwargs):
+    async def on_get_base_report(
+        self, request_id: int, report_base: ReportBaseType, **kwargs
+    ):
         logging.info("Received %s", Action.GetBaseReport)
         return ocpp.v201.call_result.GetBaseReport(status="Accepted")
 
@@ -147,6 +149,7 @@ async def send_ocpp_command(cp, command_name, delay=None, period=None):
 
     # If period is not None, send command repeatedly with period interval
     if period:
+
         async def send_command_repeatedly():
             while True:
                 command_name = await cp.receive_command()
@@ -160,8 +163,10 @@ async def send_ocpp_command(cp, command_name, delay=None, period=None):
                             await cp.send_get_base_report()
                         case _:
                             logging.warning(f"Unsupported command {command_name}")
-                except Exception as e:
-                    logging.exception(f"Failure while processing command {command_name}")
+                except Exception:
+                    logging.exception(
+                        f"Failure while processing command {command_name}"
+                    )
                 finally:
                     await asyncio.sleep(period)
 
@@ -203,7 +208,9 @@ async def on_connect(websocket, path):
         await cp.start()
         # Check if request argument is specified
         if args.request:
-            asyncio.create_task(send_ocpp_command(cp, args.request, args.delay, args.period))
+            asyncio.create_task(
+                send_ocpp_command(cp, args.request, args.delay, args.period)
+            )
 
     except ConnectionClosed:
         logging.info("ChargePoint %s closed connection", cp.id)