diff --git a/api/internal/pkg/scheduler/scheduler.go b/api/internal/pkg/scheduler/scheduler.go index 35613c78..235194ad 100644 --- a/api/internal/pkg/scheduler/scheduler.go +++ b/api/internal/pkg/scheduler/scheduler.go @@ -54,6 +54,17 @@ func (s *scheduler) AssignAndSchedule() error { return nil } + // 标签匹配后,未找到ParticipantIds + if len(s.participantIds) == 0 { + return errors.New("未找到匹配的ParticipantIds") + } + + // ParticipantIds 返回唯一值 + if len(s.participantIds) == 1 { + s.task.ParticipantId = s.participantIds[0] + return nil + } + //生成算法所需参数 task, providerList := s.genTaskAndProviders()