nemo-flow-adaptive 0.2.0

Adaptive runtime primitives and Redis-backed learning components for NeMo Flow.
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

// SPDX-FileCopyrightText: Copyright (c) 2026, NVIDIA CORPORATION & AFFILIATES. All rights reserved.
// SPDX-License-Identifier: Apache-2.0

//! Adaptive execution-plan data models.

use serde::{Deserialize, Serialize};

use crate::types::metadata::MetadataEnvelope;

/// Group of tools that have been observed to run in parallel.
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct ParallelGroup {
    /// Stable identifier for the parallel group.
    pub group_id: String,
    /// Tool names that belong to the group.
    pub tool_names: Vec<String>,
}

/// Learned execution plan for an agent.
///
/// The plan captures discovered tool fan-outs and the metadata template used to
/// expose those discoveries to later runs.
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct ExecutionPlan {
    /// Agent identifier the plan applies to.
    pub agent_id: String,
    /// Parallel groups learned for the agent.
    pub parallel_groups: Vec<ParallelGroup>,
    /// Metadata template emitted alongside the plan.
    pub metadata_template: MetadataEnvelope,
}