diff --git a/.changelog/6444.bugfix.md b/.changelog/6444.bugfix.md new file mode 100644 index 00000000000..4086bf5a87e --- /dev/null +++ b/.changelog/6444.bugfix.md @@ -0,0 +1 @@ +go/worker/storage/committee: Fix worker teardown diff --git a/go/worker/storage/committee/worker.go b/go/worker/storage/committee/worker.go index ab3d2ffa80b..8fcea2e56e6 100644 --- a/go/worker/storage/committee/worker.go +++ b/go/worker/storage/committee/worker.go @@ -1086,12 +1086,9 @@ func (w *Worker) Serve(ctx context.Context) error { // nolint: gocyclo rootType := prevRoots[i].Type if !syncing.outstanding.contains(rootType) && syncing.awaitingRetry.contains(rootType) { syncing.scheduleDiff(rootType) - doneCh := fetchPool.Submit(func() { + _ = fetchPool.Submit(func() { w.fetchDiff(ctx, this.Round, prevRoots[i], this.Roots[i]) }) - wg.Go(func() { - <-doneCh - }) } } }