prefix for log_process()

1 files changed, 4 insertions, 1 deletions

diff --git a/kvmd/aioproc.py b/kvmd/aioproc.py
index 37b44e5c..57ae0f85 100644
--- a/kvmd/aioproc.py
+++ b/kvmd/aioproc.py
@@ -67,13 +67,16 @@ async def log_process(
     cmd: List[str],
     logger: logging.Logger,
     env: Optional[Dict[str, str]]=None,
+    prefix: str="",
 ) -> asyncio.subprocess.Process:  # pylint: disable=no-member
 
     (proc, stdout) = await read_process(cmd, env=env)
     if stdout:
         log = (logger.info if proc.returncode == 0 else logger.error)
+        if prefix:
+            prefix += " "
         for line in stdout.split("\n"):
-            log("=> %s", line)
+            log("%s=> %s", prefix, line)
     return proc