mathias/tapir
1
0
Fork 0
Code Issues 35 Pull Requests Actions Packages Projects Releases Wiki Activity

test(uploads): the worker waits for its heartbeat to finish -- a mutation that skipped the wait survived until now

Browse Source 
Co-Authored-By: Claude Sonnet 5.5 <noreply@anthropic.com>
This commit is contained in:
mathias
2026-10-02 08:53:10 +02:00
co-authored by Claude Sonnet 5.5
parent 538ed93ccd
commit 9393c27cdb
1 changed files with 1 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/uploads/worker_progress_test.go
+1
View File
@@ -131,6 +131,7 @@ func TestWorkerProgress_AShutdownIsNotRecordedAsAFailedStep(t *testing.T) {
func TestWorkerProgress_TheHeartbeatBeatsWhileAnEngineCallIsStuckAndStopsWhenTheJobEnds(t *testing.T) { func TestWorkerProgress_TheHeartbeatBeatsWhileAnEngineCallIsStuckAndStopsWhenTheJobEnds(t *testing.T) {
r := newWRig(t, time.Minute) r := newWRig(t, time.Minute)
r.tr.block = make(chan struct{}) 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)) w := newProgressWorker(t, r, r.tr, uploads.WithHeartbeat(5*time.Millisecond, time.Hour))
done := make(chan struct{}) done := make(chan struct{})
go func() { defer close(done); w.Process(context.Background(), r.spool(t, "a")) }() go func() { defer close(done); w.Process(context.Background(), r.spool(t, "a")) }()