Launch primitive: test-name and import fixes
Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>
This commit is contained in:
parent
cfbecd307f
commit
92c193c965
2 changed files with 4 additions and 2 deletions
|
|
@ -144,7 +144,7 @@ pub enum LaunchOutcome {
|
|||
Refused(Declined),
|
||||
}
|
||||
|
||||
fn run_ref(instance: &Slug, label: &Label) -> PipelineRef {
|
||||
fn opened_run(instance: &Slug, label: &Label) -> PipelineRef {
|
||||
PipelineRef { kind: PipelineKind::Run, id: format!("{}:run:{}", instance.0, label.0).as_str().into() }
|
||||
}
|
||||
|
||||
|
|
@ -205,7 +205,7 @@ pub fn open_and_launch(ports: &Ports, request: LaunchRequest) -> Result<LaunchOu
|
|||
if let Err(declined) = committed(ports.mind.admit(&agent, &label.0, vec![PipelineDocument::Run(run)])?) {
|
||||
return Ok(LaunchOutcome::Refused(declined));
|
||||
}
|
||||
let run = run_ref(&instance, &label);
|
||||
let run = opened_run(&instance, &label);
|
||||
if ports.launcher.start(turn, &label).is_err() {
|
||||
let withdrawal = PipelineResolution {
|
||||
subject: run,
|
||||
|
|
|
|||
|
|
@ -225,6 +225,8 @@ mod tests {
|
|||
use std::net::SocketAddr;
|
||||
use std::time::Duration;
|
||||
|
||||
use eureka_pipeline::{RunOperator, RunTurn};
|
||||
|
||||
use super::*;
|
||||
use crate::testkit::*;
|
||||
|
||||
|
|
|
|||
Loading…
Reference in a new issue