chore: reduce the log level of vulnerability go service forwarding to debug (#3955)

Signed-off-by: anil <[email protected]>

Author: epipav

services/apps/git_integration/src/crowdgit/services/utils.py

@@ -1,8 +1,9 @@
 import asyncio
-import logging
 import re
 from urllib.parse import urlparse
 
+import loguru
+
 from crowdgit.errors import (
     CommandExecutionError,
     CommandTimeoutError,
@@ -168,7 +169,8 @@ async def run_shell_command(
     cwd: str = None,
     timeout: float | None = None,
     input_text: str | bytes | None = None,
-    stderr_logger: logging.Logger | None = None,
+    stderr_logger: loguru.Logger | None = None,
+    stderr_log_level: str = "INFO",
 ) -> str:
     """
     Run shell command asynchronously and return output on success, raise exception on failure.
@@ -179,6 +181,7 @@ async def run_shell_command(
         timeout: Command timeout in seconds
         input_text: Text (str) or bytes to send to stdin (will automatically append newline if not present)
         stderr_logger: If provided, a logger whose .info() method is called with each stderr line in real-time
+        stderr_log_level: Log level for stderr lines (default: "INFO")
 
     Returns:
         str: Command stdout output
@@ -230,7 +233,7 @@ async def _stream() -> None:
                     async for raw_line in process.stderr:
                         line = _safe_decode(raw_line).rstrip()
                         if line:
-                            stderr_logger.info(line)
+                            stderr_logger.log(stderr_log_level, line)
                             stderr_lines.append(line)
 
                 stdout, _ = await asyncio.gather(process.stdout.read(), _stream())

services/apps/git_integration/src/crowdgit/services/vulnerability_scanner/vulnerability_scanner_service.py

@@ -36,6 +36,7 @@ async def run(self, repo_id: str, repo_path: str, repo_url: str) -> None:
             output = await run_shell_command(
                 [self.vulnerability_scanner_executable, repo_path, repo_url],
                 stderr_logger=self.logger,
+                stderr_log_level="DEBUG",
             )
         except Exception as e:
             self.logger.warning(f"Scanner failed for {repo_url}: {e}")
@@ -54,6 +55,7 @@ async def run(self, repo_id: str, repo_path: str, repo_url: str) -> None:
                             "--no-transitive",
                         ],
                         stderr_logger=self.logger,
+                        stderr_log_level="DEBUG",
                     )
                 except Exception as retry_err:
                     self.logger.error(f"Retry also failed for {repo_url}: {retry_err}")
@@ -68,7 +70,7 @@ async def run(self, repo_id: str, repo_path: str, repo_url: str) -> None:
                 output = None
 
         if output is not None:
-            self.logger.info(f"Vulnerability scanner output: {output}")
+            self.logger.debug(f"Vulnerability scanner output: {output}")
             try:
                 json_output = json.loads(output)
             except json.JSONDecodeError as e: