@@ -1140,8 +1140,7 @@ def test_warnings_metric_count_timeout_cluster_in_shards_resp3(env):
11401140 coord_before_info_dict = info_modules_to_dict (env )
11411141
11421142 # Test coord metric update after debug ft.search (not tested with resp2)
1143- env .expect (debug_cmd (), 'FT.SEARCH' , 'idx' , '*' , 'LIMIT' , 0 , 1 ,
1144- 'TIMEOUT_AFTER_N' , 1 , 'DEBUG_PARAMS_COUNT' , 2 ).noError ()
1143+ env .expect (debug_cmd (), 'FT.SEARCH' , 'idx' , '*' , 'TIMEOUT_AFTER_N' , 1 , 'DEBUG_PARAMS_COUNT' , 2 ).noError ()
11451144
11461145 # Check coord metric + 1
11471146 after_info_dict = info_modules_to_dict (env )
@@ -1151,8 +1150,7 @@ def test_warnings_metric_count_timeout_cluster_in_shards_resp3(env):
11511150 message = "Coordinator timeout warning should be +1 after FT.SEARCH" )
11521151
11531152 # Test debug aggregate with and without internal only
1154- env .expect (debug_cmd (), 'FT.AGGREGATE' , 'idx' , '*' , 'LIMIT' , 0 , 1 ,
1155- 'TIMEOUT_AFTER_N' , 0 , 'DEBUG_PARAMS_COUNT' , 2 ).noError ()
1153+ env .expect (debug_cmd (), 'FT.AGGREGATE' , 'idx' , '*' , 'TIMEOUT_AFTER_N' , 0 , 'DEBUG_PARAMS_COUNT' , 2 ).noError ()
11561154
11571155 # Verify timeout warning was counted on coordinator
11581156 after_info_dict = info_modules_to_dict (env )
@@ -1162,8 +1160,7 @@ def test_warnings_metric_count_timeout_cluster_in_shards_resp3(env):
11621160 message = "Coordinator timeout warning should be +1 after FT.AGGREGATE" )
11631161
11641162 # Test with internal only
1165- env .expect (debug_cmd (), 'FT.AGGREGATE' , 'idx' , '*' ,
1166- 'TIMEOUT_AFTER_N' , 1 , 'INTERNAL_ONLY' , 'DEBUG_PARAMS_COUNT' , 3 ).noError ()
1163+ env .expect (debug_cmd (), 'FT.AGGREGATE' , 'idx' , '*' , 'TIMEOUT_AFTER_N' , 1 , 'INTERNAL_ONLY' , 'DEBUG_PARAMS_COUNT' , 3 ).noError ()
11671164
11681165 # Since the cursor is not depleted after 1 read, the coord might sent another read to the shards
11691166 # which might trigger more metric increments (until reaching EOF)
0 commit comments