From e8cdb9d8b35cd8d851a302a01afbfe41fc5b7da4 Mon Sep 17 00:00:00 2001
From: Gaius <gaius.qi@gmail.com>
Date: Wed, 10 Jan 2024 12:37:22 +0800
Subject: [PATCH] feat: sync available scheduler addresses from manager (#208)

Signed-off-by: Gaius <gaius.qi@gmail.com>
---
 src/announcer/mod.rs  | 2 +-
 src/grpc/scheduler.rs | 3 ++-
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git a/src/announcer/mod.rs b/src/announcer/mod.rs
index 159fd18e..f0085e37 100644
--- a/src/announcer/mod.rs
+++ b/src/announcer/mod.rs
@@ -169,7 +169,7 @@ impl SchedulerAnnouncer {
                         }
                     };
 
-                    if let Err(err) = self.scheduler_client.init_announce_host(request).await {
+                    if let Err(err) = self.scheduler_client.announce_host(request).await {
                         error!("announce host to scheduler failed: {}", err);
                     };
                 }
diff --git a/src/grpc/scheduler.rs b/src/grpc/scheduler.rs
index 56ed921c..a0c8eb58 100644
--- a/src/grpc/scheduler.rs
+++ b/src/grpc/scheduler.rs
@@ -313,7 +313,8 @@ impl SchedulerClient {
             && data
                 .available_schedulers
                 .iter()
-                .all(|available_scheduler| available_schedulers.contains(available_scheduler))
+                .zip(available_schedulers.iter())
+                .all(|(a, b)| a == b)
         {
             info!(
                 "available schedulers is not changed: {:?}",