oharness-loop 0.1.0

Agent, Loop trait, ReactLoop, ConversationLoop, and run_reflexion for open-harness
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

//! The `Loop` trait + `LoopContext` (ยง12.1).

use async_trait::async_trait;
use oharness_core::{
    AgentError, ApprovalChannel, BudgetHandle, Cancellation, RunOutcome, ScopedEmitter, Task,
};
use oharness_critic::{CompositeCritic, CriticTrigger};
use oharness_llm::Llm;
use oharness_memory::MemoryPolicy;
use oharness_tools::context::Workspace;
use oharness_tools::ToolSet;
use std::sync::Arc;

#[async_trait]
pub trait Loop: Send + Sync {
    async fn run(&self, task: Task, ctx: &LoopContext) -> Result<RunOutcome, AgentError>;
}

pub struct LoopContext {
    pub llm: Arc<dyn Llm>,
    pub tools: Arc<dyn ToolSet>,
    pub memory: Arc<dyn MemoryPolicy>,
    /// Optional critic (usually a [`CompositeCritic`] for multi-critic
    /// setups). `None` disables all critic invocations regardless of
    /// trigger setting.
    pub critics: Option<Arc<CompositeCritic>>,
    pub critic_trigger: CriticTrigger,
    pub events: ScopedEmitter,
    pub budget: Arc<dyn BudgetHandle>,
    pub cancellation: Cancellation,
    pub approval: Arc<dyn ApprovalChannel>,
    /// Optional per-run workspace. Propagated into
    /// `ToolContext.workspace` for every tool call so the shipped
    /// `fs` / `bash` tools (which already consult
    /// `ToolContext.workspace_path()`) scope filesystem access to
    /// this directory. `None` leaves tools unscoped (they fall back
    /// to cwd).
    pub workspace: Option<Arc<Workspace>>,
    pub revision_depth_cap: u32,
    pub max_turns: u32,
}