diff --git a/db/influxdb.go b/db/influxdb.go index 803d369..e73b14a 100644 --- a/db/influxdb.go +++ b/db/influxdb.go @@ -117,12 +117,12 @@ func (ad *InfluxDBAdapter) Save(channels []core.Channel) error { saveContext, cancel := context.WithTimeout(context.Background(), INFLUXDB_MAX_SAVE_DUR) defer cancel() - fmt.Printf("[InfluxDB] logged %d channels OK\n", len(channels)) - err = ad.client.Write(saveContext, []byte(sb.String())) if err != nil { return err } + fmt.Printf("[InfluxDB] logged %d channels OK\n", len(channels)) + return nil }