19
19
import datadog .trace .bootstrap .instrumentation .api .Tags ;
20
20
import datadog .trace .bootstrap .instrumentation .api .UTF8BytesString ;
21
21
import datadog .trace .bootstrap .instrumentation .decorator .ClientDecorator ;
22
+ import java .util .HashMap ;
22
23
import java .util .List ;
24
+ import java .util .Map ;
23
25
import java .util .Optional ;
24
26
25
27
public class OpenAIClientDecorator extends ClientDecorator {
@@ -126,7 +128,7 @@ public LLMObsSpan startLLMObsChatCompletionSpan(ChatCompletionCreateParams param
126
128
llmObsSpan .annotateIO (inputData .toString (), null ); // No output yet, will be set in response
127
129
}
128
130
129
- java . util . Map <String , Object > metadata = new java . util . HashMap <>();
131
+ Map <String , Object > metadata = new HashMap <>();
130
132
metadata .put ("endpoint" , "/chat/completions" );
131
133
metadata .put ("provider" , "openai" );
132
134
metadata .put ("model" , modelName );
@@ -144,7 +146,7 @@ public void finishLLMObsChatCompletionSpan(
144
146
try {
145
147
if (throwable != null ) {
146
148
// Set error information
147
- java . util . Map <String , Object > errorMetadata = new java . util . HashMap <>();
149
+ Map <String , Object > errorMetadata = new HashMap <>();
148
150
errorMetadata .put ("error.type" , throwable .getClass ().getSimpleName ());
149
151
errorMetadata .put ("error.message" , throwable .getMessage ());
150
152
llmObsSpan .setMetadata (errorMetadata );
@@ -186,13 +188,13 @@ public void finishLLMObsChatCompletionSpan(
186
188
if (outputData .length () > 0 ) {
187
189
llmObsSpan .annotateIO (null , outputData .toString ());
188
190
}
189
- java . util . Map <String , Object > responseMetadata = new java . util . HashMap <>();
191
+ Map <String , Object > responseMetadata = new HashMap <>();
190
192
responseMetadata .put ("response.choices_count" , choices .size ());
191
193
192
194
llmObsSpan .setMetadata (responseMetadata );
193
195
}
194
196
} catch (Exception e ) {
195
- java . util . Map <String , Object > errorMetadata = new java . util . HashMap <>();
197
+ Map <String , Object > errorMetadata = new HashMap <>();
196
198
errorMetadata .put ("error.type" , "ResponseProcessingError" );
197
199
errorMetadata .put ("error.message" , "Failed to process response: " + e .getMessage ());
198
200
llmObsSpan .setMetadata (errorMetadata );
0 commit comments