mirror of
https://github.com/wassname/ray.git
synced 2026-07-16 11:21:10 +08:00
Fix a bug that 'remote_avaiable' used after it was moved #9002(#9002)
This commit is contained in:
@@ -761,9 +761,9 @@ void NodeManager::HeartbeatAdded(const ClientID &client_id,
|
||||
remote_resources.SetLoadResources(std::move(remote_load));
|
||||
|
||||
if (new_scheduler_enabled_ && client_id != self_node_id_) {
|
||||
new_resource_scheduler_->AddOrUpdateNode(client_id.Binary(),
|
||||
remote_total.GetResourceMap(),
|
||||
remote_available.GetResourceMap());
|
||||
new_resource_scheduler_->AddOrUpdateNode(
|
||||
client_id.Binary(), remote_total.GetResourceMap(),
|
||||
remote_resources.GetAvailableResources().GetResourceMap());
|
||||
NewSchedulerSchedulePendingTasks();
|
||||
return;
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user