fix(query/control): handle flux errors from the table iterator in the controller (#14715)

2019-08-20 12:20:40 -05:00 · 2019-08-20 12:20:40 -05:00 · b35552721c
parent 99cebbbdc1
commit b35552721c
1 changed files with 1 additions and 0 deletions
--- a/query/control/controller.go
+++ b/query/control/controller.go
@ -809,6 +809,7 @@ type errorCollectingTableIterator struct {
 func (ti *errorCollectingTableIterator) Do(f func(t flux.Table) error) error {
 	err := ti.TableIterator.Do(f)
 	if err != nil {
+		err = handleFluxError(err)
 		ti.q.addRuntimeError(err)
 	}
 	return err