@@ -38,12 +38,13 @@ function g.test_suggestion()
38
38
message = " Replication from localhost:13302 (A-2)" ..
39
39
" to localhost:13301 (A-1) isn't running" ,
40
40
}
41
-
42
- t .assert_equals (h .list_cluster_issues (g .A1 ), {replication_issue })
43
- t .assert_items_equals (
44
- h .get_suggestions (g .A1 ).restart_replication ,
45
- {{uuid = g .A1 .instance_uuid }}
46
- )
41
+ h .retrying ({}, function ()
42
+ t .assert_equals (h .list_cluster_issues (g .A1 ), {replication_issue })
43
+ t .assert_items_equals (
44
+ h .get_suggestions (g .A1 ).restart_replication ,
45
+ {{uuid = g .A1 .instance_uuid }}
46
+ )
47
+ end )
47
48
48
49
g .A2 .process :kill (' STOP' )
49
50
@@ -52,11 +53,13 @@ function g.test_suggestion()
52
53
53
54
g .A2 .process :kill (' CONT' )
54
55
55
- t .assert_equals (h .list_cluster_issues (g .A1 ), {replication_issue })
56
- t .assert_items_equals (
57
- h .get_suggestions (g .A1 ).restart_replication ,
58
- {{uuid = g .A1 .instance_uuid }}
59
- )
56
+ h .retrying ({}, function ()
57
+ t .assert_equals (h .list_cluster_issues (g .A1 ), {replication_issue })
58
+ t .assert_items_equals (
59
+ h .get_suggestions (g .A1 ).restart_replication ,
60
+ {{uuid = g .A1 .instance_uuid }}
61
+ )
62
+ end )
60
63
61
64
g .A1 :graphql ({
62
65
query = [[
@@ -69,7 +72,7 @@ function g.test_suggestion()
69
72
variables = {uuids = {g .A1 .instance_uuid }}
70
73
})
71
74
72
- t . helpers .retrying ({}, function ()
75
+ h .retrying ({}, function ()
73
76
t .assert_equals (h .list_cluster_issues (g .A1 ), {})
74
77
t .assert_equals (h .get_suggestions (g .A1 ).restart_replication , nil )
75
78
end )
0 commit comments