From aeb475ea8d0790b932e7569c86f7afef0196b53f Mon Sep 17 00:00:00 2001
From: Anton Bobrov <antbob@users.noreply.github.com>
Date: Wed, 5 Aug 2026 10:43:39 +0200
Subject: [PATCH] Add bare bones LangFuse integration

---
 openshift/configmap-otel-collector-config.yml | 7 ++++++-
 openshift/deployment-otel-collector.yml       | 6 ++++++
 ymir/agents/observability.py                  | 1 +
 3 files changed, 13 insertions(+), 1 deletion(-)

diff --git a/openshift/configmap-otel-collector-config.yml b/openshift/configmap-otel-collector-config.yml
index fded5edf9..eea973518 100644
--- a/openshift/configmap-otel-collector-config.yml
+++ b/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]
diff --git a/openshift/deployment-otel-collector.yml b/openshift/deployment-otel-collector.yml
index bdb04b7a4..e55f658a8 100644
--- a/openshift/deployment-otel-collector.yml
+++ b/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
diff --git a/ymir/agents/observability.py b/ymir/agents/observability.py
index 4341b7c92..cc9a3a07c 100644
--- a/ymir/agents/observability.py
+++ b/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)