Struct DagExecutionResult 

pub struct DagExecutionResult {
    pub dag_id: String,
    pub execution_path: Vec<String>,
    pub steps: IndexMap<String, StepExecutionResult>,
    pub total_duration_ms: f64,
    pub escalated: bool,
    pub escalation_reason: Option<String>,
    pub escalation_node_id: Option<String>,
    pub escalation_prompt: Option<String>,
    pub escalation_gating: Option<GatingMetadata>,
    pub final_answer: Option<Answer>,
}

DAG 全体の実行結果。

Fields

dag_id: String

実行された DAG の識別子。

execution_path: Vec<String>

辿ったノード ID の実行経路。

steps: IndexMap<String, StepExecutionResult>

各ステップの詳細実行結果マップ。

total_duration_ms: f64

DAG 全体の実行所要時間 (ミリ秒)。

escalated: bool

エスカレーションノードに到達して終了したか否か。

escalation_reason: Option<String>

エスカレーション理由 (該当する場合)。

escalation_node_id: Option<String>

エスカレーションをトリガーした直前ノード ID。

escalation_prompt: Option<String>

上位 LLM (System 2) 向けの診断 Guided CoT プロンプト案。

escalation_gating: Option<GatingMetadata>

エスカレーション要因となった確信度ゲーティング詳細メタデータ。

final_answer: Option<Answer>

最終決定 Answer (最後の推論ノードの結果)。

Trait Implementations

impl Clone for DagExecutionResult

fn clone(&self) -> DagExecutionResult

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for DagExecutionResult

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for DagExecutionResult

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for DagExecutionResult

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.