File tree Expand file tree Collapse file tree 1 file changed +15
-3
lines changed Expand file tree Collapse file tree 1 file changed +15
-3
lines changed Original file line number Diff line number Diff line change @@ -219,11 +219,23 @@ def test_consumer_groups_mirroring(self):
219
219
220
220
def _group_present_in_target_cluster ():
221
221
target_rpk = RpkTool (self .target_cluster .service )
222
- groups = target_rpk .group_list (states = ["Stable" , "Empty" ])
223
- return "test_group" in groups
222
+ groups = target_rpk .group_list ()
224
223
225
- wait_until (
224
+ if not any (g .group == "test_group" for g in groups ):
225
+ return False , None
226
+
227
+ desc = target_rpk .group_describe (
228
+ group = "test_group" , tolerant = True , summary = False
229
+ )
230
+
231
+ return True , desc
232
+
233
+ target_cluster_group = wait_until_result (
226
234
lambda : _group_present_in_target_cluster (),
227
235
timeout_sec = 20 ,
228
236
err_msg = "Failed to find consumer group in the target cluster" ,
229
237
)
238
+
239
+ assert target_cluster_group .state == "Empty" , (
240
+ "Group test_group state expected to be empty on target cluster"
241
+ )
You can’t perform that action at this time.
0 commit comments