feat: use scheduler's cluster id in host resource (#2844)

Signed-off-by: Gaius <[email protected]>
dragonflyoss · Oct 31, 2023 · 6caf724 · 6caf724
1 parent 4a161e4
commit 6caf724
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/scheduler/service/service_v1.go b/scheduler/service/service_v1.go
@@ -546,7 +546,7 @@ func (v *V1) AnnounceHost(ctx context.Context, req *schedulerv1.AnnounceHostRequ
 		}
 
 		if req.GetSchedulerClusterId() != 0 {
-			options = append(options, resource.WithSchedulerClusterID(req.GetSchedulerClusterId()))
+			options = append(options, resource.WithSchedulerClusterID(uint64(v.config.Manager.SchedulerClusterID)))
 		}
 
 		if req.GetObjectStoragePort() != 0 {

diff --git a/scheduler/service/service_v2.go b/scheduler/service/service_v2.go
@@ -539,7 +539,7 @@ func (v *V2) AnnounceHost(ctx context.Context, req *schedulerv2.AnnounceHostRequ
 		}
 
 		if req.Host.GetSchedulerClusterId() != 0 {
-			options = append(options, resource.WithSchedulerClusterID(req.Host.GetSchedulerClusterId()))
+			options = append(options, resource.WithSchedulerClusterID(uint64(v.config.Manager.SchedulerClusterID)))
 		}
 
 		if req.Host.GetObjectStoragePort() != 0 {