(maka) branch rust-preview updated: test(agent): await compaction workers without busy polling

[wy...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

M4n5ter pushed a commit to branch rust-preview
in repository https://gitbox.apache.org/repos/asf/maka.git


The following commit(s) were added to refs/heads/rust-preview by this push:
     new 056fc33f18 test(agent): await compaction workers without busy polling
056fc33f18 is described below

commit 056fc33f18aad3dffc971e50ef345564498fd055
Author: Wang <m4...@gmail.com>
AuthorDate: Sun Oct 18 00:28:00 2026 +0800

    test(agent): await compaction workers without busy polling
    
    Generated-by: Codex
---
 plugins/agent/native/src/owner/tests/scale/compaction.rs | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/plugins/agent/native/src/owner/tests/scale/compaction.rs b/plugins/agent/native/src/owner/tests/scale/compaction.rs
index 778213960b..2ec936fa55 100644
--- a/plugins/agent/native/src/owner/tests/scale/compaction.rs
+++ b/plugins/agent/native/src/owner/tests/scale/compaction.rs
@@ -229,7 +229,11 @@ async fn phase(
         .expect("controlled HTTP phase must match its explicit plan");
     assert_eq!(arrival.cycle, expected.cycle);
     assert_eq!(arrival.purpose, expected.purpose);
-    load.fixture.drained().await;
+    // This sequential fixture owns the tracker until shutdown. Wait for its
+    // notification instead of charging a self-waking observer to each phase.
+    assert!(load.fixture.owner.workers.close());
+    load.fixture.owner.workers.wait().await;
+    assert!(load.fixture.owner.workers.reopen());
     let completion_ms = start.elapsed().as_secs_f64() * 1000.0;
     let cpu_seconds = usage().0 - cpu;
     let through = *load.fixture.store.subscribe_commits().borrow();


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@maka.apache.org
For additional commands, e-mail: commits-help@maka.apache.org