mirror of
https://github.com/fabro-sh/fabro.git
synced 2026-09-08 22:21:45 +00:00
Store workflow slug in manifest so resolve_run can match by directory name
When running `fabro run smoke`, the slug "smoke" was used to locate the workflow but never persisted. If the DOT graph name diverged from the directory name (e.g. workflows/foo/ contains digraph Bar), resolve_run couldn't find the run by slug. Now the slug is extracted from the workflow path, stored in the manifest, and matched in resolve_run. Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
This commit is contained in:
Bryan Helmkamp
parent
387cee9c10
commit
263399e0cd
8 changed files with 239 additions and 3 deletions
|
|
@ -626,6 +626,7 @@ async fn execute_run(state: Arc<AppState>, run_id: String) {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: true,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let result = tokio::select! {
|
||||
|
|
|
|||
|
|
@ -326,6 +326,18 @@ pub async fn run_command(
|
|||
}
|
||||
};
|
||||
|
||||
// Extract workflow slug from the workflow path argument.
|
||||
// If bare name (no extension, e.g. "smoke"), use it directly.
|
||||
// Otherwise derive from the parent directory of the resolved .toml path.
|
||||
let workflow_slug: Option<String> = if workflow_path.extension().is_none() {
|
||||
Some(workflow_path.to_string_lossy().into_owned())
|
||||
} else {
|
||||
workflow_path
|
||||
.parent()
|
||||
.and_then(|p| p.file_name())
|
||||
.map(|n| n.to_string_lossy().into_owned())
|
||||
};
|
||||
|
||||
let directory = run_cfg
|
||||
.as_ref()
|
||||
.and_then(|c| c.work_dir.as_deref())
|
||||
|
|
@ -1180,6 +1192,7 @@ pub async fn run_command(
|
|||
.and_then(|c| c.assets.as_ref())
|
||||
.map(|a| a.include.clone())
|
||||
.unwrap_or_default(),
|
||||
workflow_slug: workflow_slug.clone(),
|
||||
};
|
||||
|
||||
let run_start = Instant::now();
|
||||
|
|
@ -1786,6 +1799,7 @@ async fn run_from_branch(
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let run_start = Instant::now();
|
||||
|
|
|
|||
|
|
@ -91,6 +91,8 @@ pub struct RunInfo {
|
|||
pub run_id: String,
|
||||
pub dir_name: String,
|
||||
pub workflow_name: String,
|
||||
#[serde(default, skip_serializing_if = "Option::is_none")]
|
||||
pub workflow_slug: Option<String>,
|
||||
pub status: RunStatus,
|
||||
pub start_time: String,
|
||||
pub labels: HashMap<String, String>,
|
||||
|
|
@ -130,6 +132,7 @@ pub fn scan_runs(base: &Path) -> Result<Vec<RunInfo>> {
|
|||
|
||||
let run_id = manifest.run_id;
|
||||
let workflow_name = manifest.workflow_name;
|
||||
let workflow_slug = manifest.workflow_slug;
|
||||
let start_time_dt = manifest.start_time;
|
||||
let start_time = start_time_dt.to_rfc3339();
|
||||
let labels = manifest.labels;
|
||||
|
|
@ -140,6 +143,7 @@ pub fn scan_runs(base: &Path) -> Result<Vec<RunInfo>> {
|
|||
run_id,
|
||||
dir_name,
|
||||
workflow_name,
|
||||
workflow_slug,
|
||||
status,
|
||||
start_time,
|
||||
labels,
|
||||
|
|
@ -161,6 +165,7 @@ pub fn scan_runs(base: &Path) -> Result<Vec<RunInfo>> {
|
|||
run_id: dir_name.clone(),
|
||||
dir_name,
|
||||
workflow_name: "[no manifest]".to_string(),
|
||||
workflow_slug: None,
|
||||
status: RunStatus::Unknown,
|
||||
start_time: mtime,
|
||||
labels: HashMap::new(),
|
||||
|
|
@ -306,12 +311,18 @@ pub fn resolve_run(base: &Path, identifier: &str) -> Result<RunInfo> {
|
|||
_ => {}
|
||||
}
|
||||
|
||||
// Step 2: try workflow name match, return most recent (runs are sorted newest-first).
|
||||
// Supports both display names ("LegacyTool") and slugs ("legacy-tool") by comparing
|
||||
// case-insensitively first, then with separators stripped (hyphens/underscores removed).
|
||||
// Step 2: try workflow slug (exact, case-insensitive) then workflow name match.
|
||||
// Returns the most recent run (runs are sorted newest-first).
|
||||
let id_lower = identifier.to_lowercase();
|
||||
let id_collapsed = collapse_separators(&id_lower);
|
||||
let wf_match = runs.iter().filter(|r| !r.is_orphan).find(|r| {
|
||||
// Exact slug match (case-insensitive)
|
||||
if let Some(slug) = &r.workflow_slug {
|
||||
if slug.to_lowercase() == id_lower {
|
||||
return true;
|
||||
}
|
||||
}
|
||||
// Fuzzy workflow name match (substring, separator-collapsed)
|
||||
let name_lower = r.workflow_name.to_lowercase();
|
||||
name_lower.contains(&id_lower) || collapse_separators(&name_lower).contains(&id_collapsed)
|
||||
});
|
||||
|
|
@ -815,6 +826,7 @@ mod tests {
|
|||
run_id: "old".into(),
|
||||
dir_name: "d1".into(),
|
||||
workflow_name: "p".into(),
|
||||
workflow_slug: None,
|
||||
status: RunStatus::Concluded(crate::outcome::StageStatus::Success),
|
||||
start_time: "2025-06-01T00:00:00Z".into(),
|
||||
labels: HashMap::new(),
|
||||
|
|
@ -827,6 +839,7 @@ mod tests {
|
|||
run_id: "new".into(),
|
||||
dir_name: "d2".into(),
|
||||
workflow_name: "p".into(),
|
||||
workflow_slug: None,
|
||||
status: RunStatus::Concluded(crate::outcome::StageStatus::Success),
|
||||
start_time: "2026-03-01T00:00:00Z".into(),
|
||||
labels: HashMap::new(),
|
||||
|
|
@ -848,6 +861,7 @@ mod tests {
|
|||
run_id: "a".into(),
|
||||
dir_name: "d1".into(),
|
||||
workflow_name: "deploy-prod".into(),
|
||||
workflow_slug: None,
|
||||
status: RunStatus::Concluded(crate::outcome::StageStatus::Success),
|
||||
start_time: "2026-01-01T00:00:00Z".into(),
|
||||
labels: HashMap::new(),
|
||||
|
|
@ -860,6 +874,7 @@ mod tests {
|
|||
run_id: "b".into(),
|
||||
dir_name: "d2".into(),
|
||||
workflow_name: "test-suite".into(),
|
||||
workflow_slug: None,
|
||||
status: RunStatus::Concluded(crate::outcome::StageStatus::Success),
|
||||
start_time: "2026-01-01T00:00:00Z".into(),
|
||||
labels: HashMap::new(),
|
||||
|
|
@ -881,6 +896,7 @@ mod tests {
|
|||
run_id: "a".into(),
|
||||
dir_name: "d1".into(),
|
||||
workflow_name: "p".into(),
|
||||
workflow_slug: None,
|
||||
status: RunStatus::Concluded(crate::outcome::StageStatus::Success),
|
||||
start_time: "2026-01-01T00:00:00Z".into(),
|
||||
labels: HashMap::from([("env".into(), "prod".into())]),
|
||||
|
|
@ -893,6 +909,7 @@ mod tests {
|
|||
run_id: "b".into(),
|
||||
dir_name: "d2".into(),
|
||||
workflow_name: "p".into(),
|
||||
workflow_slug: None,
|
||||
status: RunStatus::Concluded(crate::outcome::StageStatus::Success),
|
||||
start_time: "2026-01-01T00:00:00Z".into(),
|
||||
labels: HashMap::from([("env".into(), "staging".into())]),
|
||||
|
|
@ -919,6 +936,7 @@ mod tests {
|
|||
run_id: "orphan".into(),
|
||||
dir_name: "d1".into(),
|
||||
workflow_name: "[no manifest]".into(),
|
||||
workflow_slug: None,
|
||||
status: RunStatus::Unknown,
|
||||
start_time: "".into(),
|
||||
labels: HashMap::new(),
|
||||
|
|
@ -1451,6 +1469,31 @@ mod tests {
|
|||
assert_eq!(info.run_id, "aaa111-full");
|
||||
}
|
||||
|
||||
#[test]
|
||||
fn resolve_run_matches_by_workflow_slug() {
|
||||
let dir = tempfile::tempdir().unwrap();
|
||||
// Graph name is "Bar" but slug is "foo" — resolve_run("foo") should match via slug
|
||||
make_run_dir(
|
||||
dir.path(),
|
||||
"20260101-AAA111",
|
||||
Some(serde_json::json!({
|
||||
"run_id": "aaa111-full",
|
||||
"workflow_name": "Bar",
|
||||
"workflow_slug": "foo",
|
||||
"goal": "",
|
||||
"start_time": "2026-01-01T12:00:00Z",
|
||||
"node_count": 1,
|
||||
"edge_count": 0
|
||||
})),
|
||||
None,
|
||||
false,
|
||||
);
|
||||
|
||||
let info = resolve_run(dir.path(), "foo").unwrap();
|
||||
assert_eq!(info.run_id, "aaa111-full");
|
||||
assert_eq!(info.workflow_slug.as_deref(), Some("foo"));
|
||||
}
|
||||
|
||||
// === Step 1: end_time tests ===
|
||||
|
||||
#[test]
|
||||
|
|
|
|||
|
|
@ -300,6 +300,7 @@ fn write_manifest(run_dir: &Path, graph: &Graph, config: &RunConfig) -> crate::m
|
|||
base_sha: config.base_sha.clone(),
|
||||
labels: config.labels.clone(),
|
||||
base_branch: config.base_branch.clone(),
|
||||
workflow_slug: config.workflow_slug.clone(),
|
||||
};
|
||||
let _ = std::fs::create_dir_all(run_dir);
|
||||
let _ = manifest.save(&run_dir.join("manifest.json"));
|
||||
|
|
@ -785,6 +786,8 @@ pub struct RunConfig {
|
|||
pub pull_request_draft: bool,
|
||||
/// Glob patterns for asset collection. Empty = no asset collection.
|
||||
pub asset_globs: Vec<String>,
|
||||
/// Workflow directory slug (e.g. "smoke" from `fabro/workflows/smoke/`).
|
||||
pub workflow_slug: Option<String>,
|
||||
}
|
||||
|
||||
/// The workflow run execution engine.
|
||||
|
|
@ -2795,6 +2798,7 @@ mod tests {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let outcome = engine.run(&g, &config).await.unwrap();
|
||||
assert_eq!(outcome.status, StageStatus::Success);
|
||||
|
|
@ -2824,6 +2828,7 @@ mod tests {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&g, &config).await.unwrap();
|
||||
let checkpoint_path = dir.path().join("checkpoint.json");
|
||||
|
|
@ -2861,6 +2866,7 @@ mod tests {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&g, &config).await.unwrap();
|
||||
|
||||
|
|
@ -2894,6 +2900,7 @@ mod tests {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let result = engine.run(&g, &config).await;
|
||||
assert!(result.is_err());
|
||||
|
|
@ -2923,6 +2930,7 @@ mod tests {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&g, &config).await.unwrap();
|
||||
|
||||
|
|
@ -2965,6 +2973,7 @@ mod tests {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let outcome = engine.run(&g, &config).await.unwrap();
|
||||
assert_eq!(outcome.status, StageStatus::Success);
|
||||
|
|
@ -3031,6 +3040,7 @@ mod tests {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&g, &config).await.unwrap();
|
||||
|
||||
|
|
@ -3124,6 +3134,7 @@ mod tests {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&g, &config).await.unwrap();
|
||||
|
||||
|
|
@ -3160,6 +3171,7 @@ mod tests {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&g, &config).await.unwrap();
|
||||
|
||||
|
|
@ -3191,6 +3203,7 @@ mod tests {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&g, &config).await.unwrap();
|
||||
|
||||
|
|
@ -3222,6 +3235,7 @@ mod tests {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&g, &config).await.unwrap();
|
||||
|
||||
|
|
@ -3257,6 +3271,7 @@ mod tests {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&g, &config).await.unwrap();
|
||||
|
||||
|
|
@ -3420,6 +3435,7 @@ mod tests {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&g, &config).await.unwrap();
|
||||
|
||||
|
|
@ -3466,6 +3482,7 @@ mod tests {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&g, &config).await.unwrap();
|
||||
|
||||
|
|
@ -3530,6 +3547,7 @@ mod tests {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let outcome = engine.run(&g, &config).await.unwrap();
|
||||
|
||||
|
|
@ -3597,6 +3615,7 @@ mod tests {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let result = engine.run(&g, &config).await;
|
||||
|
||||
|
|
@ -3668,6 +3687,7 @@ mod tests {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let result = engine.run(&g, &config).await;
|
||||
assert!(result.is_ok());
|
||||
|
|
@ -3728,6 +3748,7 @@ mod tests {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let outcome = engine.run(&g, &config).await.unwrap();
|
||||
assert_eq!(outcome.status, StageStatus::Success);
|
||||
|
|
@ -3789,6 +3810,7 @@ mod tests {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let outcome = engine.run(&g, &config).await.unwrap();
|
||||
|
||||
|
|
@ -3825,6 +3847,7 @@ mod tests {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let outcome = engine.run(&g, &config).await.unwrap();
|
||||
assert_eq!(outcome.status, StageStatus::Success);
|
||||
|
|
@ -3857,6 +3880,7 @@ mod tests {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let result = engine.run(&g, &config).await;
|
||||
assert!(result.is_err());
|
||||
|
|
@ -3888,6 +3912,7 @@ mod tests {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let outcome = engine.run(&g, &config).await.unwrap();
|
||||
assert_eq!(outcome.status, StageStatus::Success);
|
||||
|
|
@ -3932,6 +3957,7 @@ mod tests {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
// Set cancel after a short delay (while the slow handler is running)
|
||||
|
|
@ -4013,6 +4039,7 @@ mod tests {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let result = engine.run(&g, &config).await;
|
||||
assert!(result.is_err());
|
||||
|
|
@ -4047,6 +4074,7 @@ mod tests {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let result = engine.run(&g, &config).await;
|
||||
assert!(result.is_err());
|
||||
|
|
@ -4083,6 +4111,7 @@ mod tests {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let result = engine.run(&g, &config).await;
|
||||
assert!(result.is_err());
|
||||
|
|
@ -4124,6 +4153,7 @@ mod tests {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let result = engine.run(&g, &config).await;
|
||||
assert!(result.is_err());
|
||||
|
|
@ -4163,6 +4193,7 @@ mod tests {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let result = engine.run(&g, &config).await;
|
||||
assert!(result.is_err());
|
||||
|
|
@ -4199,6 +4230,7 @@ mod tests {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let result = engine.run(&g, &config).await;
|
||||
assert!(result.is_err());
|
||||
|
|
@ -4296,6 +4328,7 @@ mod tests {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
// The engine returns Err because the Fail outcome has no outgoing fail edge,
|
||||
|
|
@ -4508,6 +4541,7 @@ mod tests {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let result = engine.run(&g, &config).await;
|
||||
assert!(result.is_err());
|
||||
|
|
@ -4547,6 +4581,7 @@ mod tests {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let result = engine.run(&g, &config).await;
|
||||
assert!(result.is_err());
|
||||
|
|
@ -4593,6 +4628,7 @@ mod tests {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let result = engine.run(&g, &config).await;
|
||||
assert!(result.is_err());
|
||||
|
|
@ -4679,6 +4715,7 @@ mod tests {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let result = engine.run(&g, &config).await;
|
||||
assert!(result.is_err());
|
||||
|
|
@ -4776,6 +4813,7 @@ mod tests {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let result = engine.run(&g, &config).await;
|
||||
assert!(result.is_err());
|
||||
|
|
@ -4850,6 +4888,7 @@ mod tests {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let outcome = engine.run(&g, &config).await.unwrap();
|
||||
assert_eq!(outcome.status, StageStatus::Success);
|
||||
|
|
@ -4911,6 +4950,7 @@ mod tests {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let outcome = engine.run(&g, &config).await.unwrap();
|
||||
assert_eq!(outcome.status, StageStatus::Success);
|
||||
|
|
@ -4973,6 +5013,7 @@ mod tests {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let _outcome = engine.run(&g, &config).await.unwrap();
|
||||
|
||||
|
|
@ -5065,6 +5106,7 @@ mod tests {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&g, &config).await.unwrap();
|
||||
|
||||
|
|
|
|||
|
|
@ -159,6 +159,7 @@ impl Handler for SubWorkflowHandler {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: true,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
// Clone parent context for child; inject parent preamble
|
||||
|
|
|
|||
|
|
@ -22,6 +22,8 @@ pub struct Manifest {
|
|||
pub labels: HashMap<String, String>,
|
||||
#[serde(default, skip_serializing_if = "Option::is_none")]
|
||||
pub base_branch: Option<String>,
|
||||
#[serde(default, skip_serializing_if = "Option::is_none")]
|
||||
pub workflow_slug: Option<String>,
|
||||
}
|
||||
|
||||
impl Manifest {
|
||||
|
|
@ -50,6 +52,7 @@ mod tests {
|
|||
base_sha: Some("abc123".to_string()),
|
||||
labels: HashMap::from([("env".into(), "test".into())]),
|
||||
base_branch: None,
|
||||
workflow_slug: None,
|
||||
}
|
||||
}
|
||||
|
||||
|
|
@ -88,6 +91,19 @@ mod tests {
|
|||
assert!(result.is_err());
|
||||
}
|
||||
|
||||
#[test]
|
||||
fn save_and_load_roundtrip_with_slug() {
|
||||
let dir = tempfile::tempdir().unwrap();
|
||||
let path = dir.path().join("manifest.json");
|
||||
|
||||
let mut manifest = sample_manifest();
|
||||
manifest.workflow_slug = Some("smoke".to_string());
|
||||
manifest.save(&path).unwrap();
|
||||
let loaded = Manifest::load(&path).unwrap();
|
||||
|
||||
assert_eq!(loaded.workflow_slug.as_deref(), Some("smoke"));
|
||||
}
|
||||
|
||||
#[test]
|
||||
fn labels_omitted_when_empty() {
|
||||
let dir = tempfile::tempdir().unwrap();
|
||||
|
|
@ -104,5 +120,6 @@ mod tests {
|
|||
assert!(raw.get("labels").is_none());
|
||||
assert!(raw.get("run_branch").is_none());
|
||||
assert!(raw.get("base_sha").is_none());
|
||||
assert!(raw.get("workflow_slug").is_none());
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -406,6 +406,7 @@ async fn daytona_pipeline_artifact_offload_and_sync() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = engine
|
||||
|
|
@ -603,6 +604,7 @@ async fn daytona_git_checkpoint_remote_emits_events() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = engine
|
||||
|
|
@ -791,6 +793,7 @@ async fn daytona_parallel_git_branching_e2e() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = engine
|
||||
|
|
@ -1170,6 +1173,7 @@ async fn daytona_git_checkpoint_with_shadow_branch() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = engine
|
||||
|
|
@ -1312,6 +1316,7 @@ async fn daytona_asset_collection() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = engine
|
||||
|
|
@ -1569,6 +1574,7 @@ async fn daytona_git_push_run_branch_to_origin() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = engine
|
||||
|
|
|
|||
|
|
@ -208,6 +208,7 @@ async fn end_to_end_linear_pipeline() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = engine
|
||||
|
|
@ -353,6 +354,7 @@ async fn end_to_end_branching_pipeline() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = engine
|
||||
|
|
@ -480,6 +482,7 @@ async fn end_to_end_human_gate_pipeline() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = engine
|
||||
|
|
@ -597,6 +600,7 @@ async fn goal_gate_routes_to_retry_target_on_failure() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let result = engine.run(&graph, &config).await;
|
||||
|
|
@ -724,6 +728,7 @@ async fn goal_gate_routes_to_retry_target_when_present() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = engine
|
||||
|
|
@ -1042,6 +1047,7 @@ async fn retry_on_failure_then_succeed() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = engine
|
||||
|
|
@ -1123,6 +1129,7 @@ async fn pipeline_with_many_nodes() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = engine
|
||||
|
|
@ -1455,6 +1462,7 @@ async fn smoke_test_with_mock_codergen_backend() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = engine
|
||||
|
|
@ -1562,6 +1570,7 @@ async fn end_to_end_parallel_fan_out_fan_in() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = engine
|
||||
|
|
@ -1681,6 +1690,7 @@ async fn resume_from_checkpoint_completes_pipeline() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = engine
|
||||
|
|
@ -1786,6 +1796,7 @@ async fn resume_from_checkpoint_preserves_goal_gate_outcomes() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
// This should succeed because goal gate for gated_work is satisfied
|
||||
|
|
@ -1835,6 +1846,7 @@ async fn graph_goal_in_context() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&graph, &config).await.expect("run");
|
||||
|
||||
|
|
@ -1876,6 +1888,7 @@ async fn event_streaming_lifecycle() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&graph, &config).await.expect("run");
|
||||
|
||||
|
|
@ -1961,6 +1974,7 @@ async fn context_flow_between_stages() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&graph, &config).await.expect("run");
|
||||
|
||||
|
|
@ -2019,6 +2033,7 @@ async fn tool_handler_e2e() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let outcome = engine.run(&graph, &config).await.expect("run");
|
||||
assert_eq!(outcome.status, StageStatus::Success);
|
||||
|
|
@ -2094,6 +2109,7 @@ async fn auto_approve_interviewer_e2e() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let outcome = engine.run(&graph, &config).await.expect("run");
|
||||
assert_eq!(outcome.status, StageStatus::Success);
|
||||
|
|
@ -2136,6 +2152,7 @@ async fn codergen_without_backend_simulated() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&graph, &config).await.expect("run");
|
||||
|
||||
|
|
@ -2246,6 +2263,7 @@ async fn branching_loop_back_on_failure() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let outcome = engine.run(&graph, &config).await.expect("run");
|
||||
assert_eq!(outcome.status, StageStatus::Success);
|
||||
|
|
@ -2336,6 +2354,7 @@ async fn human_gate_loops_back() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let outcome = engine.run(&graph, &config).await.expect("run");
|
||||
assert_eq!(outcome.status, StageStatus::Success);
|
||||
|
|
@ -2399,6 +2418,7 @@ async fn scenario_ship_a_feature() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let outcome = engine.run(&graph, &config).await.expect("run");
|
||||
assert_eq!(outcome.status, StageStatus::Success);
|
||||
|
|
@ -2490,6 +2510,7 @@ async fn scenario_parallel_expert_review() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let outcome = engine.run(&graph, &config).await.expect("run");
|
||||
assert_eq!(outcome.status, StageStatus::Success);
|
||||
|
|
@ -2579,6 +2600,7 @@ async fn scenario_node_retries_on_retry_status() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let outcome = engine.run(&graph, &config).await.expect("run");
|
||||
assert_eq!(outcome.status, StageStatus::Success);
|
||||
|
|
@ -2646,6 +2668,7 @@ async fn scenario_loop_restart_resets_context() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let outcome = engine.run(&graph, &config).await.expect("run");
|
||||
assert_eq!(outcome.status, StageStatus::Success);
|
||||
|
|
@ -2719,6 +2742,7 @@ async fn scenario_bug_triage_router() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let outcome = engine.run(&graph, &config).await.expect("run");
|
||||
assert_eq!(outcome.status, StageStatus::Success);
|
||||
|
|
@ -2783,6 +2807,7 @@ async fn scenario_crash_recovery() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let outcome = engine
|
||||
.run_from_checkpoint(&graph, &config, &checkpoint)
|
||||
|
|
@ -2897,6 +2922,7 @@ async fn manager_loop_stop_condition_satisfied_e2e() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let outcome = engine.run(&graph, &config).await.expect("run");
|
||||
|
||||
|
|
@ -2979,6 +3005,7 @@ async fn manager_loop_max_cycles_exceeded_e2e() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let outcome = engine.run(&graph, &config).await.expect("run");
|
||||
|
||||
|
|
@ -3120,6 +3147,7 @@ async fn conditional_branching_success_fail_paths() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let outcome = engine.run(&graph, &config).await.expect("run");
|
||||
assert_eq!(outcome.status, StageStatus::Success);
|
||||
|
|
@ -3178,6 +3206,7 @@ async fn edge_selection_condition_match_wins_over_weight() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&graph, &config).await.expect("run");
|
||||
|
||||
|
|
@ -3230,6 +3259,7 @@ async fn edge_selection_weight_breaks_ties() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&graph, &config).await.expect("run");
|
||||
|
||||
|
|
@ -3274,6 +3304,7 @@ async fn edge_selection_lexical_tiebreak() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&graph, &config).await.expect("run");
|
||||
|
||||
|
|
@ -3337,6 +3368,7 @@ async fn context_updates_visible_across_nodes() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&graph, &config).await.expect("run");
|
||||
|
||||
|
|
@ -3386,6 +3418,7 @@ async fn stylesheet_applies_model_override() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let outcome = engine.run(&graph, &config).await.expect("run");
|
||||
assert_eq!(outcome.status, StageStatus::Success);
|
||||
|
|
@ -3447,6 +3480,7 @@ async fn custom_handler_registration_and_execution() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&graph, &config).await.expect("run");
|
||||
|
||||
|
|
@ -3523,6 +3557,7 @@ async fn integration_smoke_plan_implement_review_done() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let outcome = engine.run(&graph, &config).await.expect("run");
|
||||
assert_eq!(outcome.status, StageStatus::Success);
|
||||
|
|
@ -3632,6 +3667,7 @@ async fn manager_loop_runs_child_engine_e2e() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = engine
|
||||
|
|
@ -3772,6 +3808,7 @@ async fn manager_loop_context_flows_e2e() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = engine.run(&graph, &config).await.expect("run");
|
||||
|
|
@ -3851,6 +3888,7 @@ async fn manager_loop_child_dotfile_e2e() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = engine.run(&graph, &config).await.expect("run");
|
||||
|
|
@ -3970,6 +4008,7 @@ async fn graph_merge_e2e_through_engine() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = engine
|
||||
|
|
@ -4126,6 +4165,7 @@ async fn fidelity_default_is_compact() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&graph, &config).await.expect("run");
|
||||
|
||||
|
|
@ -4188,6 +4228,7 @@ async fn fidelity_graph_default_applied() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&graph, &config).await.expect("run");
|
||||
|
||||
|
|
@ -4246,6 +4287,7 @@ async fn fidelity_node_overrides_graph_default() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&graph, &config).await.expect("run");
|
||||
|
||||
|
|
@ -4310,6 +4352,7 @@ async fn fidelity_edge_overrides_node_and_graph() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&graph, &config).await.expect("run");
|
||||
|
||||
|
|
@ -4364,6 +4407,7 @@ async fn fidelity_full_produces_empty_preamble() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&graph, &config).await.expect("run");
|
||||
|
||||
|
|
@ -4428,6 +4472,7 @@ async fn fidelity_truncate_preamble_minimal() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&graph, &config).await.expect("run");
|
||||
|
||||
|
|
@ -4505,6 +4550,7 @@ async fn fidelity_summary_low_mode() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&graph, &config).await.expect("run");
|
||||
|
||||
|
|
@ -4577,6 +4623,7 @@ async fn fidelity_summary_medium_mode() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&graph, &config).await.expect("run");
|
||||
|
||||
|
|
@ -4649,6 +4696,7 @@ async fn fidelity_summary_high_mode() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&graph, &config).await.expect("run");
|
||||
|
||||
|
|
@ -4714,6 +4762,7 @@ async fn fidelity_full_sets_thread_id_in_context() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&graph, &config).await.expect("run");
|
||||
|
||||
|
|
@ -4790,6 +4839,7 @@ async fn fidelity_full_nodes_share_thread_id() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&graph, &config).await.expect("run");
|
||||
|
||||
|
|
@ -4876,6 +4926,7 @@ async fn fidelity_resume_degrades_full_to_summary_high() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine
|
||||
.run_from_checkpoint(&graph, &config, &checkpoint)
|
||||
|
|
@ -4978,6 +5029,7 @@ async fn fidelity_resume_degrade_only_affects_first_hop() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine
|
||||
.run_from_checkpoint(&graph, &config, &checkpoint)
|
||||
|
|
@ -5067,6 +5119,7 @@ async fn fidelity_resume_no_degrade_when_not_full() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine
|
||||
.run_from_checkpoint(&graph, &config, &checkpoint)
|
||||
|
|
@ -5114,6 +5167,7 @@ async fn fidelity_stored_in_checkpoint_context() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&graph, &config).await.expect("run");
|
||||
|
||||
|
|
@ -5205,6 +5259,7 @@ async fn fidelity_precedence_multi_node_pipeline() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&graph, &config).await.expect("run");
|
||||
|
||||
|
|
@ -5278,6 +5333,7 @@ async fn fidelity_compact_preamble_includes_completed_stages_and_context() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&graph, &config).await.expect("run");
|
||||
|
||||
|
|
@ -5359,6 +5415,7 @@ async fn fidelity_summary_low_excludes_context_values_in_pipeline() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine_low
|
||||
.run(&graph_low, &config_low)
|
||||
|
|
@ -5432,6 +5489,7 @@ async fn fidelity_summary_low_excludes_context_values_in_pipeline() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine_med
|
||||
.run(&graph_med, &config_med)
|
||||
|
|
@ -5508,6 +5566,7 @@ async fn fidelity_thread_id_fallback_to_previous_node_in_pipeline() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&graph, &config).await.expect("run");
|
||||
|
||||
|
|
@ -5567,6 +5626,7 @@ async fn fidelity_thread_id_from_node_class_in_pipeline() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&graph, &config).await.expect("run");
|
||||
|
||||
|
|
@ -5629,6 +5689,7 @@ async fn fidelity_edge_thread_id_override_in_pipeline() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&graph, &config).await.expect("run");
|
||||
|
||||
|
|
@ -5692,6 +5753,7 @@ async fn fidelity_full_without_explicit_thread_id_uses_previous_node() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&graph, &config).await.expect("run");
|
||||
|
||||
|
|
@ -5765,6 +5827,7 @@ async fn fidelity_from_parsed_dot_pipeline() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&graph, &config).await.expect("run");
|
||||
|
||||
|
|
@ -5818,6 +5881,7 @@ async fn fidelity_checkpoint_roundtrip_preserves_fidelity() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&graph, &config).await.expect("run");
|
||||
|
||||
|
|
@ -5893,6 +5957,7 @@ async fn fidelity_node_thread_id_overrides_edge_thread_id_in_pipeline() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine.run(&graph, &config).await.expect("run");
|
||||
|
||||
|
|
@ -5985,6 +6050,7 @@ async fn fidelity_resume_preserves_context_values_across_checkpoint() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
engine
|
||||
.run_from_checkpoint(&graph, &config, &checkpoint)
|
||||
|
|
@ -6202,6 +6268,7 @@ mod real_llm {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = tokio::time::timeout(
|
||||
|
|
@ -6322,6 +6389,7 @@ mod real_llm {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = tokio::time::timeout(
|
||||
|
|
@ -6467,6 +6535,7 @@ mod real_llm {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = tokio::time::timeout(
|
||||
|
|
@ -6580,6 +6649,7 @@ mod real_llm {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = tokio::time::timeout(
|
||||
|
|
@ -6682,6 +6752,7 @@ async fn human_gate_freeform_only_routes_text() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = engine
|
||||
|
|
@ -6819,6 +6890,7 @@ async fn human_gate_freeform_with_fixed_choice_match() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = engine
|
||||
|
|
@ -6940,6 +7012,7 @@ async fn human_gate_freeform_fallback_on_unmatched_text() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = engine
|
||||
|
|
@ -7075,6 +7148,7 @@ async fn human_gate_freeform_sets_allow_freeform_on_question() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = engine
|
||||
|
|
@ -7190,6 +7264,7 @@ async fn human_gate_without_freeform_sets_allow_freeform_false() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = engine
|
||||
|
|
@ -7456,6 +7531,7 @@ fn make_run_config(dir: &std::path::Path) -> RunConfig {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
}
|
||||
}
|
||||
|
||||
|
|
@ -8598,6 +8674,7 @@ async fn arc_e2e_with_real_llm() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = engine
|
||||
|
|
@ -8732,6 +8809,7 @@ async fn run_fidelity_prompt_pipeline(fidelity: &str) -> String {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
engine
|
||||
|
|
@ -8937,6 +9015,7 @@ async fn large_context_values_are_offloaded_to_artifact_store() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = engine
|
||||
|
|
@ -9163,6 +9242,7 @@ async fn artifact_pointers_rewritten_for_remote_sandbox() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = engine
|
||||
|
|
@ -9299,6 +9379,7 @@ async fn node_dir_uses_visit_count_on_revisit() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = engine
|
||||
|
|
@ -10279,6 +10360,7 @@ async fn full_pipeline_with_cli_backend_node() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = engine
|
||||
|
|
@ -10416,6 +10498,7 @@ async fn stylesheet_backend_property_routes_to_cli() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = engine
|
||||
|
|
@ -10703,6 +10786,7 @@ async fn git_checkpoint_host_emits_events_and_diff_patch() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
// 5. Run pipeline
|
||||
|
|
@ -10895,6 +10979,7 @@ async fn git_checkpoint_host_writes_shadow_branch() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
// 5. Run pipeline
|
||||
|
|
@ -11095,6 +11180,7 @@ async fn parallel_git_branching_host_e2e() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
// 5. Run pipeline
|
||||
|
|
@ -11360,6 +11446,7 @@ async fn git_checkpoint_host_skips_empty_diff_patch() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = engine
|
||||
|
|
@ -11744,6 +11831,7 @@ async fn e2e_circuit_breaker_deterministic_self_loop() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let result = engine.run(&graph, &config).await;
|
||||
|
|
@ -11797,6 +11885,7 @@ async fn e2e_circuit_breaker_custom_limit() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let result = engine.run(&graph, &config).await;
|
||||
|
|
@ -11843,6 +11932,7 @@ async fn e2e_circuit_breaker_ignores_transient_failures() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let result = engine.run(&graph, &config).await;
|
||||
|
|
@ -11896,6 +11986,7 @@ async fn e2e_circuit_breaker_different_reasons_separate_counters() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let result = engine.run(&graph, &config).await;
|
||||
|
|
@ -11942,6 +12033,7 @@ async fn e2e_circuit_breaker_loop_restart() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let result = engine.run(&graph, &config).await;
|
||||
|
|
@ -12010,6 +12102,7 @@ async fn e2e_failure_signature_persisted_in_context() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = engine.run(&graph, &config).await.unwrap();
|
||||
|
|
@ -12080,6 +12173,7 @@ async fn e2e_failure_signature_hint_overrides_reason_in_context() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let _outcome = engine.run(&graph, &config).await.unwrap();
|
||||
|
|
@ -12142,6 +12236,7 @@ async fn e2e_signature_maps_persist_in_checkpoint() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = engine.run(&graph, &config).await.unwrap();
|
||||
|
|
@ -12275,6 +12370,7 @@ async fn e2e_circuit_breaker_emits_events_before_abort() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let result = engine.run(&graph, &config).await;
|
||||
|
|
@ -12348,6 +12444,7 @@ async fn e2e_circuit_breaker_does_not_fire_below_limit() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = engine.run(&graph, &config).await.unwrap();
|
||||
|
|
@ -12450,6 +12547,7 @@ async fn e2e_circuit_breaker_multi_stage_impl_verify_cycle() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let result = engine.run(&graph, &config).await;
|
||||
|
|
@ -12553,6 +12651,7 @@ async fn e2e_loop_restart_blocked_for_deterministic_failure() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let result = engine.run(&graph, &config).await;
|
||||
|
|
@ -12599,6 +12698,7 @@ async fn e2e_loop_restart_blocked_for_structural_failure() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let result = engine.run(&graph, &config).await;
|
||||
|
|
@ -12645,6 +12745,7 @@ async fn e2e_loop_restart_blocked_for_budget_exhausted_failure() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let result = engine.run(&graph, &config).await;
|
||||
|
|
@ -12691,6 +12792,7 @@ async fn e2e_loop_restart_blocked_for_canceled_failure() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let result = engine.run(&graph, &config).await;
|
||||
|
|
@ -12734,6 +12836,7 @@ async fn e2e_loop_restart_blocked_for_compilation_loop_failure() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let result = engine.run(&graph, &config).await;
|
||||
|
|
@ -12781,6 +12884,7 @@ async fn e2e_loop_restart_allowed_for_transient_infra() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let result = engine.run(&graph, &config).await;
|
||||
|
|
@ -12891,6 +12995,7 @@ async fn e2e_stall_watchdog_triggers_from_dot_parsed_pipeline() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let result = engine.run(&graph, &config).await;
|
||||
|
|
@ -12953,6 +13058,7 @@ async fn e2e_stall_watchdog_kept_alive_by_handler_events() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = engine
|
||||
|
|
@ -13005,6 +13111,7 @@ async fn e2e_stall_watchdog_disabled_with_zero_timeout() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = engine
|
||||
|
|
@ -13076,6 +13183,7 @@ async fn e2e_stall_watchdog_with_explicit_timeout_override() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let start = std::time::Instant::now();
|
||||
|
|
@ -13213,6 +13321,7 @@ async fn asset_collection_local_sandbox_success() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: vec!["test-results/**".to_string()],
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = engine
|
||||
|
|
@ -13328,6 +13437,7 @@ async fn asset_collection_local_sandbox_on_failure() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: vec!["test-results/**".to_string()],
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = engine
|
||||
|
|
@ -13425,6 +13535,7 @@ async fn asset_collection_docker_sandbox() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
|
||||
let outcome = engine
|
||||
|
|
@ -13500,6 +13611,7 @@ async fn wait_timer_e2e() {
|
|||
pull_request_enabled: false,
|
||||
pull_request_draft: false,
|
||||
asset_globs: Vec::new(),
|
||||
workflow_slug: None,
|
||||
};
|
||||
let outcome = engine.run(&graph, &config).await.expect("run");
|
||||
assert_eq!(outcome.status, StageStatus::Success);
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue