Initialize aggregation processors (influxdata#7853)

danielnelson · Jul 17, 2020 · 0bcc515 · 0bcc515
1 parent 3441fb1
commit 0bcc515
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/agent/agent.go b/agent/agent.go
@@ -224,6 +224,13 @@ func (a *Agent) initPlugins() error {
 				aggregator.Config.Name, err)
 		}
 	}
+	for _, processor := range a.Config.AggProcessors {
+		err := processor.Init()
+		if err != nil {
+			return fmt.Errorf("could not initialize processor %s: %v",
+				processor.Config.Name, err)
+		}
+	}
 	for _, output := range a.Config.Outputs {
 		err := output.Init()
 		if err != nil {