[autofix.ci] apply automated fixes
authorautofix-ci[bot] <114827586+autofix-ci[bot]@users.noreply.github.com>
Tue, 25 Jun 2024 19:56:48 +0000 (19:56 +0000)
committerGitHub <noreply@github.com>
Tue, 25 Jun 2024 19:56:48 +0000 (19:56 +0000)
tests/ocpp-server/server.py

index 98a9d8530790ccccc7bf333ef7e1445bff9952e6..cba2009275f9fb5a9ae443c5e928f0a3f99cfc22 100644 (file)
@@ -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)