fix: check error before defer in prometheus k8s (#10091)

2021-11-24 12:19:25 -07:00 · 2021-11-24 12:19:25 -07:00 · 121ae1faaa
parent 84562877cc
commit 121ae1faaa
1 changed files with 1 additions and 1 deletions
--- a/plugins/inputs/prometheus/kubernetes.go
+++ b/plugins/inputs/prometheus/kubernetes.go
@ -110,10 +110,10 @@ func (p *Prometheus) watchPod(ctx context.Context, client *kubernetes.Clientset)
 		LabelSelector: p.KubernetesLabelSelector,
 		FieldSelector: p.KubernetesFieldSelector,
 	})
-	defer watcher.Stop()
 	if err != nil {
 		return err
 	}
+	defer watcher.Stop()

 	for {
 		select {