From 609e2288528e691f9ab088e2782741e094dc189a Mon Sep 17 00:00:00 2001 From: Yingwen Date: Tue, 8 Apr 2025 16:14:47 +0800 Subject: [PATCH] fix: get root cause of the procedure when coverting to pb (#5841) --- src/common/meta/src/rpc/procedure.rs | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/src/common/meta/src/rpc/procedure.rs b/src/common/meta/src/rpc/procedure.rs index c8a43ffcb2..65eaaca7c7 100644 --- a/src/common/meta/src/rpc/procedure.rs +++ b/src/common/meta/src/rpc/procedure.rs @@ -20,6 +20,7 @@ use api::v1::meta::{ ProcedureMeta as PbProcedureMeta, ProcedureStateResponse as PbProcedureStateResponse, ProcedureStatus as PbProcedureStatus, }; +use common_error::ext::ErrorExt; use common_procedure::{ProcedureId, ProcedureInfo, ProcedureState}; use snafu::ResultExt; @@ -73,15 +74,15 @@ pub fn procedure_state_to_pb_state(state: &ProcedureState) -> (PbProcedureStatus match state { ProcedureState::Running => (PbProcedureStatus::Running, String::default()), ProcedureState::Done { .. } => (PbProcedureStatus::Done, String::default()), - ProcedureState::Retrying { error } => (PbProcedureStatus::Retrying, error.to_string()), - ProcedureState::Failed { error } => (PbProcedureStatus::Failed, error.to_string()), + ProcedureState::Retrying { error } => (PbProcedureStatus::Retrying, error.output_msg()), + ProcedureState::Failed { error } => (PbProcedureStatus::Failed, error.output_msg()), ProcedureState::PrepareRollback { error } => { - (PbProcedureStatus::PrepareRollback, error.to_string()) + (PbProcedureStatus::PrepareRollback, error.output_msg()) } ProcedureState::RollingBack { error } => { - (PbProcedureStatus::RollingBack, error.to_string()) + (PbProcedureStatus::RollingBack, error.output_msg()) } - ProcedureState::Poisoned { error, .. } => (PbProcedureStatus::Poisoned, error.to_string()), + ProcedureState::Poisoned { error, .. } => (PbProcedureStatus::Poisoned, error.output_msg()), } }