[Core] Try scheduling tasks when the local resource creation is updated (#20019)

## Why are these changes needed?

Check https://github.com/ray-project/ray/pull/19996/files#r741963616

## Related issue number
This commit is contained in:
SangBin Cho 2021-11-04 04:29:51 +09:00 committed by GitHub
parent f4256a4ddc
commit eacaff5d8d
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23

View file

@ -897,6 +897,7 @@ void NodeManager::ResourceCreateUpdated(const NodeID &node_id,
// Updating local node could result in a inconsistence view in cluster resource
// scheduler which could make task hang.
if (node_id == self_node_id_) {
cluster_task_manager_->ScheduleAndDispatchTasks();
return;
}