Update flyteplugins/go/tasks/plugins/webapi/agent/plugin.go

Co-authored-by: Kevin Su <[email protected]> Signed-off-by: Future-Outlier <[email protected]>
flyteorg · Dec 17, 2023 · de33fc3 · de33fc3
1 parent b3f7c76
commit de33fc3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flyteplugins/go/tasks/plugins/webapi/agent/plugin.go b/flyteplugins/go/tasks/plugins/webapi/agent/plugin.go
@@ -336,7 +336,7 @@ func initializeAgentRegistry(cfg *Config, connectionCache map[*Agent]*grpc.Clien
 		agentRegistry[taskType][false] = cfg.Agents[agentID]
 	}
 
-	if cfg.DefaultAgent.Endpoint != "" {
+	if len(cfg.DefaultAgent.Endpoint) == 0 {
 		agentDeployments = append(agentDeployments, &cfg.DefaultAgent)
 	}
 	agentDeployments = append(agentDeployments, maps.Values(cfg.Agents)...)