@@ -150,13 +150,15 @@ def new_chat_completion(*args, **kwargs):
150
150
151
151
with capture_internal_exceptions ():
152
152
if _should_send_default_pii ():
153
- span .set_data ("messages " , messages )
154
- span .set_data ("model " , model )
155
- span .set_data ("streaming" , streaming )
153
+ span .set_data ("ai.input_messages " , messages )
154
+ span .set_data ("ai.model_id " , model )
155
+ span .set_data ("ai. streaming" , streaming )
156
156
157
157
if hasattr (res , "choices" ):
158
158
if _should_send_default_pii ():
159
- span .set_data ("response" , res .choices [0 ].message )
159
+ span .set_data (
160
+ "ai.responses" , list (map (lambda x : x .message , res .choices ))
161
+ )
160
162
_calculate_chat_completion_usage (messages , res , span )
161
163
span .__exit__ (None , None , None )
162
164
elif hasattr (res , "_iterator" ):
@@ -185,7 +187,7 @@ def new_iterator():
185
187
map (lambda chunk : "" .join (chunk ), data_buf )
186
188
)
187
189
if _should_send_default_pii ():
188
- span .set_data ("responses" , all_responses )
190
+ span .set_data ("ai. responses" , all_responses )
189
191
_calculate_chat_completion_usage (
190
192
messages , res , span , all_responses
191
193
)
@@ -210,12 +212,17 @@ def new_embeddings_create(*args, **kwargs):
210
212
op = consts .OP .OPENAI_EMBEDDINGS_CREATE ,
211
213
description = "OpenAI Embedding Creation" ,
212
214
) as span :
213
- if "input" in kwargs and isinstance (kwargs ["input" ], str ):
214
- span .set_data ("input" , kwargs ["input" ])
215
+ if "input" in kwargs :
216
+ if isinstance (kwargs ["input" ], str ):
217
+ span .set_data ("ai.input_messages" , [kwargs ["input" ]])
218
+ elif (
219
+ isinstance (kwargs ["input" ], list )
220
+ and len (kwargs ["input" ]) > 0
221
+ and isinstance (kwargs ["input" ][0 ], str )
222
+ ):
223
+ span .set_data ("ai.input_messages" , kwargs ["input" ])
215
224
if "model" in kwargs :
216
- span .set_data ("model" , kwargs ["model" ])
217
- if "dimensions" in kwargs :
218
- span .set_data ("dimensions" , kwargs ["dimensions" ])
225
+ span .set_data ("ai.model_id" , kwargs ["model" ])
219
226
try :
220
227
response = f (* args , ** kwargs )
221
228
except Exception as e :
0 commit comments