diff options
| author | Gabriel Arakaki Giovanini <mail@gabrielgio.me> | 2023-06-23 21:25:37 +0200 |
|---|---|---|
| committer | Gabriel Arakaki Giovanini <mail@gabrielgio.me> | 2023-06-23 21:25:37 +0200 |
| commit | 1dea35b9bcb3d37d61e554a99488626da9795331 (patch) | |
| tree | c8d7cea6e3b44121e067edebf91f2044f8538b6b /pkg/worker/worker.go | |
| parent | 8eeddc0bfb574aada6bb76638957421b52344bb0 (diff) | |
| download | lens-1dea35b9bcb3d37d61e554a99488626da9795331.tar.gz lens-1dea35b9bcb3d37d61e554a99488626da9795331.tar.bz2 lens-1dea35b9bcb3d37d61e554a99488626da9795331.zip | |
feat: Remove unecessary param from repo
Diffstat (limited to 'pkg/worker/worker.go')
| -rw-r--r-- | pkg/worker/worker.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/pkg/worker/worker.go b/pkg/worker/worker.go index c52f0be..18cc0e2 100644 --- a/pkg/worker/worker.go +++ b/pkg/worker/worker.go @@ -36,12 +36,12 @@ func (self *WorkerPool) AddWorker(name string, worker Worker) { } func (self *WorkerPool) Start(ctx context.Context) { + self.wg.Add(len(self.workers)) for _, w := range self.workers { - self.wg.Add(1) go func(w *Work) { defer self.wg.Done() if err := w.Worker.Start(ctx); err != nil && !errors.Is(err, context.Canceled) { - fmt.Println("Error ", w.Name, err.Error()) + fmt.Println("Processes finished, error", w.Name, err.Error()) } else { fmt.Println(w.Name, "done") } |