wassname/ray
1
0
Fork 0
mirror of https://github.com/wassname/ray.git synced 2026-07-15 11:25:40 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix TestObjectTableResubscribe testcase bug (#9650)

Browse Source
This commit is contained in:
fangfengbin
2020-07-23 20:28:31 +08:00
committed by GitHub
parent 64b0f173c8
commit 5ab17e0dd8
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/ray/gcs/gcs_client/test/service_based_gcs_client_test.cc
+5 -1
View File
@@ -981,12 +981,16 @@ TEST_F(ServiceBasedGcsClientTest, TestObjectTableResubscribe) {
// Restart GCS.
RestartGcsServer();
// When GCS client detects that GCS server has restarted, but the pub-sub server
// didn't restart, it will fetch the subscription data again from the GCS server, so
// `object2_change_count` plus 1.
WaitPendingDone(object2_change_count, 2);
// Add location of object to GCS again and check if resubscribe works.
ASSERT_TRUE(AddLocation(object1_id, node_id));
WaitPendingDone(object1_change_count, 1);
ASSERT_TRUE(AddLocation(object2_id, node_id));
WaitPendingDone(object2_change_count, 2);
WaitPendingDone(object2_change_count, 3);
}
TEST_F(ServiceBasedGcsClientTest, TestNodeTableResubscribe) {