feat: feature flag io_publisher

Author: onur-askui

src/askui/chat/api/runs/events/io_publisher.py

@@ -4,19 +4,30 @@
 import sys
 from typing import Any
 
+from askui.chat.api.dependencies import get_settings
 from askui.chat.api.runs.events.events import Event
 
 
 class IOPublisher:
     """Publisher that serializes events to JSON and writes to stdout."""
 
+    def __init__(self) -> None:
+        """Initialize the IO publisher."""
+        settings = get_settings()
+        self._enabled = settings.enable_io_events
+
     def publish(self, event: Event) -> None:
         """
         Publish an event by serializing it to JSON and writing to stdout.
 
+        If the publisher is disabled, this method does nothing.
+
         Args:
             event: The event to publish
         """
+        if not self._enabled:
+            return
+
         try:
             event_dict: dict[str, Any] = event.model_dump(mode="json")
             event_json = json.dumps(event_dict)

src/askui/chat/api/settings.py

@@ -118,3 +118,7 @@ class Settings(BaseSettings):
         default_factory=OtelSettings,
         description="OpenTelemetry configuration settings",
     )
+    enable_io_events: bool = Field(
+        default=False,
+        description="Whether to enable the publishing events to stdout",
+    )