From b3480de83b30764b6d4237f5de243a49d9a22f61 Mon Sep 17 00:00:00 2001
From: Richard McDaniel <1130888+rmcdaniel@users.noreply.github.com>
Date: Fri, 13 Nov 2026 12:54:16 +0000
Subject: [PATCH] Bound completion qualifier polling for shutdown

---
 tests/completion_limits_server.rs | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/tests/completion_limits_server.rs b/tests/completion_limits_server.rs
index 7eef83e..1ebde69 100644
--- a/tests/completion_limits_server.rs
+++ b/tests/completion_limits_server.rs
@@ -51,7 +51,9 @@ async fn published_worker_completes_inline_fanout_and_fails_an_oversized_batch()
     );
 
     let queue = format!("completion-limits-{}", durable_workflow::Uuid::new_v4());
-    let mut worker = Worker::new(client.clone(), &queue).max_concurrent_activity_tasks(16);
+    let mut worker = Worker::new(client.clone(), &queue)
+        .poll_timeout(Duration::from_millis(10))
+        .max_concurrent_activity_tasks(16);
     worker.register_activity("limits.bytes", |_, args| async move {
         Ok(json!(args[0].as_str().unwrap().len()))
     });