diff options
author | Wolfy-J <[email protected]> | 2020-10-28 14:42:16 +0300 |
---|---|---|
committer | Wolfy-J <[email protected]> | 2020-10-28 14:42:16 +0300 |
commit | 810bc58c7b64029d21504d3f7286ccaeb16b0207 (patch) | |
tree | c26be1bc76cc7c9fb9262cfd54855c50c416ec4c /worker.go | |
parent | a8e31d57147252b0ef28237bf3094d7f5af01f5e (diff) | |
parent | 47a570c220a36ae7b770ea594a41637fa31fc8e8 (diff) |
Merge branch 'release_2.0' into feature/logging
Diffstat (limited to 'worker.go')
-rwxr-xr-x | worker.go | 4 |
1 files changed, 2 insertions, 2 deletions
@@ -74,7 +74,7 @@ type WorkerBase interface { // Kill kills underlying process, make sure to call Wait() func to gather // error log from the stderr. Does not waits for process completion! - Kill(ctx context.Context) error + Kill() error // Relay returns attached to worker goridge relay Relay() goridge.Relay @@ -280,7 +280,7 @@ func (w *WorkerProcess) Stop(ctx context.Context) error { // Kill kills underlying process, make sure to call Wait() func to gather // error log from the stderr. Does not waits for process completion! -func (w *WorkerProcess) Kill(ctx context.Context) error { +func (w *WorkerProcess) Kill() error { w.state.Set(StateKilling) w.mu.Lock() defer w.mu.Unlock() |