Adding priority to the task (#140)
This commit is contained in:
parent
c318042e96
commit
8454a6ebf3
1 changed files with 6 additions and 0 deletions
6
job.go
6
job.go
|
@ -62,6 +62,7 @@ type Job interface {
|
||||||
PartitionPolicy(policy *aurora.PartitionPolicy) Job
|
PartitionPolicy(policy *aurora.PartitionPolicy) Job
|
||||||
Tier(tier string) Job
|
Tier(tier string) Job
|
||||||
SlaPolicy(policy *aurora.SlaPolicy) Job
|
SlaPolicy(policy *aurora.SlaPolicy) Job
|
||||||
|
Priority(priority int32) Job
|
||||||
}
|
}
|
||||||
|
|
||||||
type resourceType int
|
type resourceType int
|
||||||
|
@ -383,3 +384,8 @@ func (j *AuroraJob) SlaPolicy(policy *aurora.SlaPolicy) Job {
|
||||||
|
|
||||||
return j
|
return j
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (j *AuroraJob) Priority(priority int32) Job {
|
||||||
|
j.jobConfig.TaskConfig.Priority = priority
|
||||||
|
return j
|
||||||
|
}
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue