omk 0.5.0

A Rust runtime for Kimi CLI. Turns prompts into proof-backed engineering runs with gates, worktrees, and replay.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37

use anyhow::Result;
use chrono::{DateTime, Utc};
use std::path::Path;

use super::dispatcher::GoalDispatcher;
use crate::runtime::goal::agent::GoalAgentDispatchPlan;
use crate::runtime::goal::dispatch::tasks::{
    append_agent_execution_task_events, run_goal_agent_task_wave,
};
use crate::runtime::goal::evidence::GoalAgentRunEvidence;
use crate::runtime::goal::state::GoalState;
use crate::runtime::goal::task_graph::{GoalTask, GoalTaskGraph};

#[derive(Clone)]
pub(crate) struct DefaultGoalDispatcher;

impl GoalDispatcher for DefaultGoalDispatcher {
    async fn execute_wave(
        &self,
        state: &GoalState,
        task_graph: &GoalTaskGraph,
        project_dir: &Path,
        started_at: DateTime<Utc>,
        dispatch: &GoalAgentDispatchPlan,
    ) -> Result<GoalAgentRunEvidence> {
        run_goal_agent_task_wave(state, task_graph, project_dir, started_at, dispatch).await
    }

    async fn append_execution_events(
        &self,
        state: &GoalState,
        task: &GoalTask,
        evidence: &GoalAgentRunEvidence,
    ) -> Result<()> {
        append_agent_execution_task_events(state, task, evidence).await
    }
}