summaryrefslogtreecommitdiff
path: root/pkg/worker_watcher
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2020-12-17 03:23:41 +0300
committerValery Piashchynski <[email protected]>2020-12-17 03:23:41 +0300
commit2d5a042cd4c80b1989b8235a7412110d435b1130 (patch)
treeb4c6a4d0b72bb05555142de80c5402c3d1b1ba69 /pkg/worker_watcher
parent40cfd9f6b44dfe987bfbf010bf67b32abdc64208 (diff)
Fix race condition
Diffstat (limited to 'pkg/worker_watcher')
-rwxr-xr-xpkg/worker_watcher/worker_watcher.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/pkg/worker_watcher/worker_watcher.go b/pkg/worker_watcher/worker_watcher.go
index 8a71ff8a..8788e509 100755
--- a/pkg/worker_watcher/worker_watcher.go
+++ b/pkg/worker_watcher/worker_watcher.go
@@ -172,7 +172,7 @@ func (ww *workerWatcher) AddToWatch(workers []worker.BaseProcess) error {
go func(swc worker.BaseProcess) {
ww.wait(swc)
- }(workers[i])
+ }(sw)
}
return nil
}