mirror of
https://github.com/wassname/ray.git
synced 2026-07-19 11:27:32 +08:00
fix node_failures.py (#5167)
This commit is contained in:
committed by
Stephanie Wang
parent
1649f1370e
commit
ccee77aafd
@@ -49,7 +49,7 @@ while True:
|
||||
for _ in range(100):
|
||||
previous_ids = [f.remote(previous_id) for previous_id in previous_ids]
|
||||
|
||||
ray.wait(previous_ids, num_returns=len(previous_ids))
|
||||
ray.get(previous_ids)
|
||||
|
||||
for _ in range(100):
|
||||
previous_ids = [f.remote(previous_id) for previous_id in previous_ids]
|
||||
|
||||
@@ -165,7 +165,10 @@ void ObjectManager::TryPull(const ObjectID &object_id) {
|
||||
auto &client_vector = it->second.client_locations;
|
||||
|
||||
// The timer should never fire if there are no expected client locations.
|
||||
RAY_CHECK(!client_vector.empty());
|
||||
if (client_vector.empty()) {
|
||||
return;
|
||||
}
|
||||
|
||||
RAY_CHECK(local_objects_.count(object_id) == 0);
|
||||
// Make sure that there is at least one client which is not the local client.
|
||||
// TODO(rkn): It may actually be possible for this check to fail.
|
||||
|
||||
Reference in New Issue
Block a user