fix lint

Author: Hao Ni (CSI Interfusion Co Ltd)

examples/apo/legacy_apo_lunch.py

@@ -24,6 +24,7 @@
 import asyncio
 from pathlib import Path
 
+
 async def stream_output(stream, name, pipe_type, buffer):
     """Asynchronously read output stream and print to console, also store in memory buffer"""
     while True:
@@ -34,13 +35,10 @@ async def stream_output(stream, name, pipe_type, buffer):
         print(f"[{name}] {text}")
         buffer.append(text)
 
+
 async def run(cmd, name, buffer):
     """Start a subprocess and launch the logging coroutine"""
-    proc = await asyncio.create_subprocess_exec(
-        *cmd,
-        stdout=asyncio.subprocess.PIPE,
-        stderr=asyncio.subprocess.PIPE
-    )
+    proc = await asyncio.create_subprocess_exec(*cmd, stdout=asyncio.subprocess.PIPE, stderr=asyncio.subprocess.PIPE)
     print(f"{name} started (pid={proc.pid})")
 
     # concurrently monitor stdout and stderr
@@ -49,6 +47,7 @@ async def run(cmd, name, buffer):
 
     return proc
 
+
 async def main():
     # prepare in-memory buffers for each process
     server_buffer = []
@@ -67,8 +66,9 @@ async def main():
 
     print("Logs saved to legacy_apo_server.log and legacy_apo_client.log")
 
+
 if __name__ == "__main__":
     try:
         asyncio.run(main())
     except KeyboardInterrupt:
-        print("\nInterrupted by user, cleaning up...")
+        print("\nInterrupted by user, cleaning up...")

examples/apo/legacy_apo_server.py

@@ -23,7 +23,7 @@ async def example_apo():
         "You are a helpful assistant.",
         "You are a knowledgeable AI.",
         "You are a friendly chatbot.",
-        "You are an experienced expert."
+        "You are an experienced expert.",
     ]
 
     prompt_and_rewards: list[tuple[str, float]] = []