feat: Update error handling to log with warnings.warn()

src/galileo/utils/catch_log.py

@@ -1,22 +1,31 @@
 import asyncio
 import functools
 import logging
+import warnings
 from logging import Logger
 from typing import Any, Callable
 
 
 def warn_catch_exception(logger: Logger = logging.getLogger(__name__), exception: type[Exception] = Exception) -> Any:
     """
-    A function wrapper that catches exceptions and logs them to the logger.
+    A function wrapper that catches exceptions, logs them, and emits visible warnings.
+
+    This decorator ensures that observability code doesn't crash the user's application
+    while still providing visible feedback when errors occur.
+
+    Errors are:
+    1. Logged via standard Python logging (integrates with logging/tracing platforms)
+    2. Emitted as warnings (visible by default without any logging configuration)
 
     Parameters
     ----------
-    exception
-    logger
+    exception : type[Exception]
+        The base exception type to catch. Defaults to Exception.
 
     Returns
     -------
     Callable
+        The decorated function.
     """
 
     def wrapper(f: Callable) -> Callable:
@@ -25,7 +34,10 @@ def inner(*args: Any, **kwargs: Any) -> Any:
             try:
                 result = f(*args, **kwargs)
             except exception as err:
+                # Standard logging for integration with logging/tracing platforms
                 logger.warning(f"Error occurred during execution: {f.__name__}: {err}")
+                # Warning for immediate visibility without config
+                warnings.warn(f"Galileo: {f.__name__} failed: {err}", RuntimeWarning, stacklevel=2)
             else:
                 return result
 
@@ -38,16 +50,26 @@ def async_warn_catch_exception(
     logger: Logger = logging.getLogger(__name__), exception: type[Exception] = Exception
 ) -> Any:
     """
-    A function wrapper that catches exceptions and logs them to the logger.
+    An async function wrapper that catches exceptions, logs them, and emits visible warnings.
+
+    This decorator ensures that observability code doesn't crash the user's application
+    while still providing visible feedback when errors occur.
+
+    Errors are:
+    1. Logged via standard Python logging (integrates with logging/tracing platforms)
+    2. Emitted as warnings (visible by default without any logging configuration)
 
     Parameters
     ----------
-    exception
-    logger
+    logger : Logger
+        The logger to use for logging errors. Defaults to the module logger.
+    exception : type[Exception]
+        The base exception type to catch. Defaults to Exception.
 
     Returns
     -------
     Callable
+        The decorated function.
     """
 
     def wrapper(f: Callable) -> Callable:
@@ -56,7 +78,10 @@ async def inner(*args: Any, **kwargs: Any) -> Any:
             try:
                 result = await f(*args, **kwargs)
             except exception as err:
+                # Standard logging for integration with logging/tracing platforms
                 logger.warning(f"Error occurred during execution: {f.__name__}: {err}")
+                # Warning for immediate visibility without config
+                warnings.warn(f"Galileo: {f.__name__} failed: {err}", RuntimeWarning, stacklevel=2)
             else:
                 return result
 

tests/test_logger_batch.py

@@ -1046,6 +1046,7 @@ def test_get_last_output() -> None:
         input="input",
         output="llm output",
         name="test-span",
+        model="test-model",
         created_at=datetime.datetime.now(),
         duration_ns=1_000_000,
         status_code=200,
@@ -1280,7 +1281,7 @@ def test_set_session_id(mock_traces_client: Mock, mock_projects_client: Mock, mo
 
     # Log a trace
     logger.start_trace(input="input", name="test-trace", created_at=datetime.datetime.now())
-    logger.add_llm_span(input="input", output="output")
+    logger.add_llm_span(input="input", output="output", model="test-model")
     logger.conclude("output", status_code=200)
     logger.flush()
 
@@ -1352,7 +1353,7 @@ def test_start_session_with_external_id(
 
     # Log a trace
     logger.start_trace(input="input", name="test-trace", created_at=datetime.datetime.now())
-    logger.add_llm_span(input="input", output="output")
+    logger.add_llm_span(input="input", output="output", model="test-model")
     logger.conclude("output", status_code=200)
     logger.flush()