style(runner): format Pi cold admission tests

This commit is contained in:
Dotta committed 2026-10-02 10:53:28 -05:00
1 parent 33f4a2137d
commit 852b22755b
2 files changed
+26 -11

No files matched your search

@@ -793,7 +793,10 @@ mod tests {
#[test]
fn only_pi_cold_open_gets_the_longer_admission_budget() {
let ordinary = Duration::from_secs(30);
assert_eq!(session_open_timeout("pi", ordinary), Duration::from_secs(60));
assert_eq!(
session_open_timeout("pi", ordinary),
Duration::from_secs(60)
);
for agent in ["claude", "codex", "grok", "cursor", "copilot"] {
assert_eq!(session_open_timeout(agent, ordinary), ordinary);
}
@@ -303,17 +303,29 @@ fn assigned_gateway_binding_reaches_qualified_sidecar_without_unrelated_secrets(
#[test]
fn pi_ordinary_request_timeout_still_retires_the_sidecar() {
let mut sidecar = AcpxSidecarTransport::start_for_agent(&AcpxSidecarTransportConfig {
command: PathBuf::from(env!("CARGO_BIN_EXE_fake-acpx-sidecar")),
args: vec!["--mode".to_owned(), "silent".to_owned()],
verified_launch: None,
request_timeout: Duration::from_millis(30),
shutdown_grace: Duration::from_millis(50),
}, "pi").unwrap();
let mut sidecar = AcpxSidecarTransport::start_for_agent(
&AcpxSidecarTransportConfig {
command: PathBuf::from(env!("CARGO_BIN_EXE_fake-acpx-sidecar")),
args: vec!["--mode".to_owned(), "silent".to_owned()],
verified_launch: None,
request_timeout: Duration::from_millis(30),
shutdown_grace: Duration::from_millis(50),
},
"pi",
)
.unwrap();
let started = Instant::now();
let error = sidecar.request(GeneratedAcpxSidecarCommand::Initialize, json!({})).unwrap_err();
let error = sidecar
.request(GeneratedAcpxSidecarCommand::Initialize, json!({}))
.unwrap_err();
assert!(error.to_string().contains("timed out"));
assert!(started.elapsed() < Duration::from_secs(1));
assert!(sidecar.request(GeneratedAcpxSidecarCommand::SessionOpen, json!({})).unwrap_err().to_string().contains("unavailable"));
sidecar.shutdown().expect("timeout cleanup remains idempotent");
assert!(sidecar
.request(GeneratedAcpxSidecarCommand::SessionOpen, json!({}))
.unwrap_err()
.to_string()
.contains("unavailable"));
sidecar
.shutdown()
.expect("timeout cleanup remains idempotent");
}