From 7b6a3514dd9f7c6454a1b753a5b5247cab064722 Mon Sep 17 00:00:00 2001 From: Richard McDaniel <1130888+rmcdaniel@users.noreply.github.com> Date: Fri, 13 Nov 2026 23:41:40 +0000 Subject: [PATCH] Register each cold logging worker before polling --- tests/workflow_logging_server.rs | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/tests/workflow_logging_server.rs b/tests/workflow_logging_server.rs index 8d81fee..54252c9 100644 --- a/tests/workflow_logging_server.rs +++ b/tests/workflow_logging_server.rs @@ -168,7 +168,9 @@ async fn published_logging_worker_entrypoint() { let kind = std::env::var(TYPE).unwrap(); let phase = std::env::var(PHASE).unwrap(); let capture = std::sync::Arc::new(Capture::default()); - let handled = worker(client(), &queue, &kind, &phase) + let worker = worker(client(), &queue, &kind, &phase); + worker.register().await.unwrap(); + let handled = worker .run_once() .with_subscriber(capture.clone()) .await