|
|
@@ -40,7 +40,7 @@ func AddCronGroup(svc *svc.ServiceContext) { |
|
|
status.UpdateAutoStoppedInstance(svc) |
|
|
status.UpdateAutoStoppedInstance(svc) |
|
|
}) |
|
|
}) |
|
|
|
|
|
|
|
|
svc.Cron.AddFunc("0 5/5 * * * *", func() { |
|
|
|
|
|
|
|
|
svc.Cron.AddFunc("1 * * * * *", func() { |
|
|
queryResource := schedule.NewQueryResourcesLogic(svc.HttpClient.R().Context(), svc) |
|
|
queryResource := schedule.NewQueryResourcesLogic(svc.HttpClient.R().Context(), svc) |
|
|
trainResrc, err := queryResource.QueryResourcesByClusterId(nil, "Train") |
|
|
trainResrc, err := queryResource.QueryResourcesByClusterId(nil, "Train") |
|
|
if err != nil { |
|
|
if err != nil { |
|
|
|