diff options
| author | Valery Piashchynski <[email protected]> | 2021-02-08 01:09:17 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-02-08 01:09:17 +0300 |
| commit | 3e92e3df723ca1c4f152d8526eebfd7184e6fcec (patch) | |
| tree | cda1f4b7dafd5516c8a12b593a5b4e7d2f445f56 /pkg/worker_watcher | |
| parent | d353bc5f0be991ad44208e48ed04dc61ee53c340 (diff) | |
Push worker to the stack typo
Diffstat (limited to 'pkg/worker_watcher')
| -rwxr-xr-x | pkg/worker_watcher/worker_watcher.go | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/pkg/worker_watcher/worker_watcher.go b/pkg/worker_watcher/worker_watcher.go index 1e229d9d..d065bae5 100755 --- a/pkg/worker_watcher/worker_watcher.go +++ b/pkg/worker_watcher/worker_watcher.go @@ -54,6 +54,10 @@ func (ww *workerWatcher) Get(ctx context.Context) (worker.SyncWorker, error) { } // ========================================================= // SLOW PATH + // Put worker back (no matter it's state, it will be killed next) + if w != nil { + ww.stack.Push(w) + } // no free workers in the stack // try to continuously get free one for { |