From 8ffc0106d7e29eb59b9f1a7469c2f9a860abcb1a Mon Sep 17 00:00:00 2001 From: tzwang Date: Thu, 6 Jun 2024 17:10:06 +0800 Subject: [PATCH] fix clusterResouces bugs Former-commit-id: c977dc87486fd72df375a92d71c185fac668cb2c --- api/etc/pcm.yaml | 2 +- api/internal/logic/ai/getcenteroverviewlogic.go | 1 - api/internal/scheduler/database/aiStorage.go | 3 ++- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/api/etc/pcm.yaml b/api/etc/pcm.yaml index ee51794e..4160b508 100644 --- a/api/etc/pcm.yaml +++ b/api/etc/pcm.yaml @@ -50,7 +50,7 @@ ACRpcConf: # Endpoints: # - 127.0.0.1:8888 NonBlock: true - Timeout: 20000 + Timeout: 50000 #rpc CephRpcConf: diff --git a/api/internal/logic/ai/getcenteroverviewlogic.go b/api/internal/logic/ai/getcenteroverviewlogic.go index bcec6855..f7b72607 100644 --- a/api/internal/logic/ai/getcenteroverviewlogic.go +++ b/api/internal/logic/ai/getcenteroverviewlogic.go @@ -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) { diff --git a/api/internal/scheduler/database/aiStorage.go b/api/internal/scheduler/database/aiStorage.go index 4fcda695..43492a55 100644 --- a/api/internal/scheduler/database/aiStorage.go +++ b/api/internal/scheduler/database/aiStorage.go @@ -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 }