From c8852339c9f7358998ae2723312cbc3e1b24213a Mon Sep 17 00:00:00 2001 From: Cameron Sparr Date: Thu, 22 Oct 2015 11:14:10 -0600 Subject: [PATCH] Do not fail Connect() in influxdb output when db creation fails Fixes #304 --- outputs/influxdb/influxdb.go | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/outputs/influxdb/influxdb.go b/outputs/influxdb/influxdb.go index 94b8662a6..79abc53c1 100644 --- a/outputs/influxdb/influxdb.go +++ b/outputs/influxdb/influxdb.go @@ -78,24 +78,20 @@ func (i *InfluxDB) Connect() error { conns = append(conns, c) } - // This will get set to nil if a successful connection is made - err := errors.New("Could not create database on any server") - for _, conn := range conns { _, e := conn.Query(client.Query{ Command: fmt.Sprintf("CREATE DATABASE %s", i.Database), }) if e != nil && !strings.Contains(e.Error(), "database already exists") { - log.Println("ERROR: " + e.Error()) + log.Println("Database creation failed: " + e.Error()) } else { - err = nil break } } i.conns = conns - return err + return nil } func (i *InfluxDB) Close() error {