Exposed workflow priority as a variable (#1476)

argoproj · Jul 22, 2019 · 082e5c4 · 082e5c4
1 parent 38c4def
commit 082e5c4
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 2 deletions.
diff --git a/docs/variables.md b/docs/variables.md
@@ -51,7 +51,7 @@ The following variables are made available to reference various metadata of a wo
 | `workflow.labels.<NAME>` | Workflow labels |
 | `workflow.creationTimestamp` | Workflow creation timestamp formatted in RFC 3339 (e.g. `2018-08-23T05:42:49Z`) |
 | `workflow.creationTimestamp.<STRFTIMECHAR>` | Creation timestamp formatted with a [strftime](http:https://strftime.org) format character |
-
+| `workflow.priority` | Workflow priority |
 
 ## Exit Handler:
 | Variable | Description|

diff --git a/workflow/common/common.go b/workflow/common/common.go
@@ -109,8 +109,10 @@ const (
  GlobalVarWorkflowUID = "workflow.uid"
  // GlobalVarWorkflowStatus is a global workflow variable referencing the workflow's status.phase field
  GlobalVarWorkflowStatus = "workflow.status"
- // GlobalVarWorkflowCreationTimestamp is the workflow variable referencing the workflows metadata.creationTimestamp field
+ // GlobalVarWorkflowCreationTimestamp is the workflow variable referencing the workflow's metadata.creationTimestamp field
  GlobalVarWorkflowCreationTimestamp = "workflow.creationTimestamp"
+ // GlobalVarWorkflowPriority is the workflow variable referencing the workflow's priority field
+ GlobalVarWorkflowPriority = "workflow.priority"
  // LocalVarPodName is a step level variable that references the name of the pod
  LocalVarPodName = "pod.name"
 

diff --git a/workflow/controller/operator.go b/workflow/controller/operator.go
@@ -265,6 +265,9 @@ func (woc *wfOperationCtx) setGlobalParameters() {
  woc.globalParams[common.GlobalVarWorkflowNamespace] = woc.wf.ObjectMeta.Namespace
  woc.globalParams[common.GlobalVarWorkflowUID] = string(woc.wf.ObjectMeta.UID)
  woc.globalParams[common.GlobalVarWorkflowCreationTimestamp] = woc.wf.ObjectMeta.CreationTimestamp.String()
+ if woc.wf.Spec.Priority != nil {
+ woc.globalParams[common.GlobalVarWorkflowPriority] = strconv.Itoa(int(*woc.wf.Spec.Priority))
+ }
  for char := range strftime.FormatChars {
  cTimeVar := fmt.Sprintf("%s.%s", common.GlobalVarWorkflowCreationTimestamp, string(char))
  woc.globalParams[cTimeVar] = strftime.Format("%"+string(char), woc.wf.ObjectMeta.CreationTimestamp.Time)