fix: initialize targets async

Signed-off-by: Christian Kotzbauer <[email protected]>
ckotzbauer · Aug 20, 2022 · addc0ad · addc0ad
1 parent 36817ad
commit addc0ad
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/internal/processor/processor.go b/internal/processor/processor.go
@@ -39,12 +39,6 @@ func New(k8s *kubernetes.KubeClient, sy *syft.Syft) *Processor {
 }
 
 func (p *Processor) ListenForPods() {
-	if !HasJobImage() {
-		for _, t := range p.Targets {
-			t.Initialize()
-		}
-	}
-
 	var informer cache.SharedIndexInformer
 	informer, err := p.K8s.StartPodInformer(internal.OperatorConfig.PodLabelSelector, cache.ResourceEventHandlerFuncs{
 		UpdateFunc: func(old, new interface{}) {
@@ -306,6 +300,12 @@ func (p *Processor) runInformerAsync(informer cache.SharedIndexInformer) {
 	}()
 
 	go func() {
+		if !HasJobImage() {
+			for _, t := range p.Targets {
+				t.Initialize()
+			}
+		}
+
 		logrus.Info("Start pod-informer")
 		informer.Run(stop)
 		logrus.Info("Pod-informer has stopped")