i/Aether
1
0
Fork 0
mirror of https://github.com/fawney19/Aether.git synced 2026-09-10 05:00:19 +08:00
Code Issues Packages Projects Releases Wiki Activity

Stabilize stream runtime nextest timing

Browse Source
This commit is contained in:
fawney19
2026-05-27 11:00:04 +08:00
parent dd2da69361
commit 674cc85005
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
apps/aether-gateway/src/execution_runtime/stream/execution.rs
+2 -2
View File
@@ -5937,7 +5937,7 @@ mod tests {
.expect("execution should return a client response");
first_data_seen.notified().await;
let deadline = tokio::time::Instant::now() + Duration::from_secs(2);
let deadline = tokio::time::Instant::now() + Duration::from_secs(15);
let live_usage = loop {
let usage = usage_repository
.find_by_request_id("req-live-stream-first-data")
@@ -6102,7 +6102,7 @@ mod tests {
.expect("execution should return a client response");
first_event_seen.notified().await;
let deadline = tokio::time::Instant::now() + Duration::from_secs(2);
let deadline = tokio::time::Instant::now() + Duration::from_secs(15);
let first_event_usage = loop {
let usage = usage_repository
.find_by_request_id("req-live-stream-first-event")
apps/aether-gateway/src/execution_runtime/transport.rs
+1 -1
View File
@@ -2398,7 +2398,7 @@ mod tests {
format!("http://{addr}/chat"),
true,
ExecutionTimeouts {
first_byte_ms: Some(1_000),
first_byte_ms: Some(5_000),
total_ms: Some(25),
..ExecutionTimeouts::default()
},