~gabe/mortar unlisted

1b8a75c1f490dce6295ee9902d3eb5cdd5849851 — Gabe Fierro 1 year, 6 months ago f52cc69 v1.1.0-alpha4
finish influxdb stage how we do in btrdb
1 files changed, 2 insertions(+), 1 deletions(-)

M stages/influxdb.go
M stages/influxdb.go => stages/influxdb.go +2 -1
@@ 68,7 68,7 @@ func NewInfluxDBTimeseriesQueryStage(cfg *InfluxDBTimeseriesStageConfig) (*Influ
							log.Println(err)
						}
					}
					stage.output <- req
					//stage.output <- req
				case <-stage.ctx.Done():
					// case that breaks the stage and releases resources
					fmt.Println("Ending Timeseries Queue")


@@ 231,6 231,7 @@ func (stage *InfluxDBTimeseriesQueryStage) processQuery(req *Request) error {

		}
	}
	req.fetch_responses <- nil

	return nil
}