mirror of
https://gitee.com/milvus-io/milvus.git
synced 2025-12-30 23:45:28 +08:00
MS-611 Add resources validity check in ResourceMgr
Former-commit-id: cc00283529c2e56ee9829c2f42d7c217d1ba3f42
This commit is contained in:
parent
0d3da0b841
commit
d0e7744abc
@ -66,12 +66,10 @@ JobMgr::worker_function() {
|
||||
}
|
||||
|
||||
auto tasks = build_task(job);
|
||||
auto disk_list = res_mgr_->GetDiskResources();
|
||||
if (!disk_list.empty()) {
|
||||
if (auto disk = disk_list[0].lock()) {
|
||||
for (auto& task : tasks) {
|
||||
disk->task_table().Put(task);
|
||||
}
|
||||
// disk resources NEVER be empty.
|
||||
if (auto disk = res_mgr_->GetDiskResources()[0].lock()) {
|
||||
for (auto& task : tasks) {
|
||||
disk->task_table().Put(task);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user