@@ -1437,7 +1437,9 @@ tracking_status(Config) ->
14371437 rabbit_ct_broker_helpers :rpc (Config , Server , ? MODULE , delete_testcase_queue , [Q ]).
14381438
14391439restart_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 ;
14411443 ok ->
14421444 [Server | _ ] = rabbit_ct_broker_helpers :get_node_configs (Config , nodename ),
14431445
@@ -1459,10 +1461,6 @@ restart_stream(Config) ->
14591461
14601462 publish_confirm (Ch , Q , [<<" msg2" >>]),
14611463 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 ]),
14661464 ok
14671465 end .
14681466
@@ -2807,13 +2805,11 @@ ensure_retention_applied(Config, Server) ->
28072805 rabbit_ct_broker_helpers :rpc (Config , Server , gen_server , call , [osiris_retention , test ]).
28082806
28092807rebalance (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
28112809 ok ->
28122810 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
28172813 end .
28182814
28192815rebalance0 (Config ) ->
0 commit comments