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

Merge branch 'master' of https://github.com/paypal/gorealis

Browse source
This commit is contained in:
Kumar Krishna 2018-02-01 17:12:35 -08:00
commit 4133f2cb88
2 changed files with 10 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

14
realis.go
View file

@ -553,7 +553,8 @@ func (r *realisClient) GetJobUpdateSummaries(jobUpdateQuery *aurora.JobUpdateQue
return resp, nil return resp, nil
} }
func (r *realisClient) GetJobs(role string) (*aurora.Response, *aurora.GetJobsResult_, error) {
func (r *realisClient) GetJobs(role string) (*aurora.Response, *aurora.GetJobsResult_, error) {
var resp *aurora.Response var resp *aurora.Response
var result *aurora.GetJobsResult_ var result *aurora.GetJobsResult_
var clientErr error var clientErr error
@ -699,7 +700,7 @@ func (r *realisClient) ScheduleCronJob(auroraJob Job) (*aurora.Response, error)
}) })
if retryErr != nil { if retryErr != nil {
return nil, errors.Wrap(clientErr, retryErr.Error()+": Error sending Cron Job Schedule message to Aurora Scheduler") return nil, errors.Wrap(clientErr, retryErr.Error()+"Error sending Cron Job Schedule message to Aurora Scheduler")
} }
return resp, nil return resp, nil
} }
@ -722,12 +723,15 @@ func (r *realisClient) DescheduleCronJob(key *aurora.JobKey) (*aurora.Response,
}) })
if retryErr != nil { if retryErr != nil {
return nil, errors.Wrap(clientErr, retryErr.Error()+": Error sending Cron Job De-schedule message to Aurora Scheduler") return nil, errors.Wrap(clientErr, retryErr.Error()+"Error sending Cron Job De-schedule message to Aurora Scheduler")
} }
return resp, nil return resp, nil
} }
func (r *realisClient) StartCronJob(key *aurora.JobKey) (*aurora.Response, error) { func (r *realisClient) StartCronJob(key *aurora.JobKey) (*aurora.Response, error) {
var resp *aurora.Response var resp *aurora.Response
var clientErr error var clientErr error
@ -898,7 +902,7 @@ func (r *realisClient) ResumeJobUpdate(updateKey *aurora.JobUpdateKey, message s
return true, nil return true, nil
}) })
if retryErr != nil { if retryErr != nil {
return nil, errors.Wrap(clientErr, retryErr.Error()+": Error sending ResumeJobUpdate command to Aurora Scheduler") return nil, errors.Wrap(retryErr, "Error sending ResumeJobUpdate command to Aurora Scheduler")
} }
return resp, nil return resp, nil
@ -921,7 +925,7 @@ func (r *realisClient) PulseJobUpdate(updateKey *aurora.JobUpdateKey) (*aurora.R
return true, nil return true, nil
}) })
if retryErr != nil { if retryErr != nil {
return nil, errors.Wrap(clientErr, retryErr.Error()+": Error sending PulseJobUpdate command to Aurora Scheduler") return nil, errors.Wrap(retryErr, "Error sending PulseJobUpdate command to Aurora Scheduler")
} }
return resp, nil return resp, nil

3
updatejob.go
View file

@ -29,8 +29,7 @@ func NewDefaultUpdateJob(config *aurora.TaskConfig) *UpdateJob {
req := aurora.NewJobUpdateRequest() req := aurora.NewJobUpdateRequest()
req.TaskConfig = config req.TaskConfig = config
s := NewUpdateSettings() req.Settings = NewUpdateSettings()
req.Settings = s
job := NewJob().(*AuroraJob) job := NewJob().(*AuroraJob)
job.jobConfig.TaskConfig = config job.jobConfig.TaskConfig = config