@@ -1437,7 +1437,9 @@ tracking_status(Config) ->
1437
1437
rabbit_ct_broker_helpers :rpc (Config , Server , ? MODULE , delete_testcase_queue , [Q ]).
1438
1438
1439
1439
restart_stream (Config ) ->
1440
- case rabbit_ct_broker_helpers :enable_feature_flag (Config , restart_stream ) of
1440
+ case rabbit_ct_broker_helpers :enable_feature_flag (Config , restart_streams ) of
1441
+ {skip , _ } = Skip ->
1442
+ Skip ;
1441
1443
ok ->
1442
1444
[Server | _ ] = rabbit_ct_broker_helpers :get_node_configs (Config , nodename ),
1443
1445
@@ -1459,10 +1461,6 @@ restart_stream(Config) ->
1459
1461
1460
1462
publish_confirm (Ch , Q , [<<" msg2" >>]),
1461
1463
rabbit_ct_broker_helpers :rpc (Config , Server , ? MODULE , delete_testcase_queue , [Q ]),
1462
- ok ;
1463
- _ ->
1464
- ct :pal (" skipping test ~s as feature flag `restart_stream` not supported" ,
1465
- [? FUNCTION_NAME ]),
1466
1464
ok
1467
1465
end .
1468
1466
@@ -2807,13 +2805,11 @@ ensure_retention_applied(Config, Server) ->
2807
2805
rabbit_ct_broker_helpers :rpc (Config , Server , gen_server , call , [osiris_retention , test ]).
2808
2806
2809
2807
rebalance (Config ) ->
2810
- case rabbit_ct_broker_helpers :enable_feature_flag (Config , restart_stream ) of
2808
+ case rabbit_ct_broker_helpers :enable_feature_flag (Config , restart_streams ) of
2811
2809
ok ->
2812
2810
rebalance0 (Config );
2813
- _ ->
2814
- ct :pal (" skipping test ~s as feature flag `restart_stream` not supported" ,
2815
- [? FUNCTION_NAME ]),
2816
- ok
2811
+ {skip , _ } = Skip ->
2812
+ Skip
2817
2813
end .
2818
2814
2819
2815
rebalance0 (Config ) ->
0 commit comments