fix(sysflow): fix double call to StartWorkers() function when policy …

…are reloaded (#1) Ref: EXP-2010 Signed-off-by: Mauro Sardara <[email protected]>
sysflow-telemetry · Feb 12, 2024 · f05648a · f05648a
1 parent 564d3f0
commit f05648a
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/core/policyengine/policyengine.go b/core/policyengine/policyengine.go
@@ -94,6 +94,9 @@ func (s *PolicyEngine) Init(conf map[string]interface{}) (err error) {
 			logger.Error.Printf("Unable to compile local policies from directory %s, %v", s.config.PoliciesPath, err)
 			return
 		}
+
+		// start workers
+		s.pi.StartWorkers()
 	} else {
 		s.policyMonitor, err = monitor.NewPolicyMonitor(s.config, s.createPolicyInterpreter, s.out)
 		if err != nil {
@@ -197,9 +200,6 @@ func (s *PolicyEngine) createPolicyInterpreter() (*engine.PolicyInterpreter[*com
 		return nil, err
 	}
 
-	// start workers
-	pi.StartWorkers()
-
 	return pi, nil
 }