From 9393c27cdb709a31ce25703ffbbd98b5d2be9191 Mon Sep 17 00:00:00 2001 From: Mathias Date: Fri, 2 Oct 2026 08:53:10 +0200 Subject: [PATCH] test(uploads): the worker waits for its heartbeat to finish -- a mutation that skipped the wait survived until now Co-Authored-By: Claude Sonnet 5.5 --- internal/uploads/worker_progress_test.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/uploads/worker_progress_test.go b/internal/uploads/worker_progress_test.go index 24611ea..b6e1cf1 100644 --- a/internal/uploads/worker_progress_test.go +++ b/internal/uploads/worker_progress_test.go @@ -131,6 +131,7 @@ func TestWorkerProgress_AShutdownIsNotRecordedAsAFailedStep(t *testing.T) { func TestWorkerProgress_TheHeartbeatBeatsWhileAnEngineCallIsStuckAndStopsWhenTheJobEnds(t *testing.T) { r := newWRig(t, time.Minute) r.tr.block = make(chan struct{}) + r.st.beatDelay = 20 * time.Millisecond w := newProgressWorker(t, r, r.tr, uploads.WithHeartbeat(5*time.Millisecond, time.Hour)) done := make(chan struct{}) go func() { defer close(done); w.Process(context.Background(), r.spool(t, "a")) }()