Struct InProcessDagExecutor 

pub struct InProcessDagExecutor { /* private fields */ }

インプロセス DAG 実行エンジン。

単一プロンプトでの複合推論を避け、軽量モデルによる多段判定と Rust 側での決定論的ブール論理・制御フローをミリ秒台で実行する。

Implementations

impl InProcessDagExecutor

pub fn new( engine: Arc<InferenceEngine>, tokenizer: Arc<JevTokenizer>, calib_config: CalibrationConfig, ) -> Self

新規 DAG 実行エンジンを構築する。

引数

• engine: ONNX 推論エンジン。
• tokenizer: Jev 高速トークナイザー。
• calib_config: 較正温度設定。

pub fn with_max_steps(self, max_steps: usize) -> Self

実行ステップ数の安全上限を設定する。既定値は 50。

pub async fn execute( &self, state: &str, dag: &DagDefinition, ) -> Result<DagExecutionResult, DagError>

DAG を実行し、実行結果を返却する。

実行前に静的検証を行い、DAG 全体を dag.timeout_ms の制限時間でラップして実行する。

引数

• state: 入力コンテキスト文。
• dag: 宣言的 DAG 定義。