|
|
@@ -42,16 +42,12 @@ func UpdateDeployTaskStatus(svc *svc.ServiceContext) { |
|
|
ins = list[i] |
|
|
ins = list[i] |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
updateDeployTaskStatus(svc, ins) |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
func updateDeployTaskStatus(svc *svc.ServiceContext, ins *models.AiDeployInstanceTask) { |
|
|
|
|
|
list, err := svc.Scheduler.AiStorages.GetInstanceListByDeployTaskId(ins.Id) |
|
|
|
|
|
|
|
|
inslist, err := svc.Scheduler.AiStorages.GetInstanceListByDeployTaskId(ins.Id) |
|
|
if err != nil { |
|
|
if err != nil { |
|
|
return |
|
|
return |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
for _, instance := range list { |
|
|
|
|
|
|
|
|
for _, instance := range inslist { |
|
|
go UpdateDeployInstanceStatus(svc, instance, false) |
|
|
go UpdateDeployInstanceStatus(svc, instance, false) |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
|