From 1938a59c73ca7bab79a9ed2e61a56a3f3eb40d03 Mon Sep 17 00:00:00 2001
From: Eran Raichstein <eranra@il.ibm.com>
Date: Tue, 15 Aug 2023 11:58:01 +0300
Subject: [PATCH] Update queuejob_controller_ex.go
---
pkg/controller/queuejob/queuejob_controller_ex.go | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
diff --git a/pkg/controller/queuejob/queuejob_controller_ex.go b/pkg/controller/queuejob/queuejob_controller_ex.go
index d28120c2..a9699d30 100644
--- a/pkg/controller/queuejob/queuejob_controller_ex.go
+++ b/pkg/controller/queuejob/queuejob_controller_ex.go
@@ -245,8 +245,11 @@ func NewJobController(config *rest.Config, serverOption *options.ServerOption) *
cc.agentList = []string{}
for _, agentconfig := range strings.Split(serverOption.AgentConfigs, ",") {
agentData := strings.Split(agentconfig, ":")
- cc.agentMap["/root/kubernetes/"+agentData[0]] = queuejobdispatch.NewJobClusterAgent(agentconfig, cc.agentEventQueue)
- cc.agentList = append(cc.agentList, "/root/kubernetes/"+agentData[0])
+ jobClusterAgent := queuejobdispatch.NewJobClusterAgent(agentconfig, cc.agentEventQueue)
+ if jobClusterAgent != nil {
+ cc.agentMap["/root/kubernetes/"+agentData[0]] = jobClusterAgent
+ cc.agentList = append(cc.agentList, "/root/kubernetes/"+agentData[0])
+ }
}
if cc.isDispatcher && len(cc.agentMap) == 0 {