diff --git a/internal/repository/worker_group.go b/internal/repository/worker_group.go index 6b9dc6ddf..20783b188 100644 --- a/internal/repository/worker_group.go +++ b/internal/repository/worker_group.go @@ -24,10 +24,6 @@ func RunWorkers(ctx context.Context, count int, workerFunc func() error, finalFu // make sure finalFunc is run finalFunc() - // if the workers returned an error, return it to the caller - if err != nil { - return err - } - - return nil + // return error from workers to the caller + return err }