fix: use workflow_run_id as trace_id instead

pull/22547/head
kurokobo 10 months ago
parent 804f4459bc
commit b7a1243dfa

@ -143,7 +143,7 @@ class ArizePhoenixDataTrace(BaseTraceInstance):
def workflow_trace(self, trace_info: WorkflowTraceInfo): def workflow_trace(self, trace_info: WorkflowTraceInfo):
workflow_metadata = { workflow_metadata = {
"workflow_id": trace_info.workflow_run_id or "", "workflow_run_id": trace_info.workflow_run_id or "",
"message_id": trace_info.message_id or "", "message_id": trace_info.message_id or "",
"workflow_app_log_id": trace_info.workflow_app_log_id or "", "workflow_app_log_id": trace_info.workflow_app_log_id or "",
"status": trace_info.workflow_run_status or "", "status": trace_info.workflow_run_status or "",
@ -153,7 +153,7 @@ class ArizePhoenixDataTrace(BaseTraceInstance):
} }
workflow_metadata.update(trace_info.metadata) workflow_metadata.update(trace_info.metadata)
trace_id = uuid_to_trace_id(trace_info.message_id) trace_id = uuid_to_trace_id(trace_info.workflow_run_id)
span_id = RandomIdGenerator().generate_span_id() span_id = RandomIdGenerator().generate_span_id()
context = SpanContext( context = SpanContext(
trace_id=trace_id, trace_id=trace_id,

Loading…
Cancel
Save