feat: Send more workflow info to plugins. Fixes #8573

cmd/argoexec/commands/agent.go

@@ -103,6 +103,10 @@ func initAgentExecutor() *executor.AgentExecutor {
 	if !ok {
 		log.Fatalf("Unable to determine workflow name from environment variable %s", common.EnvVarWorkflowName)
 	}
+	workflowUid, ok := os.LookupEnv(common.EnvVarWorkflowUID)
+	if !ok {
+		log.Warn("Unable to determine workflow Uid from environment variable %s", common.EnvVarWorkflowUID)
+	}
 
 	addresses := getPluginAddresses()
 	names := getPluginNames()
@@ -120,5 +124,5 @@ func initAgentExecutor() *executor.AgentExecutor {
 		plugins = append(plugins, rpc.New(address, string(data)))
 	}
 
-	return executor.NewAgentExecutor(clientSet, restClient, config, namespace, workflowName, plugins)
+	return executor.NewAgentExecutor(clientSet, restClient, config, namespace, workflowName, workflowUid, plugins)
 }

pkg/plugins/executor/objectmeta.go

@@ -1,5 +1,7 @@
 package executor
 
 type ObjectMeta struct {
-	Name string `json:"name"`
+	Name      string `json:"name"`
+	Namespace string `json:"namespace"`
+	Uid       string `json:"uid"`
 }

workflow/common/common.go

@@ -119,6 +119,8 @@ const (
 	EnvVarInstanceID = "ARGO_INSTANCE_ID"
 	// EnvVarWorkflowName is the name of the workflow for which the an agent is responsible for
 	EnvVarWorkflowName = "ARGO_WORKFLOW_NAME"
+	// EnvVarWorkflowUID is the workflow UUID
+	EnvVarWorkflowUID = "ARGO_WORKFLOW_UID"
 	// EnvVarNodeID is the node ID of the node.
 	EnvVarNodeID = "ARGO_NODE_ID"
 	// EnvVarPluginAddresses is a list of plugin addresses