Przeglądaj źródła

add to agent query as well

Alexander Belanger 4 lat temu
rodzic
commit
4afb240e84
1 zmienionych plików z 7 dodań i 1 usunięć
  1. 7 1
      internal/kubernetes/agent.go

+ 7 - 1
internal/kubernetes/agent.go

@@ -744,12 +744,18 @@ func (a *Agent) StreamJobs(namespace string, selectors string, rw *websocket.Web
 					return
 				}
 
+				labelSelector := "meta.helm.sh/release-name"
+
+				if selectors != "" {
+					labelSelector = selectors
+				}
+
 				jobs, err := a.Clientset.BatchV1().Jobs(namespace).List(
 					ctx,
 					metav1.ListOptions{
 						Limit:         100,
 						Continue:      continueVal,
-						LabelSelector: "meta.helm.sh/release-name",
+						LabelSelector: labelSelector,
 					},
 				)