QA bugfixing

Author: Andrei Bratu

src/humanloop/decorators/flow.py

@@ -1,4 +1,5 @@
 import logging
+import traceback
 import uuid
 from functools import wraps
 from typing import Any, Callable, Mapping, Optional, Sequence
@@ -67,7 +68,8 @@ def wrapper(*args: Sequence[Any], **kwargs: Mapping[str, Any]) -> Any:
                     output = func(*args, **kwargs)
                     error = None
                 except Exception as e:
-                    logger.error(f"{func.__name__}: {e}")
+                    # print error, line of code, and function name
+                    logger.error(f"Error calling {func.__name__}: {e}")
                     output = None
                     error = str(e)
 

src/humanloop/decorators/prompt.py

@@ -112,7 +112,7 @@ def wrapper(*args: Sequence[Any], **kwargs: Mapping[str, Any]) -> Any:
                     output = func(*args, **kwargs)
                     error = None
                 except Exception as e:
-                    logger.error(f"{func.__name__}: {e}")
+                    logger.error(f"Error calling {func.__name__}: {e}")
                     output = None
                     error = str(e)
 

src/humanloop/decorators/tool.py

@@ -71,7 +71,7 @@ def wrapper(*args, **kwargs):
                     output = func(*args, **kwargs)
                     error = None
                 except Exception as e:
-                    logger.error(f"{func.__name__}: {e}")
+                    logger.error(f"Error calling {func.__name__}: {e}")
                     output = None
                     error = str(e)
 

src/humanloop/otel/exporter.py

@@ -31,7 +31,7 @@ class HumanloopSpanExporter(SpanExporter):
     Spans not created by Humanloop SDK decorators will be ignored.
     """
 
-    DEFAULT_NUMBER_THREADS = 1
+    DEFAULT_NUMBER_THREADS = 4
 
     def __init__(
         self,
@@ -257,10 +257,8 @@ def _export_flow(self, span: ReadableSpan) -> None:
         else:
             flow = file_object["flow"]
         path: str = file_object["path"]
-        if not isinstance(log_object["output"], str):
-            # Output expected to be a string, if decorated function
-            # does not return one, jsonify it
-            log_object["output"] = json.dumps(log_object["output"])
+        if "output" not in log_object:
+            log_object["output"] = None
         try:
             log_response = self._client.flows.log(
                 path=path,

src/humanloop/otel/processor.py

@@ -125,7 +125,7 @@ def _enrich_prompt_kernel(prompt_span: ReadableSpan, llm_provider_call_span: Rea
     prompt["max_tokens"] = prompt.get("max_tokens") or gen_ai_object.get("request", {}).get("max_tokens", None)
     prompt["presence_penalty"] = prompt.get("presence_penalty") or llm_object.get("presence_penalty", None)
     prompt["frequency_penalty"] = prompt.get("frequency_penalty") or llm_object.get("frequency_penalty", None)
-    prompt["tools"] = list(prompt.get("tools", {}).values())
+    prompt["tools"] = prompt.get("tools", [])
 
     try:
         # Validate the Prompt Kernel