fix bug

server/worker.go

@@ -3,6 +3,7 @@ package server
 import (
 	"context"
 	"errors"
+	"fmt"
 	odysseus "github.com/odysseus/odysseus-protocol/gen/proto/go/base/v1"
 	omanager "github.com/odysseus/odysseus-protocol/gen/proto/go/nodemanager/v1"
 	"github.com/odysseus/scheduler/config"
@@ -37,7 +38,7 @@ func PopWorker(rdb *redis.Client) (Worker, error) {
 				break
 			}
 			log.WithField("elem", elem).Debug("lPop worker")
-			managerList, err := rdb.SMembers(context.Background(), config.WORKER_STATUS_PREFIX+elem).Result()
+			managerList, err := rdb.SMembers(context.Background(), workerStatusKey(elem)).Result()
 			if err != nil {
 				log.WithError(err).Error("get worker status failed")
 				continue
@@ -56,6 +57,9 @@ func PopWorker(rdb *redis.Client) (Worker, error) {
 	}
 	return Worker{}, ErrNoWorker
 }
+func workerStatusKey(wid string) string {
+	return fmt.Sprintf("%s_%s", config.WORKER_STATUS_PREFIX, wid)
+}
 
 func newManagerClient(endpoint string) (omanager.NodeManagerServiceClient, error) {
 	client, err := grpc.Dial(endpoint,