aa
This commit is contained in:
@@ -1171,10 +1171,6 @@ func ReloadJobSpan(ctx *jxcontext.Context, jobIDs []int, span int) (err error) {
|
||||
var (
|
||||
db = dao.GetDB()
|
||||
)
|
||||
jobs, err := dao.GetJobsNoPage(db, nil, nil, []int{model.JobStatusDoing}, nil, utils.ZeroTimeValue, utils.ZeroTimeValue, span, false)
|
||||
if len(jobs) != len(jobIDs) {
|
||||
return fmt.Errorf("传入的任务IDs有误!")
|
||||
}
|
||||
for k, v := range jobIDs {
|
||||
job := &model.Job{}
|
||||
job.ID = v
|
||||
|
||||
Reference in New Issue
Block a user