ridv/gorealis-v2
1
0
Fork 0
Code Issues Pull requests Projects Releases 13 Packages Wiki Activity Actions

add priority in deep copy and jobUpdate

Browse source
This commit is contained in:
lenhattan86 2021-09-16 15:57:23 -07:00
parent a42d848d58
commit 7bb0ae01b2
3 changed files with 8 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

5
jobUpdate.go
View file

@ -221,6 +221,11 @@ func (j *JobUpdate) IsService(isService bool) *JobUpdate {
return j return j
} }
func (j *JobUpdate) Priority(priority int32) *JobUpdate {
j.task.Priority(priority)
return j
}
func (j *JobUpdate) TaskConfig() *aurora.TaskConfig { func (j *JobUpdate) TaskConfig() *aurora.TaskConfig {
return j.task.TaskConfig() return j.task.TaskConfig()
} }

3
task.go
View file

@ -78,7 +78,8 @@ func TaskFromThrift(config *aurora.TaskConfig) *AuroraTask {
Role(config.Job.Role). Role(config.Job.Role).
Name(config.Job.Name). Name(config.Job.Name).
MaxFailure(config.MaxTaskFailures). MaxFailure(config.MaxTaskFailures).
IsService(config.IsService) IsService(config.IsService).
Priority(config.Priority)
if config.Tier != nil { if config.Tier != nil {
newTask.Tier(*config.Tier) newTask.Tier(*config.Tier)

1
task_test.go
View file

@ -34,6 +34,7 @@ func TestAuroraTask_Clone(t *testing.T) {
RAM(643). RAM(643).
Disk(1000). Disk(1000).
IsService(true). IsService(true).
Priority(1).
AddPorts(10). AddPorts(10).
Tier("preferred"). Tier("preferred").
MaxFailure(23). MaxFailure(23).