mirror of https://github.com/milvus-io/milvus.git
parent
b429953c0b
commit
d482246191
|
@ -15,11 +15,8 @@
|
|||
// specific language governing permissions and limitations
|
||||
// under the License.
|
||||
|
||||
|
||||
#include "BuildMgr.h"
|
||||
#include "scheduler/BuildMgr.h"
|
||||
|
||||
namespace milvus {
|
||||
namespace scheduler {
|
||||
|
||||
} // namespace scheduler
|
||||
namespace scheduler {} // namespace scheduler
|
||||
} // namespace milvus
|
||||
|
|
|
@ -16,9 +16,9 @@
|
|||
// under the License.
|
||||
|
||||
#include "scheduler/TaskTable.h"
|
||||
#include "scheduler/SchedInst.h"
|
||||
#include "Utils.h"
|
||||
#include "event/TaskTableUpdatedEvent.h"
|
||||
#include "scheduler/SchedInst.h"
|
||||
#include "utils/Log.h"
|
||||
|
||||
#include <ctime>
|
||||
|
@ -167,13 +167,11 @@ TaskTable::PickToLoad(uint64_t limit) {
|
|||
}
|
||||
|
||||
if (table_[j]->task->path().Current() == "cpu") {
|
||||
if (table_[j]->task->Type() == TaskType::BuildIndexTask
|
||||
&& BuildMgrInst::GetInstance()->numoftasks() < 1) {
|
||||
if (table_[j]->task->Type() == TaskType::BuildIndexTask && BuildMgrInst::GetInstance()->numoftasks() < 1) {
|
||||
return std::vector<uint64_t>();
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
if (table_[j]->state == TaskTableItemState::LOADED) {
|
||||
++count;
|
||||
if (count > 2)
|
||||
|
|
Loading…
Reference in New Issue