|
|
|
@@ -79,7 +79,11 @@ func (s *Executor) runOps(ops []Op, ctx *ExecContext, cancel context.CancelFunc) |
|
|
|
err = context.Canceled |
|
|
|
} |
|
|
|
} else { |
|
|
|
err = multierror.Append(err, fmt.Errorf("%T: %w", op, e)) |
|
|
|
if err == context.Canceled { |
|
|
|
err = e |
|
|
|
} else { |
|
|
|
err = multierror.Append(err, fmt.Errorf("%T: %w", op, e)) |
|
|
|
} |
|
|
|
} |
|
|
|
lock.Unlock() |
|
|
|
|
|
|
|
|