Struct TaskContext 

pub struct TaskContext {
    pub tick: u64,
    pub workers: HashMap<WorkerId, WorkerSummary>,
    pub success_rate: f64,
    pub progress: f64,
    pub escalations: Vec<(WorkerId, Escalation)>,
    pub available_actions: Option<ActionsConfig>,
    pub v2_guidances: Option<Vec<Guidance>>,
    pub excluded_actions: Vec<String>,
    pub previous_guidances: HashMap<WorkerId, Arc<Guidance>>,
    pub done_workers: HashSet<WorkerId>,
    pub metadata: HashMap<String, Value>,
}

タスク状況（Analyzer が生成、Manager が消費）

構成

• ベース情報: tick, workers, success_rate, progress, escalations, available_actions
• 探索情報: v2_guidances, excluded_actions
• 拡張 KV: metadata で任意の追加情報を格納

使用例

let context = TaskContext::new(tick)
    .with_worker(WorkerSummary::new(WorkerId(0)).with_phase(WorkerPhase::Working))
    .with_progress(0.5)
    .insert("llm_summary", "探索フェーズ中");

Fields

tick: u64

現在の tick

workers: HashMap<WorkerId, WorkerSummary>

各 Worker の状態サマリ

success_rate: f64

成功率 (0.0 - 1.0)

progress: f64

進捗 (0.0 - 1.0)

escalations: Vec<(WorkerId, Escalation)>

Escalation 一覧（WorkerId, Escalation）

available_actions: Option<ActionsConfig>

利用可能なアクション

v2_guidances: Option<Vec<Guidance>>

ExplorationSpaceV2 から生成された Guidance

select_nodes() → Guidance 変換で直接生成。 Manager はこれをそのまま Worker に配布できる。

excluded_actions: Vec<String>

除外すべきアクション（成功済み/クローズ済み）- プロンプトから除外

previous_guidances: HashMap<WorkerId, Arc<Guidance>>

前回の Guidance（Worker ID -> Arc）

Orchestrator が Manager.prepare() 呼び出し前に設定。 Manager は prepare() でこれを使って ResolvedContext に ManagerInstruction を埋め込む。 Arc で共有することでクローン時のディープコピーを回避。

done_workers: HashSet<WorkerId>

Goal Action（Terminal Action）を達成した Worker これらのWorkerは Manager.prepare() でリクエスト対象から除外される

metadata: HashMap<String, Value>

追加メタデータ（軽量LLM分析結果等）

Implementations

impl TaskContext

pub fn new(tick: u64) -> Self

新しい TaskContext を作成

pub fn with_worker(self, summary: WorkerSummary) -> Self

Worker サマリを追加

pub fn with_success_rate(self, rate: f64) -> Self

成功率を設定

pub fn with_progress(self, progress: f64) -> Self

進捗を設定

pub fn with_escalation( self, worker_id: WorkerId, escalation: Escalation, ) -> Self

Escalation を追加

pub fn with_actions(self, actions: ActionsConfig) -> Self

利用可能なアクションを設定

pub fn with_previous_guidances( self, guidances: HashMap<WorkerId, Arc<Guidance>>, ) -> Self

前回の Guidance を設定（Arc で共有）

pub fn with_previous_guidance( self, worker_id: WorkerId, guidance: Arc<Guidance>, ) -> Self

単一 Worker の前回 Guidance を追加

pub fn insert<V: Into<Value>>(self, key: impl Into<String>, value: V) -> Self

メタデータを追加

pub fn set<V: Into<Value>>(&mut self, key: impl Into<String>, value: V)

メタデータを追加（mutable）

pub fn get(&self, key: &str) -> Option<&Value>

メタデータを取得

pub fn get_str(&self, key: &str) -> Option<&str>

メタデータを文字列として取得

pub fn get_f64(&self, key: &str) -> Option<f64>

メタデータを数値として取得

pub fn get_i64(&self, key: &str) -> Option<i64>

メタデータを整数として取得

pub fn get_bool(&self, key: &str) -> Option<bool>

メタデータを真偽値として取得

pub fn has_escalations(&self) -> bool

Escalation があるか

pub fn has_escalation_for(&self, worker_id: WorkerId) -> bool

特定の Worker が Escalation 中かどうか

pub fn worker(&self, id: WorkerId) -> Option<&WorkerSummary>

特定 Worker の情報を取得

pub fn escalated_worker_count(&self) -> usize

Escalation 中の Worker 数を取得

pub fn worker_ids(&self) -> Vec<WorkerId>

Worker ID 一覧を取得

impl TaskContext

pub fn has_exploration(&self) -> bool

探索が有効か（v2_guidances がある場合）

pub fn filter_for_workers(&self, worker_ids: &[WorkerId]) -> TaskContext

指定した Worker のみを含むフィルタ済み TaskContext を作成

Manager のパーティショニングで使用。 各 Manager は担当する Worker のみの TaskContext を受け取る。

Trait Implementations

impl Clone for TaskContext

fn clone(&self) -> TaskContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TaskContext

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

Formats the value using the given formatter.

impl Default for TaskContext

fn default() -> Self

Returns the “default value” for a type.