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 +}