Explorar o código

fix(influxdb): return internal influxdb errors

ref #6523
bergquist %!s(int64=9) %!d(string=hai) anos
pai
achega
e04d27c0b0
Modificáronse 1 ficheiros con 4 adicións e 0 borrados
  1. 4 0
      pkg/tsdb/influxdb/influxdb.go

+ 4 - 0
pkg/tsdb/influxdb/influxdb.go

@@ -82,6 +82,10 @@ func (e *InfluxDBExecutor) Execute(ctx context.Context, queries tsdb.QuerySlice,
 		return result.WithError(err)
 	}
 
+	if response.Err != nil {
+		return result.WithError(response.Err)
+	}
+
 	result.QueryResults = make(map[string]*tsdb.QueryResult)
 	result.QueryResults["A"] = e.ResponseParser.Parse(&response, query)