Browse Source

Merge pull request 'fix clusterResouces bugs' (#215) from tzwang/pcm-coordinator:master into master

Former-commit-id: 85a2da220a
pull/216/head
tzwang 1 year ago
parent
commit
83f8865dd2
3 changed files with 3 additions and 3 deletions
  1. +1
    -1
      api/etc/pcm.yaml
  2. +0
    -1
      api/internal/logic/ai/getcenteroverviewlogic.go
  3. +2
    -1
      api/internal/scheduler/database/aiStorage.go

+ 1
- 1
api/etc/pcm.yaml View File

@@ -50,7 +50,7 @@ ACRpcConf:
# Endpoints:
# - 127.0.0.1:8888
NonBlock: true
Timeout: 20000
Timeout: 50000

#rpc
CephRpcConf:


+ 0
- 1
api/internal/logic/ai/getcenteroverviewlogic.go View File

@@ -79,7 +79,6 @@ func (l *GetCenterOverviewLogic) GetCenterOverview() (resp *types.CenterOverview
case <-time.After(1 * time.Second):
return resp, nil
}

}

func (l *GetCenterOverviewLogic) updateClusterResource(mu *sync.RWMutex, ch chan<- struct{}, list []*types.AdapterInfo) {


+ 2
- 1
api/internal/scheduler/database/aiStorage.go View File

@@ -227,7 +227,8 @@ func (s *AiStorage) SaveClusterResources(clusterId string, clusterName string, c
}

func (s *AiStorage) UpdateClusterResources(clusterResource *models.TClusterResource) error {
tx := s.DbEngin.Model(clusterResource).Updates(clusterResource)
tx := s.DbEngin.Where("cluster_id = ?", clusterResource.ClusterId).Updates(clusterResource)

if tx.Error != nil {
return tx.Error
}


Loading…
Cancel
Save