fix(langextract): improve error handling, test reliability, and reduce code duplication

- Add LangextractSink.bridge_context_events() helper method to centralize context emitter setup
- Fix silent exception swallowing in langextract render command - now properly reports bridge failures
- Add proper skipif guard for optional dependency tests
- Use callback pattern for clean separation of CLI concerns

Co-authored-by: Mervin Praison <MervinPraison@users.noreply.github.com>

Author: praisonai-triage-agent[bot]

src/praisonai/praisonai/cli/app.py

@@ -70,20 +70,15 @@ def _setup_langextract_observability(*, verbose: bool = False) -> None:
         # Bridge the context emitter so regular Agent.start / tool calls / LLM
         # responses are captured as well.  Without this, typical single-agent
         # flows produce an empty trace (no agent_start/end, no tool events).
-        try:
-            from praisonaiagents.trace.context_events import (
-                ContextTraceEmitter,
-                set_context_emitter,
-            )
-            context_emitter = ContextTraceEmitter(
-                sink=sink.context_sink(),
-                session_id="praisonai-cli",
-                enabled=True,
-            )
-            set_context_emitter(context_emitter)
-        except Exception as e:  # pragma: no cover - defensive
+        def warn_handler(msg: str):
             if verbose:
-                typer.echo(f"Warning: could not bridge context emitter: {e}", err=True)
+                typer.echo(f"Warning: {msg}", err=True)
+                
+        LangextractSink.bridge_context_events(
+            sink=sink,
+            session_id="praisonai-cli",
+            warn_callback=warn_handler
+        )
 
     except ImportError:
         # Gracefully degrade if langextract not installed

src/praisonai/praisonai/cli/commands/langextract.py

@@ -82,19 +82,17 @@ def render(
 
     # Also bridge the context emitter so real agent runtime events
     # (agent_start/end, tool_call_*, llm_response) are captured.
-    try:
-        from praisonaiagents.trace.context_events import (
-            ContextTraceEmitter,
-            set_context_emitter,
-        )
-        context_emitter = ContextTraceEmitter(
-            sink=sink.context_sink(),
-            session_id="praisonai-langextract-render",
-            enabled=True,
-        )
-        set_context_emitter(context_emitter)
-    except Exception:
-        pass
+    from praisonai.observability.langextract import LangextractSink
+    
+    def warn_handler(msg: str):
+        # Warn user about bridge failure since this command specifically generates traces
+        typer.echo(f"Warning: {msg}", err=True)
+        
+    LangextractSink.bridge_context_events(
+        sink=sink,
+        session_id="praisonai-langextract-render",
+        warn_callback=warn_handler
+    )
 
     try:
         # Run the workflow

src/praisonai/praisonai/observability/langextract.py

@@ -154,6 +154,35 @@ def context_sink(self) -> "_ContextToActionBridge":
         """
         return _ContextToActionBridge(self)
 
+    @staticmethod
+    def bridge_context_events(sink: "LangextractSink", session_id: str, warn_callback=None) -> None:
+        """
+        Helper method to set up context event bridging for the given sink.
+        
+        Args:
+            sink: LangextractSink instance to bridge
+            session_id: Session ID for the context emitter
+            warn_callback: Optional callback function for warnings, called with message string
+        """
+        try:
+            from praisonaiagents.trace.context_events import (
+                ContextTraceEmitter,
+                set_context_emitter,
+            )
+            context_emitter = ContextTraceEmitter(
+                sink=sink.context_sink(),
+                session_id=session_id,
+                enabled=True,
+            )
+            set_context_emitter(context_emitter)
+        except ImportError:
+            # Context emitter bridging is optional if not available
+            if warn_callback:
+                warn_callback("ContextTraceEmitter not available")
+        except Exception as e:
+            if warn_callback:
+                warn_callback(f"could not bridge context emitter: {e}")
+
     # ---- TraceSinkProtocol -------------------------------------------------
 
     def emit(self, event: ActionEvent) -> None:

src/praisonai/tests/unit/test_langextract_sink.py

@@ -407,6 +407,7 @@ def test_bridge_maps_context_events_to_action_events(self):
         assert "agent_end" in types
         assert sink._source_text == "Write a haiku"
 
+    @pytest.mark.skipif(not _langextract_available(), reason="langextract not installed")
     def test_setup_observability_registers_context_emitter(self):
         """`--observe langextract` must install the bridge on the context emitter."""
         import praisonai.cli.app as cli_app