diff --git a/agent.go b/agent.go index 6540601ea0999..90bc24f8da714 100644 --- a/agent.go +++ b/agent.go @@ -88,6 +88,8 @@ func (a *Agent) LoadOutputs() ([]string, error) { return nil, fmt.Errorf("Undefined but requested output: %s", name) } + _, err = c.Query(client.Query{ + Command: fmt.Sprintf("CREATE DATABASE %s", config.Database), output := creator() err := a.Config.ApplyOutput(name, output)