Skip to content

Commit

Permalink
fix panic (#171)
Browse files Browse the repository at this point in the history
* fix panic
  • Loading branch information
gfr10598 authored Jul 3, 2019
1 parent 90a442c commit 2eca0ac
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion rex/rex.go
Original file line number Diff line number Diff line change
Expand Up @@ -377,7 +377,10 @@ func (rex *ReprocessingExecutor) finish(ctx context.Context, t *state.Task, term
status, err := job.Wait(ctx)
if err != nil {
if err != state.ErrTaskSuspended {
log.Println(status.Err(), src.FullyQualifiedName())
log.Println(err, src.FullyQualifiedName())
if status != nil {
log.Println(status.Err(), src.FullyQualifiedName())
}
t.SetError(ctx, err, "job.Wait")
}
return err
Expand Down

0 comments on commit 2eca0ac

Please sign in to comment.