fix: correct lint errors

pull/22547/head
kurokobo 10 months ago
parent e85680460d
commit a2400836af

@ -3,7 +3,7 @@ import json
import logging import logging
import os import os
from datetime import datetime, timedelta from datetime import datetime, timedelta
from typing import Optional, Union, cast from typing import Any, Optional, Union, cast
from openinference.semconv.trace import OpenInferenceSpanKindValues, SpanAttributes from openinference.semconv.trace import OpenInferenceSpanKindValues, SpanAttributes
from opentelemetry import trace from opentelemetry import trace
@ -238,7 +238,7 @@ class ArizePhoenixDataTrace(BaseTraceInstance):
try: try:
if node_execution.node_type == "llm": if node_execution.node_type == "llm":
llm_attributes = { llm_attributes: dict[str, Any] = {
SpanAttributes.INPUT_VALUE: json.dumps(process_data.get("prompts", []), ensure_ascii=False), SpanAttributes.INPUT_VALUE: json.dumps(process_data.get("prompts", []), ensure_ascii=False),
} }
provider = process_data.get("model_provider") provider = process_data.get("model_provider")
@ -247,7 +247,9 @@ class ArizePhoenixDataTrace(BaseTraceInstance):
llm_attributes[SpanAttributes.LLM_PROVIDER] = provider llm_attributes[SpanAttributes.LLM_PROVIDER] = provider
if model: if model:
llm_attributes[SpanAttributes.LLM_MODEL_NAME] = model llm_attributes[SpanAttributes.LLM_MODEL_NAME] = model
outputs = json.loads(node_execution.outputs).get("usage", {}) if "outputs" in node_execution else {} outputs = (
json.loads(node_execution.outputs).get("usage", {}) if "outputs" in node_execution else {}
)
usage_data = ( usage_data = (
process_data.get("usage", {}) if "usage" in process_data else outputs.get("usage", {}) process_data.get("usage", {}) if "usage" in process_data else outputs.get("usage", {})
) )
@ -705,7 +707,7 @@ class ArizePhoenixDataTrace(BaseTraceInstance):
) )
return workflow_nodes return workflow_nodes
def _construct_llm_attributes(self, prompts: dict | list | str) -> dict: def _construct_llm_attributes(self, prompts: dict | list | str | None) -> dict[str, str]:
"""Helper method to construct LLM attributes with passed prompts.""" """Helper method to construct LLM attributes with passed prompts."""
attributes = {} attributes = {}
if isinstance(prompts, list): if isinstance(prompts, list):

Loading…
Cancel
Save