Fix k8s loop stopped on exclude

RyaxTech · Apr 26, 2024 · 0f98467 · 0f98467
1 parent 81813b4
commit 0f98467
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/connectors/k8s.go b/connectors/k8s.go
@@ -24,6 +24,8 @@ type K8sConfig struct {
 var bebida_prefix = "ryax.tech/"
 
 func WatchQueues(channel chan interface{}, defaultPunchNbCore int, defaultPunchDuration int) {
+	defer panic("The kubernetes watcher stopped for unknown reason. Quit!")
+
 	k8sConfig := K8sConfig{namespace: "default", labelSelector: "", kubeconfigPath: os.Getenv("KUBECONFIG")}
 
 	config, err := clientcmd.BuildConfigFromFlags("", k8sConfig.kubeconfigPath)
@@ -50,7 +52,7 @@ func WatchQueues(channel chan interface{}, defaultPunchNbCore int, defaultPunchD
 			// Exclude pod if explicitly requested
 			if pod.Annotations[bebida_prefix+"bebida"] == "exclude" {
 				log.Infof("Found exclusion annotation %s, do exclude this pod", bebida_prefix+"bebida: exclude")
-				return
+				continue
 			}
 			pendingPod := events.NewPendingPod(defaultPunchNbCore, defaultPunchDuration)
 			pendingPod.PodId = pod.ObjectMeta.Name