From acf133cd0efc14b1e45719a88dc57fac71bb1c90 Mon Sep 17 00:00:00 2001 From: "autofix-ci[bot]" <114827586+autofix-ci[bot]@users.noreply.github.com> Date: Tue, 25 Jun 2024 19:56:48 +0000 Subject: [PATCH] [autofix.ci] apply automated fixes --- tests/ocpp-server/server.py | 15 +++++++++++---- 1 file changed, 11 insertions(+), 4 deletions(-) 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) -- 2.34.1