From 52ecd489556e45c6fa4ef843ce46f34c6d19ba30 Mon Sep 17 00:00:00 2001 From: ChristianZaccaria Date: Fri, 22 Sep 2023 17:38:02 +0100 Subject: [PATCH] Update label to identify number of pods --- pkg/controller/queuejob/queuejob_controller_ex.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/controller/queuejob/queuejob_controller_ex.go b/pkg/controller/queuejob/queuejob_controller_ex.go index 8d356403..0ebae097 100644 --- a/pkg/controller/queuejob/queuejob_controller_ex.go +++ b/pkg/controller/queuejob/queuejob_controller_ex.go @@ -144,7 +144,7 @@ func GetQueueJobKey(obj interface{}) (string, error) { // UpdateQueueJobStatus was part of pod informer, this is now a method of queuejob_controller file. // This change is done in an effort to simplify the controller and enable to move to controller runtime. func (qjm *XController) UpdateQueueJobStatus(queuejob *arbv1.AppWrapper) error { - labelSelector := fmt.Sprintf("%s=%s", "appwrapper.mcad.ibm.com", queuejob.Name) + labelSelector := fmt.Sprintf("%s=%s", "ray.io/cluster", queuejob.Name) pods, errt := qjm.clients.CoreV1().Pods("").List(context.TODO(), metav1.ListOptions{LabelSelector: labelSelector}) if errt != nil { return errt