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 6, 2023 · 8f28ffd · 8f28ffd
1 parent 7996769
commit 8f28ffd
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
@@ -391,7 +391,7 @@ func newAgentPlugin() webapi.PluginEntry {
 	connectionCache := make(map[*Agent]*grpc.ClientConn)
 	isSyncTask := make(map[string]bool)
 
-	setAgentMetadata(cfg, connectionCache, isSyncTask)
+	agentMetadata := setAgentMetadata(cfg, connectionCache, isSyncTask)
 	logger.Infof(context.Background(), "supported task types: %v", cfg.SupportedTaskTypes)
 	logger.Infof(context.Background(), "is sync task: %v", isSyncTask)