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
38
39
40
41
42
43
44
45
46
47

use std::path::Path;

use anyhow::Result;

use crate::runtime::goal::agent::GoalAgentTaskProposal;
use crate::runtime::goal::dispatch::tasks::results::{
    read_goal_agent_worker_results, summarize_goal_agent_worker_results,
};
use crate::runtime::goal::evidence::{
    extract_goal_agent_task_proposals, write_goal_agent_mutation_snapshot,
};
use crate::runtime::goal::state::GoalState;
use crate::runtime::scheduler::runner::RunSummary;
use crate::runtime::worker::{WorkerResult, WorkerSpec};

pub(crate) async fn gather_wave_results(
    worker_specs: &[WorkerSpec],
    accepted_task_ids: &[String],
    state: &GoalState,
    project_dir: &Path,
    mutation_diff_path: &Path,
    changed_files_path: &Path,
    summary: &RunSummary,
) -> Result<(
    Vec<WorkerResult>,
    Option<String>,
    Vec<GoalAgentTaskProposal>,
    Vec<String>,
)> {
    let worker_results = read_goal_agent_worker_results(worker_specs, accepted_task_ids).await?;
    let worker_summary = summarize_goal_agent_worker_results(&worker_results)
        .or_else(|| (summary.cancelled > 0).then(|| "cancelled by user".to_string()));
    let agent_proposed_tasks = extract_goal_agent_task_proposals(&worker_results);
    let changed_files = write_goal_agent_mutation_snapshot(
        state,
        project_dir,
        mutation_diff_path,
        changed_files_path,
    )
    .await?;
    Ok((
        worker_results,
        worker_summary,
        agent_proposed_tasks,
        changed_files,
    ))
}