diff options
Diffstat (limited to 'pkg/worker/worker.go')
-rwxr-xr-x | pkg/worker/worker.go | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/pkg/worker/worker.go b/pkg/worker/worker.go index aef7f2b0..4d4ca09b 100755 --- a/pkg/worker/worker.go +++ b/pkg/worker/worker.go @@ -224,6 +224,8 @@ func (w *Process) Wait() error { w.state.Set(internal.StateStopped) } + w.stderr.Reset() + return nil } @@ -307,6 +309,7 @@ func (w *Process) watch() { w.mu.Lock() // write new message w.stderr.Write((*buf)[:n]) + w.stderr.Reset() w.mu.Unlock() w.put(buf) } |