fix strategy bugs

Former-commit-id: 1a10655de7ace36f0888008c23b50edb9d89af7c
This commit is contained in:
tzwang 2024-05-21 11:00:29 +08:00
parent d4db154bc7
commit de5d7ec1f1
3 changed files with 10 additions and 2 deletions

View File

@ -101,8 +101,8 @@ func (l *PageListTaskLogic) updateTaskStatus(tasklist []*types.TaskModel, ch cha
task := list[0]
for i := range list {
earliest, _ := time.Parse(constants.Layout_temp, task.UpdatedTime)
latest, _ := time.Parse(constants.Layout_temp, list[i].UpdatedTime)
earliest, _ := time.Parse(time.RFC3339, task.UpdatedTime)
latest, _ := time.Parse(time.RFC3339, list[i].UpdatedTime)
if latest.Before(earliest) {
task = list[i]
}

View File

@ -113,6 +113,9 @@ func (as *AiScheduler) PickOptimalStrategy() (strategy.Strategy, error) {
case strategy.REPLICATION:
var clusterIds []string
for _, resource := range resources {
if resource == nil {
continue
}
clusterIds = append(clusterIds, resource.ClusterId)
}
strategy := strategy.NewReplicationStrategy(clusterIds, 1)

View File

@ -31,6 +31,11 @@ func (ps *DynamicResourcesStrategy) Schedule() ([]*AssignedCluster, error) {
var assignedCluster AssignedCluster
var results []*AssignedCluster
for _, res := range ps.resources {
if res == nil {
continue
}
if opt.ResourceType == "cpu" {
if res.CpuCoreHours <= 0 {
cluster := &AssignedCluster{ClusterId: res.ClusterId, Replicas: ps.replicas}