From 4de5f30ca26fa9ecc86a87cd3d1410bb4e11512a Mon Sep 17 00:00:00 2001 From: Shivram Srivastava Date: Mon, 10 Oct 2022 12:34:54 +0530 Subject: [PATCH] Adding priority to the task --- job.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/job.go b/job.go index 1d85f33..8470546 100644 --- a/job.go +++ b/job.go @@ -62,6 +62,7 @@ type Job interface { PartitionPolicy(policy *aurora.PartitionPolicy) Job Tier(tier string) Job SlaPolicy(policy *aurora.SlaPolicy) Job + Priority(priority int32) Job } type resourceType int @@ -383,3 +384,8 @@ func (j *AuroraJob) SlaPolicy(policy *aurora.SlaPolicy) Job { return j } + +func (j *AuroraJob) Priority(priority int32) Job { + j.jobConfig.TaskConfig.Priority = priority + return j +}