Add bare bones LangFuse integration

openshift/configmap-otel-collector-config.yml

@@ -17,6 +17,11 @@ data:
       otlphttp/trace-server:
         endpoint: http://localhost:8080
         encoding: json
+      otlphttp/langfuse:
+        endpoint: https://us.cloud.langfuse.com/api/public/otel
+        headers:
+          Authorization: "Basic ${env:LANGFUSE_AUTH}"
+          x-langfuse-ingestion-version: "4"
     extensions:
       health_check:
         endpoint: 0.0.0.0:13133
@@ -25,4 +30,4 @@ data:
       pipelines:
         traces:
           receivers: [otlp]
-          exporters: [otlphttp/phoenix, otlphttp/trace-server]
+          exporters: [otlphttp/phoenix, otlphttp/trace-server, otlphttp/langfuse]

openshift/deployment-otel-collector.yml

@@ -32,6 +32,12 @@ spec:
       - name: otel-collector
         image: docker.io/otel/opentelemetry-collector-contrib
         imagePullPolicy: IfNotPresent
+        env:
+        - name: LANGFUSE_AUTH
+          valueFrom:
+            secretKeyRef:
+              name: langfuse-credentials
+              key: auth
         ports:
         - containerPort: 4318
           protocol: TCP

ymir/agents/observability.py

@@ -57,6 +57,7 @@ def on_start(self, span: Span, parent_context: Context | None = None) -> None:
             jira_issue = current_jira_issue.get()
             if jira_issue:
                 span.set_attribute("jira.issue", jira_issue)
+                span.set_attribute("langfuse.session.id", jira_issue)
             workflow = current_workflow.get()
             if workflow:
                 span.set_attribute("workflow.name", workflow)