|
10 | 10 | import urllib.parse |
11 | 11 |
|
12 | 12 | from cozeloop import span |
13 | | -from cozeloop.attribute.trace.model import ModelInput, ModelOutput, ModelMessagePartType, ModelMessage, ModelMessagePart, ModelImageURL, ModelFileURL, ModelChoice |
14 | | -from cozeloop.attribute.trace.runtime import Runtime |
15 | | -from cozeloop.attribute.trace.span_key import ERROR, PROMPT_KEY, PROMPT_VERSION, MODEL_PROVIDER, MODEL_NAME, RUNTIME_ |
16 | | -from cozeloop.attribute.trace.span_value import V_SCENE_CUSTOM, V_LANG_PYTHON |
| 13 | +from cozeloop.spec.tracespce import (ModelInput, ModelOutput, ModelMessagePartType, ModelMessage, ModelMessagePart, |
| 14 | + ModelImageURL, ModelFileURL, ModelChoice, Runtime, ERROR, PROMPT_KEY, |
| 15 | + PROMPT_VERSION, MODEL_PROVIDER, MODEL_NAME, RUNTIME_, CALL_OPTIONS, |
| 16 | + V_SCENE_CUSTOM, V_LANG_PYTHON) |
17 | 17 | from cozeloop.entities.prompt import Prompt |
18 | 18 | from cozeloop.internal.consts import * |
19 | 19 | from cozeloop.internal.trace.noop_span import NoopSpan |
@@ -293,8 +293,8 @@ def get_model_output_bytes_size(self, m_content): |
293 | 293 | except Exception: |
294 | 294 | return 0 |
295 | 295 |
|
296 | | - def set_error(self, error: str): |
297 | | - self.set_tags({ERROR: error}) |
| 296 | + def set_error(self, err: Exception): |
| 297 | + self.set_tags({ERROR: err.__str__()}) |
298 | 298 |
|
299 | 299 | def set_status_code(self, code: int): |
300 | 300 | with self.lock: |
@@ -324,23 +324,14 @@ def set_prompt(self, prompt: Prompt): |
324 | 324 | if prompt.version: |
325 | 325 | self.set_tags({PROMPT_VERSION: prompt.version}) |
326 | 326 |
|
327 | | - def set_prompt_baggage(self, prompt: Prompt): |
328 | | - if prompt.prompt_key: |
329 | | - self.set_baggage({PROMPT_KEY: prompt.prompt_key}) |
330 | | - if prompt.version: |
331 | | - self.set_baggage({PROMPT_VERSION: prompt.version}) |
332 | | - |
333 | 327 | def set_model_provider(self, model_provider: str): |
334 | 328 | self.set_tags({MODEL_PROVIDER: model_provider}) |
335 | 329 |
|
336 | | - def set_model_provider_baggage(self, model_provider: str): |
337 | | - self.set_baggage({MODEL_PROVIDER: model_provider}) |
338 | | - |
339 | 330 | def set_model_name(self, model_name: str): |
340 | 331 | self.set_tags({MODEL_NAME: model_name}) |
341 | 332 |
|
342 | | - def set_model_name_baggage(self, model_name: str): |
343 | | - self.set_baggage({MODEL_NAME: model_name}) |
| 333 | + def set_model_call_options(self, model_call_options: Any): |
| 334 | + self.set_tags({CALL_OPTIONS: model_call_options}) |
344 | 335 |
|
345 | 336 | def set_input_tokens(self, input_tokens: int): |
346 | 337 | self.set_tags({INPUT_TOKENS: input_tokens}) |
|
0 commit comments