hiro/ray
1
0
Fork 0
mirror of https://github.com/vale981/ray synced 2025-03-06 10:31:39 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

[Test] Fix flaky test failure (#15326)

Browse source 
* Fix trial.

* unskip test.

* Mock commit
This commit is contained in:
SangBin Cho 2021-04-16 18:09:02 -07:00 • committed by GitHub
parent e6864523cf
commit 5f74d0e40d
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 3 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
python/ray/tests/test_failure_2.py
View file

@ -374,7 +374,6 @@ def test_connect_with_disconnected_node(shutdown_only):
p.close() p.close()
@pytest.mark.skip(reason="Temporarily disabled due to flakyniess.")
@pytest.mark.parametrize( @pytest.mark.parametrize(
"ray_start_cluster_head", [{ "ray_start_cluster_head", [{
"num_cpus": 5, "num_cpus": 5,

3
src/ray/raylet/node_manager.cc
View file

@ -708,6 +708,9 @@ void NodeManager::WarnResourceDeadlock() {
exemplar.GetTaskSpecification().JobId()); exemplar.GetTaskSpecification().JobId());
RAY_CHECK_OK(gcs_client_->Errors().AsyncReportJobError(error_data_ptr, nullptr)); RAY_CHECK_OK(gcs_client_->Errors().AsyncReportJobError(error_data_ptr, nullptr));
} }
// Try scheduling tasks. Without this, if there's no more tasks coming in, deadlocked
// tasks are never be scheduled.
cluster_task_manager_->ScheduleAndDispatchTasks();
} }
void NodeManager::GetObjectManagerProfileInfo() { void NodeManager::GetObjectManagerProfileInfo() {