fix: add priority field to submitopts (argoproj#7572)

Signed-off-by: Isitha Subasinghe <[email protected]>
CashWilliams · 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)