fix!: Make sure to JSON serialize objects before setting content tags (#1627)

* Coerce values when setting input and output tags for pipelines and components respectively

* Update README and pyproject

Author: sjrl

integrations/langfuse/README.md

@@ -35,8 +35,8 @@ Here's the correct way to set up your script:
 import os
 
 # Set environment variables first
-os.environ["LANGFUSE_HOST"] = "https://cloud.langfuse.com"
-os.environ["TOKENIZERS_PARALLELISM"] = "false"
+os.environ["LANGFUSE_SECRET_KEY"] = ""  # Your Langfuse secret key
+os.environ["LANGFUSE_PUBLIC_KEY"] = ""  # Your Langfuse public key
 os.environ["HAYSTACK_CONTENT_TRACING_ENABLED"] = "true"
 
 # Then import Haystack components
@@ -58,8 +58,8 @@ Here's a full example:
 ```python
 import os
 
-os.environ["LANGFUSE_HOST"] = "https://cloud.langfuse.com"
-os.environ["TOKENIZERS_PARALLELISM"] = "false"
+os.environ["LANGFUSE_SECRET_KEY"] = ""  # Your Langfuse secret key
+os.environ["LANGFUSE_PUBLIC_KEY"] = ""  # Your Langfuse public key
 os.environ["HAYSTACK_CONTENT_TRACING_ENABLED"] = "true"
 
 from haystack.components.builders import ChatPromptBuilder

integrations/langfuse/pyproject.toml

@@ -5,7 +5,7 @@ build-backend = "hatchling.build"
 [project]
 name = "langfuse-haystack"
 dynamic = ["version"]
-description = ''
+description = "Langfuse integration for Haystack"
 readme = "README.md"
 requires-python = ">=3.9"
 license = "Apache-2.0"
@@ -22,7 +22,7 @@ classifiers = [
   "Programming Language :: Python :: Implementation :: CPython",
   "Programming Language :: Python :: Implementation :: PyPy",
 ]
-dependencies = ["haystack-ai>=2.9.0", "langfuse"]
+dependencies = ["haystack-ai>=2.12.1", "langfuse"]
 
 [project.urls]
 Documentation = "https://github.com/deepset-ai/haystack-core-integrations/tree/main/integrations/langfuse#readme"

integrations/langfuse/src/haystack_integrations/tracing/langfuse/tracer.py

@@ -101,7 +101,8 @@ def set_content_tag(self, key: str, value: Any) -> None:
                 messages = [m.to_openai_dict_format() for m in value["messages"]]
                 self._span.update(input=messages)
             else:
-                self._span.update(input=value)
+                coerced_value = tracing_utils.coerce_tag_value(value)
+                self._span.update(input=coerced_value)
         elif key.endswith(".output"):
             if "replies" in value:
                 if all(isinstance(r, ChatMessage) for r in value["replies"]):
@@ -110,7 +111,8 @@ def set_content_tag(self, key: str, value: Any) -> None:
                     replies = value["replies"]
                 self._span.update(output=replies)
             else:
-                self._span.update(output=value)
+                coerced_value = tracing_utils.coerce_tag_value(value)
+                self._span.update(output=coerced_value)
 
         self._data[key] = value
 
@@ -286,9 +288,9 @@ def handle(self, span: LangfuseSpan, component_type: Optional[str]) -> None:
         # If the span is at the pipeline level, we add input and output keys to the span
         at_pipeline_level = span.get_data().get(_PIPELINE_INPUT_KEY) is not None
         if at_pipeline_level:
-            span.raw_span().update(
-                input=span.get_data().get(_PIPELINE_INPUT_KEY), output=span.get_data().get(_PIPELINE_OUTPUT_KEY)
-            )
+            coerced_input = tracing_utils.coerce_tag_value(span.get_data().get(_PIPELINE_INPUT_KEY))
+            coerced_output = tracing_utils.coerce_tag_value(span.get_data().get(_PIPELINE_OUTPUT_KEY))
+            span.raw_span().update(input=coerced_input, output=coerced_output)
 
         if component_type in _SUPPORTED_GENERATORS:
             meta = span.get_data().get(_COMPONENT_OUTPUT_KEY, {}).get("meta")