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")) }()