goimports style fix.

This commit is contained in:
Renan DelValle 2019-01-12 14:06:32 -08:00
parent 1ec4e6b39b
commit 65a5d650c0
No known key found for this signature in database
GPG key ID: C240AD6D6F443EC9
2 changed files with 7 additions and 7 deletions

View file

@ -38,13 +38,13 @@ func (m *Monitor) JobUpdate(updateKey aurora.JobUpdateKey, interval int, timeout
status, err := m.JobUpdateStatus(updateKey, status, err := m.JobUpdateStatus(updateKey,
map[aurora.JobUpdateStatus]bool{ map[aurora.JobUpdateStatus]bool{
aurora.JobUpdateStatus_ROLLED_FORWARD: true, aurora.JobUpdateStatus_ROLLED_FORWARD: true,
aurora.JobUpdateStatus_ROLLED_BACK: true, aurora.JobUpdateStatus_ROLLED_BACK: true,
aurora.JobUpdateStatus_ABORTED: true, aurora.JobUpdateStatus_ABORTED: true,
aurora.JobUpdateStatus_ERROR: true, aurora.JobUpdateStatus_ERROR: true,
aurora.JobUpdateStatus_FAILED: true, aurora.JobUpdateStatus_FAILED: true,
}, },
time.Duration(interval) * time.Second, time.Duration(interval)*time.Second,
time.Duration(timeout) * time.Second) time.Duration(timeout)*time.Second)
if err != nil { if err != nil {
return false, err return false, err

View file

@ -789,7 +789,7 @@ func (r *realisClient) AbortJobUpdate(updateKey aurora.JobUpdateKey, message str
// Make this call synchronous by blocking until it job has successfully transitioned to aborted // Make this call synchronous by blocking until it job has successfully transitioned to aborted
m := Monitor{Client: r} m := Monitor{Client: r}
_, err := m.JobUpdateStatus(updateKey, map[aurora.JobUpdateStatus]bool{aurora.JobUpdateStatus_ABORTED:true},time.Second * 5, time.Minute) _, err := m.JobUpdateStatus(updateKey, map[aurora.JobUpdateStatus]bool{aurora.JobUpdateStatus_ABORTED: true}, time.Second*5, time.Minute)
if err != nil { if err != nil {
return resp, err return resp, err