diff --git a/CHANGELOG.md b/CHANGELOG.md index c16d735..9cfbaef 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -1,4 +1,8 @@ -1.24.1 (unreleased) +1.25.1 (unreleased) + +1.25.0 + +* Add priority api 1.24.0 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 +}