LLM Observability context lost when using Kitlin coroutines
Nadie ha tomado este issue todavía.
Evaluación
- Dificultad
- 4/5
- Tiempo estimado
- 3-5 días
- Aptitud para principiantes
- 38/100
- Tipo de issue
- Error
- Claridad
- Bastante claro
- Estado de actividad
- Estancado
- Área
- backend, observability
Línea de trabajo
Comienza con ThreadLocalContextManager.java y el constructor de DDLLMObsSpan.java para rastrear cómo LLMObsState lee y adjunta el contexto. Revisa la instrumentación existente de corrutinas de Kotlin y reproduce el problema con el escenario paralelo de Dispatchers.IO proporcionado. Se considera terminado cuando los spans LLM secundarios creados después de una suspensión conservan los IDs de span padre esperados y la jerarquía.
Escrito por el modelo de indexación a partir del texto del issue.
Descripción
Tracer Version(s)
1.58.2
Java Version(s)
21.0.7
JVM Vendor
Amazon Corretto
Bug Report
LLM Observability context lost when using Kotlin coroutines
When using LLM Observability with Kotlin coroutines, the LLMObsState context is lost when coroutines suspend and resume on different threads. This breaks parent-child span relationships and can cause spans to have incorrect or missing parent IDs.
Environment
- dd-trace-java version: 1.58.2
- Kotlin with coroutines
- Spring WebFlux / suspend functions
Root Cause
LLMObsState relies on datadog.context.Context which is backed by ThreadLocalContextManager:
// ThreadLocalContextManager.java
final class ThreadLocalContextManager implements ContextManager {
private static final ThreadLocal<Context[]> CURRENT_HOLDER =
ThreadLocal.withInitial(() -> new Context[] {EmptyContext.INSTANCE});
@Override
public Context current() {
return CURRENT_HOLDER.get()[0]; // Plain ThreadLocal - not coroutine-safe
}
}
When DDLLMObsSpan is created, it attaches to the current context and sets the parent:
// DDLLMObsSpan.java constructor
AgentSpanContext parent = LLMObsState.getLLMObsParentContext(); // Returns null on different thread
// ...
this.scope = LLMObsState.attach();
LLMObsState.setLLMObsParentContext(this.span.context());
Impact
This is particularly problematic for:
- Batch LLM operations (parallel embeddings, parallel completions)
- Agent workflows with parallel tool execution
- Any async/concurrent LLM workloads using Kotlin coroutines or reactive frameworks such as Spring WebFlux
Potential Solutions
-
Leverage existing Kotlin coroutine instrumentation - dd-trace-java has coroutine support for APM traces. Could similar context propagation be applied to
LLMObsState? -
Use
CoroutineContextelements - Allow users to propagate LLM Obs context explicitly via coroutine context, similar to how MDC context can be propagated. -
Integrate with
datadog.context.Contextpropagation - If there's existing machinery for propagatingContextacross async boundaries, ensureLLMObsStatebenefits from it.
Contribution
I would be happy to contribute a fix for this if the approach is welcomed. Please let me know the preferred direction and any guidance on implementation.
Expected Behavior
Child LLM spans created within coroutines should correctly reference their parent span, maintaining the trace hierarchy.
Actual Behavior
LLMObsState.getLLMObsParentContext()returnsnullwhen called from a different thread- Child spans get
parent_id="undefined"instead of the actual parent span ID - Trace hierarchy is broken in the Datadog LLM Observability UI
Reproduction Code
Reproduction Scenario
// Parent span created on Thread-1
val parentSpan = LLMObs.startAgentSpan("agent", mlApp, sessionId)
coroutineScope {
// Child spans created in parallel coroutines
// These may run on Thread-2, Thread-3, etc.
listOf(task1, task2, task3).map { task ->
async([Dispatchers.IO](http://dispatchers.io/)) {
// LLMObsState.getLLMObsParentContext() returns null here
// because ThreadLocal from Thread-1 is not available
val childSpan = LLMObs.startLLMSpan("llm.inference", model, provider, mlApp, sessionId)
// ... do work
childSpan.finish()
}
}.awaitAll()
}
parentSpan.finish()
- Lenguaje dominante
- Java
- Estrellas
- 737
- Forks
- 361
- Merge medio
- 3 d 20 h
- PR fusionados (30 d)
- 173
Guía de contribución
Primeros pasos
- Lee el issue completo y luego la guía de contribución del proyecto.
- Comenta en el issue que vas a ocuparte — evita que dos personas hagan lo mismo.
- Haz un fork del repositorio y trabaja en una rama.
- Abre un pull request que haga referencia al número del issue.
Más de DataDog/dd-trace-java
-
type: feature request
Dificultad 1/5 1-3 horas Aptitud para principiantes 70/100
DataDog/dd-trace-java#10245 · 1 comentario ·
-
Dificultad 4/5 3-5 días Aptitud para principiantes 62/100
DataDog/dd-trace-java#12608 ·
-
type: bug report
Dificultad 4/5 3-5 días Aptitud para principiantes 35/100
DataDog/dd-trace-java#12597 ·
-
Dificultad 4/5 3-5 días Aptitud para principiantes 35/100
DataDog/dd-trace-java#12540 · 4 comentarios · 1 asignado ·
-
Dificultad 3/5 1-2 días Aptitud para principiantes 25/100
DataDog/dd-trace-java#12480 ·
Todos los issues de DataDog/dd-trace-java
Issues similares
-
executions.Query — startDate and timeRange filters are sent with inverted comparison operators Abiertoarea/plugin
Dificultad 2/5 1-3 horas Aptitud para principiantes 75/100
kestra-io/plugin-kestra#190 ·
-
litertlm-android AAR ships no consumer ProGuard rules → "mid == null" SIGABRT in minified apps Abierto
Dificultad 2/5 1-3 horas Aptitud para principiantes 70/100
google-ai-edge/LiteRT-LM#3739 ·
-
bug
Dificultad 2/5 1-3 horas Aptitud para principiantes 75/100
-
Add canonical URLs and a sitemap Abierto
Dificultad 2/5 1-3 horas Aptitud para principiantes 75/100
integra-team-red/meet-map#249 ·
-
[Studio][Bug] Cancelled create-user dialog keeps the password and admin switch for the next attempt Abierto
Dificultad 2/5 1-3 horas Aptitud para principiantes 75/100
apache/rocketmq-dashboard#5064 ·