24 lines
677 B
Go
24 lines
677 B
Go
|
package realis
|
||
|
|
|
||
|
|
import (
|
||
|
|
"context"
|
||
|
|
|
||
|
|
"github.com/aurora-scheduler/gorealis/v2/gen-go/apache/aurora"
|
||
|
|
)
|
||
|
|
|
||
|
|
func (r *Client) 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.GetResult_().GetConfigSummaryResult_().GetSummary().GetGroups() != nil &&
|
||
|
|
len(resp.GetResult_().GetConfigSummaryResult_().GetSummary().GetGroups()) > 0 &&
|
||
|
|
resp.GetResponseCode() == aurora.ResponseCode_OK,
|
||
|
|
nil
|
||
|
|
}
|