refactor: use SDK constants for thread ID attribute

javascript/src/agents/judge/judge-span-collector.ts

@@ -1,4 +1,5 @@
 import { SpanProcessor, ReadableSpan } from "@opentelemetry/sdk-trace-base";
+import { attributes } from "langwatch/observability";
 
 /**
  * Collects OpenTelemetry spans for judge evaluation.
@@ -37,7 +38,7 @@ export class JudgeSpanCollector implements SpanProcessor {
 
     // Check if span or any ancestor belongs to thread
     const belongsToThread = (span: ReadableSpan): boolean => {
-      if (span.attributes["langwatch.thread.id"] === threadId) {
+      if (span.attributes[attributes.ATTR_LANGWATCH_THREAD_ID] === threadId) {
         return true;
       }
       const parentId = span.parentSpanContext?.spanId;

python/scenario/_tracing/judge_span_collector.py

@@ -8,6 +8,7 @@
 from typing import List, Dict, Optional
 from opentelemetry.context import Context
 from opentelemetry.sdk.trace import SpanProcessor, ReadableSpan
+from langwatch.attributes import AttributeKey
 
 
 class JudgeSpanCollector(SpanProcessor):
@@ -65,7 +66,7 @@ def get_spans_for_thread(self, thread_id: str) -> List[ReadableSpan]:
         def belongs_to_thread(span: ReadableSpan) -> bool:
             """Check if span or any ancestor belongs to thread."""
             attrs = span.attributes or {}
-            if attrs.get("langwatch.thread.id") == thread_id:
+            if attrs.get(AttributeKey.LangWatchThreadId) == thread_id:
                 return True
 
             parent_ctx = span.parent

python/scenario/scenario_executor.py

@@ -27,6 +27,7 @@
 import concurrent.futures
 
 from scenario.config import ScenarioConfig
+from langwatch.attributes import AttributeKey
 from scenario._utils import (
     convert_agent_return_types_to_openai_messages,
     check_valid_return_type,
@@ -531,7 +532,9 @@ async def _call_agent(
             with self._trace.span(
                 type="agent", name=f"{agent.__class__.__name__}.call"
             ) as span:
-                span.set_attributes({"langwatch.thread.id": self._state.thread_id})
+                span.set_attributes(
+                    {AttributeKey.LangWatchThreadId: self._state.thread_id}
+                )
                 with show_spinner(
                     text=(
                         "Judging..."