summaryrefslogtreecommitdiff
path: root/worker_watcher.go
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2020-12-15 13:11:23 +0300
committerValery Piashchynski <[email protected]>2020-12-15 13:11:23 +0300
commit7b0a6720c21056ed4b922eb5b1b8a91a44dc3638 (patch)
tree1c826999423e59db5b7dab1184725e22468ecfbd /worker_watcher.go
parent61279e26fb5dc5ae36263f3dddb02bd22c0c07ba (diff)
Fix golangci-lint warnings
Diffstat (limited to 'worker_watcher.go')
-rwxr-xr-xworker_watcher.go3
1 files changed, 0 insertions, 3 deletions
diff --git a/worker_watcher.go b/worker_watcher.go
index f9b3d372..f8fb67a9 100755
--- a/worker_watcher.go
+++ b/worker_watcher.go
@@ -228,7 +228,6 @@ func (ww *workerWatcher) GetFreeWorker(ctx context.Context) (WorkerBase, error)
if w == nil {
continue
}
- //ww.ReduceWorkersCount()
return w, nil
case <-ctx.Done():
return nil, errors.E(op, errors.NoFreeWorkers, errors.Str("no free workers in the stack, timeout exceed"))
@@ -236,7 +235,6 @@ func (ww *workerWatcher) GetFreeWorker(ctx context.Context) (WorkerBase, error)
}
}
- //ww.ReduceWorkersCount()
return w, nil
}
@@ -278,7 +276,6 @@ func (ww *workerWatcher) RemoveWorker(wb WorkerBase) error {
wb.State().Set(StateRemove)
return nil
-
}
// O(1) operation