summaryrefslogtreecommitdiff
path: root/worker.go
diff options
context:
space:
mode:
authorWolfy-J <[email protected]>2020-10-28 14:42:16 +0300
committerWolfy-J <[email protected]>2020-10-28 14:42:16 +0300
commit810bc58c7b64029d21504d3f7286ccaeb16b0207 (patch)
treec26be1bc76cc7c9fb9262cfd54855c50c416ec4c /worker.go
parenta8e31d57147252b0ef28237bf3094d7f5af01f5e (diff)
parent47a570c220a36ae7b770ea594a41637fa31fc8e8 (diff)
Merge branch 'release_2.0' into feature/logging
Diffstat (limited to 'worker.go')
-rwxr-xr-xworker.go4
1 files changed, 2 insertions, 2 deletions
diff --git a/worker.go b/worker.go
index 2dda51cc..ef532f51 100755
--- a/worker.go
+++ b/worker.go
@@ -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()