feat: option to output json logs to console and env option to switch between json and pretty for console logging (#63)

Author: rishikesh-jentic

agents/standard_agent.py

@@ -13,10 +13,14 @@
 from  agents.llm.base_llm import BaseLLM
 from  agents.tools.base import JustInTimeToolingBase
 from  agents.goal_preprocessor.base import BaseGoalPreprocessor
+from  agents.prompts import load_prompts
 
 from  uuid import uuid4
+import time
 from  enum import Enum
-from agents.prompts import load_prompts
+from utils.logger import get_logger
+
+logger = get_logger(__name__)
 
 _PROMPTS = load_prompts("agent", required_prompts=["summarize"])
 
@@ -68,6 +72,7 @@ def state(self) -> AgentState:
     def solve(self, goal: str) -> ReasoningResult:
         """Solves a goal synchronously (library-style API)."""
         run_id = uuid4().hex
+        start_time = time.perf_counter()
 
         if self.goal_preprocessor:
             revised_goal, intervention_message = self.goal_preprocessor.process(goal, self.memory.get("conversation_history"))
@@ -86,6 +91,19 @@ def solve(self, goal: str) -> ReasoningResult:
             self.memory[f"result:{run_id}"] = result
             self.memory["conversation_history"].append({"goal": goal, "result": result.final_answer})
             self._state = AgentState.READY
+
+            duration_ms = int((time.perf_counter() - start_time) * 1000)
+            logger.info(
+                "final_result",
+                run_id=run_id,
+                success=result.success,
+                iterations=result.iterations,
+                tool_calls_count=len(result.tool_calls or []),
+                duration_ms=duration_ms,
+                goal=goal,
+                final_answer_preview=((result.final_answer[:200] + "…") if (result.final_answer and len(result.final_answer) > 200) else result.final_answer),
+                model=getattr(self.llm, "model", None),
+            )
             return result
 
         except Exception:

config.json

@@ -4,14 +4,13 @@
 
     "console": {
       "enabled": true,
-      "format": "%(asctime)s | %(levelname_coloured)s | %(name)s: %(message)s"
+      "renderer": "pretty"
     },
 
     "file": {
       "enabled": true,
       "level": "DEBUG",
       "path": "logs/standard_agent.log",
-      "format": "%(asctime)s | %(levelname)s | %(name)s | %(message)s",
       "rotation": {
         "enabled": true,
         "max_bytes": 10485760,

utils/logger.py

@@ -62,14 +62,23 @@ def _pre_chain() -> list:
         structlog.processors.TimeStamper(fmt="ISO", key=TIME_KEY),
     ]
 
-def _build_console_handler(level: int) -> logging.Handler:
-    formatter = structlog.stdlib.ProcessorFormatter(
-        foreign_pre_chain=_pre_chain(),
-        processors=[
+def _build_console_handler(level: int, renderer: str) -> logging.Handler:
+    """Build a console handler with either pretty or JSON rendering."""
+
+    processors: list[Any]
+    if renderer == "json":
+        processors = [
+            structlog.stdlib.ProcessorFormatter.remove_processors_meta,
+            structlog.processors.EventRenamer(to="message"),
+            structlog.processors.JSONRenderer(),
+        ]
+    else:  # pretty (default)
+        processors = [
             structlog.stdlib.ProcessorFormatter.remove_processors_meta,
             structlog.dev.ConsoleRenderer(colors=_supports_colour(), timestamp_key=TIME_KEY),
-        ],
-    )
+        ]
+
+    formatter = structlog.stdlib.ProcessorFormatter(foreign_pre_chain=_pre_chain(), processors=processors,)
     handler = logging.StreamHandler(sys.stdout)
     handler.setLevel(level)
     handler.setFormatter(formatter)
@@ -103,10 +112,13 @@ def _build_file_handler(file_cfg: Dict[str, Any]) -> logging.Handler:
 
 
 def init_logger(config_path: str | Path | None = None) -> None:
-    """Structured setup for hosted agents: JSON for files and non-TTY stdout.
+    """Structured logging setup.
+
+    Console renderer is configurable via config, with env override support when needed:
+    - Config: logging.console.renderer = "json" | "pretty" (default: pretty)
+    - Env (optional): LOG_CONSOLE_RENDERER=pretty|json (wins over config)
 
-    - Local TTY console: coloured ConsoleRenderer for readability
-    - Non-TTY stdout and files: JSON for ingestion by log frameworks
+    Files always use JSON with optional rotation.
     """
     cfg = _read_cfg(config_path)
 
@@ -125,7 +137,10 @@ def init_logger(config_path: str | Path | None = None) -> None:
     # Console handler enabled by default
     console_enabled = cfg.get("console", {}).get("enabled", True)
     if console_enabled:
-        handlers.append(_build_console_handler(root_level))
+        renderer = os.getenv("LOG_CONSOLE_RENDERER") or cfg.get("console", {}).get("renderer", "pretty").strip().lower()
+        if renderer not in {"json", "pretty"}:
+            raise ValueError(f"Invalid console logging renderer option: {renderer!r}. Allowed: json, pretty")
+        handlers.append(_build_console_handler(root_level, renderer))
 
     # File handler (JSON) if enabled
     file_cfg = cfg.get("file", {})