diff --git a/manager/types/scheduler_cluster.go b/manager/types/scheduler_cluster.go index f21cd2d1c..12dfd3b4c 100644 --- a/manager/types/scheduler_cluster.go +++ b/manager/types/scheduler_cluster.go @@ -55,7 +55,7 @@ type GetSchedulerClustersQuery struct { type SchedulerClusterConfig struct { FilterParentLimit uint32 `yaml:"filterParentLimit" mapstructure:"filterParentLimit" json:"filter_parent_limit" binding:"omitempty,gte=1,lte=100"` - FilterParentRangeLimit uint32 `yaml:"filterParentRangeLimit" mapstructure:"filterParentRangeLimit" json:"filter_parent_range_limit" binding:"omitempty,gte=1,lte=1000"` + FilterParentRangeLimit uint32 `yaml:"filterParentRangeLimit" mapstructure:"filterParentRangeLimit" json:"filter_parent_range_limit" binding:"omitempty,gte=10,lte=1000"` } type SchedulerClusterClientConfig struct { diff --git a/scheduler/rpcserver/rpcserver.go b/scheduler/rpcserver/rpcserver.go index 267d4805b..d3c15d5c0 100644 --- a/scheduler/rpcserver/rpcserver.go +++ b/scheduler/rpcserver/rpcserver.go @@ -44,7 +44,7 @@ func New(service *service.Service, opts ...grpc.ServerOption) *grpc.Server { // RegisterPeerTask registers peer and triggers seed peer download task. func (s *Server) RegisterPeerTask(ctx context.Context, req *schedulerv1.PeerTaskRequest) (*schedulerv1.RegisterResult, error) { - // FIXME: Scheudler will not generate task id. + // FIXME Scheudler will not generate task id. if req.TaskId == "" { req.TaskId = idgen.TaskID(req.Url, req.UrlMeta) } diff --git a/scheduler/service/service.go b/scheduler/service/service.go index f41ec758e..31640c4eb 100644 --- a/scheduler/service/service.go +++ b/scheduler/service/service.go @@ -571,7 +571,8 @@ func (s *Service) registerTask(ctx context.Context, req *schedulerv1.PeerTaskReq return task, true, nil } - // Start trigger seed peer task. + // FIXME Need to add the condition that the seed peer grpc client is + // available and can be triggered back-to-source. if s.config.SeedPeer.Enable { if task.IsSeedPeerFailed() { return task, true, nil