fix: add priority field to submitopts (#7572)

Signed-off-by: Isitha Subasinghe <isitha@pipekit.io>
argoproj · Jan 17, 2022 · dbb1bcf · dbb1bcf
1 parent 81118d1
commit dbb1bcf
Show file tree

Hide file tree

Showing 12 changed files with 531 additions and 464 deletions.
diff --git a/api/jsonschema/schema.json b/api/jsonschema/schema.json
@@ -6562,6 +6562,10 @@
           "description": "Set the podPriorityClassName of the workflow",
           "type": "string"
         },
+        "priority": {
+          "description": "Priority is used if controller is configured to process limited number of workflows in parallel, higher priority workflows are processed first.",
+          "type": "integer"
+        },
         "serverDryRun": {
           "description": "ServerDryRun validates the workflow on the server-side without creating it",
           "type": "boolean"

diff --git a/api/openapi-spec/swagger.json b/api/openapi-spec/swagger.json
@@ -10825,6 +10825,10 @@
           "description": "Set the podPriorityClassName of the workflow",
           "type": "string"
         },
+        "priority": {
+          "description": "Priority is used if controller is configured to process limited number of workflows in parallel, higher priority workflows are processed first.",
+          "type": "integer"
+        },
         "serverDryRun": {
           "description": "ServerDryRun validates the workflow on the server-side without creating it",
           "type": "boolean"

diff --git a/pkg/apis/workflow/v1alpha1/common.go b/pkg/apis/workflow/v1alpha1/common.go
@@ -65,4 +65,7 @@ type SubmitOpts struct {
 	Annotations string `json:"annotations,omitempty" protobuf:"bytes,12,opt,name=annotations"`
 	// Set the podPriorityClassName of the workflow
 	PodPriorityClassName string `json:"podPriorityClassName,omitempty" protobuf:"bytes,13,opt,name=podPriorityClassName"`
+	// Priority is used if controller is configured to process limited number of workflows in parallel, higher priority workflows
+	// are processed first.
+	Priority *int32 `json:"priority,omitempty" protobuf:"bytes,14,opt,name=priority"`
 }
diff --git a/pkg/apis/workflow/v1alpha1/generated.pb.go b/pkg/apis/workflow/v1alpha1/generated.pb.go
diff --git a/pkg/apis/workflow/v1alpha1/generated.proto b/pkg/apis/workflow/v1alpha1/generated.proto
diff --git a/pkg/apis/workflow/v1alpha1/openapi_generated.go b/pkg/apis/workflow/v1alpha1/openapi_generated.go
diff --git a/pkg/apis/workflow/v1alpha1/zz_generated.deepcopy.go b/pkg/apis/workflow/v1alpha1/zz_generated.deepcopy.go
diff --git a/sdks/java/client/docs/IoArgoprojWorkflowV1alpha1SubmitOpts.md b/sdks/java/client/docs/IoArgoprojWorkflowV1alpha1SubmitOpts.md
@@ -18,6 +18,7 @@ Name | Type | Description | Notes
 **parameterFile** | **String** | ParameterFile holds a reference to a parameter file. This option is not supported in API |  [optional]
 **parameters** | **List&lt;String&gt;** | Parameters passes input parameters to workflow |  [optional]
 **podPriorityClassName** | **String** | Set the podPriorityClassName of the workflow |  [optional]
+**priority** | **Integer** | Priority is used if controller is configured to process limited number of workflows in parallel, higher priority workflows are processed first. |  [optional]
 **serverDryRun** | **Boolean** | ServerDryRun validates the workflow on the server-side without creating it |  [optional]
 **serviceAccount** | **String** | ServiceAccount runs all pods in the workflow using specified ServiceAccount. |  [optional]
 

diff --git a/sdks/python/client/argo_workflows/model/io_argoproj_workflow_v1alpha1_submit_opts.py b/sdks/python/client/argo_workflows/model/io_argoproj_workflow_v1alpha1_submit_opts.py
diff --git a/sdks/python/client/docs/IoArgoprojWorkflowV1alpha1SubmitOpts.md b/sdks/python/client/docs/IoArgoprojWorkflowV1alpha1SubmitOpts.md
diff --git a/sdks/python/client/docs/WorkflowServiceApi.md b/sdks/python/client/docs/WorkflowServiceApi.md
diff --git a/workflow/util/util.go b/workflow/util/util.go
@@ -243,6 +243,10 @@ func ApplySubmitOpts(wf *wfv1.Workflow, opts *wfv1.SubmitOpts) error {
 		wf.Spec.PodPriorityClassName = opts.PodPriorityClassName
 	}
 
+	if opts.Priority != nil {
+		wf.Spec.Priority = opts.Priority
+	}
+
 	wfLabels := wf.GetLabels()
 	if wfLabels == nil {
 		wfLabels = make(map[string]string)