diff options
| author | Valery Piashchynski <[email protected]> | 2021-01-13 15:30:54 +0300 |
|---|---|---|
| committer | GitHub <[email protected]> | 2021-01-13 15:30:54 +0300 |
| commit | 2a1c6092056c9dc1d725e393da97b72eb65071c4 (patch) | |
| tree | 362f0eacdf2373bf208441577c1e69b8337bd71e /pkg/worker_watcher/worker_watcher.go | |
| parent | f0f2b1aaf8e4df2ab65c6c47d9183f072ac86841 (diff) | |
| parent | 2eed81d8fdbf8ee5134bb3b3f4c11c63cf6d757c (diff) | |
Merge pull request #473 from spiral/feature/env_variables
feat(env): Add RR system environment variables
Diffstat (limited to 'pkg/worker_watcher/worker_watcher.go')
| -rwxr-xr-x | pkg/worker_watcher/worker_watcher.go | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/pkg/worker_watcher/worker_watcher.go b/pkg/worker_watcher/worker_watcher.go index 348f0459..127dc801 100755 --- a/pkg/worker_watcher/worker_watcher.go +++ b/pkg/worker_watcher/worker_watcher.go @@ -236,7 +236,7 @@ func (ww *workerWatcher) RemoveWorker(wb worker.BaseProcess) error { pid := wb.Pid() if ww.stack.FindAndRemoveByPid(pid) { - wb.State().Set(internal.StateInvalid) + wb.State().Set(internal.StateRemove) err := wb.Kill() if err != nil { return errors.E(op, err) @@ -244,7 +244,6 @@ func (ww *workerWatcher) RemoveWorker(wb worker.BaseProcess) error { return nil } - wb.State().Set(internal.StateRemove) return nil } |