82b40a53f0
CreateJob, CreateService, and StartJobUpdate now include a rudimentary verification function to check if the call made it to the Aurora Scheduler when the client experiences a timeout.
21 lines
504 B
Go
21 lines
504 B
Go
package realis
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/paypal/gorealis/gen-go/apache/aurora"
|
|
)
|
|
|
|
func (r *realisClient) jobExists(key aurora.JobKey) (bool, error) {
|
|
resp, err := r.client.GetConfigSummary(context.TODO(), &key)
|
|
if err != nil {
|
|
return false, err
|
|
}
|
|
|
|
return resp == nil ||
|
|
resp.GetResult_() == nil ||
|
|
resp.GetResult_().GetConfigSummaryResult_() == nil ||
|
|
resp.GetResult_().GetConfigSummaryResult_().GetSummary() == nil ||
|
|
resp.GetResponseCode() != aurora.ResponseCode_OK,
|
|
nil
|
|
}
|