diff --git a/cpp/src/scheduler/JobMgr.cpp b/cpp/src/scheduler/JobMgr.cpp index 25a4932f03..bf22f7be2e 100644 --- a/cpp/src/scheduler/JobMgr.cpp +++ b/cpp/src/scheduler/JobMgr.cpp @@ -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); } } }