taskrunner: return error on waitCh

This commit is contained in:
Nick Ethier
2018-10-10 22:11:45 -04:00
committed by Michael Schurter
parent 44cc52a0d4
commit 993e045ff9

View File

@@ -33,8 +33,9 @@ func (tr *TaskRunner) Restart(ctx context.Context, event *structs.TaskEvent, fai
// Drain the wait channel or wait for the request context to be canceled
waitCh, err := handle.WaitCh(ctx)
if err != nil {
tr.logger.Error("failed to kill task. Resources may have been leaked", "error", err)
return err
}
<-waitCh
return nil
}