diff options
| author | Valery Piashchynski <[email protected]> | 2021-01-05 17:37:17 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-01-05 17:37:17 +0300 |
| commit | 13b01ccaba1eedeb99d37842ec8f2019d2625187 (patch) | |
| tree | c645c240336666fa63d70ed2703a78df828c597f /pkg/worker_watcher | |
| parent | 877b0ed461c7d5e1de87b7561f414aeb236cf3ec (diff) | |
Finish implementation of the KV
Diffstat (limited to 'pkg/worker_watcher')
| -rwxr-xr-x | pkg/worker_watcher/worker_watcher.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/pkg/worker_watcher/worker_watcher.go b/pkg/worker_watcher/worker_watcher.go index 5c0882b0..348f0459 100755 --- a/pkg/worker_watcher/worker_watcher.go +++ b/pkg/worker_watcher/worker_watcher.go @@ -178,7 +178,7 @@ func (ww *workerWatcher) GetFreeWorker(ctx context.Context) (worker.BaseProcess, // thread safe operation w, stop := ww.stack.Pop() if stop { - return nil, errors.E(op, errors.ErrWatcherStopped) + return nil, errors.E(op, errors.WatcherStopped) } // handle worker remove state @@ -198,7 +198,7 @@ func (ww *workerWatcher) GetFreeWorker(ctx context.Context) (worker.BaseProcess, default: w, stop = ww.stack.Pop() if stop { - return nil, errors.E(op, errors.ErrWatcherStopped) + return nil, errors.E(op, errors.WatcherStopped) } if w == nil { continue |