run_suite.py 20.7 KB
Newer Older
1
2
import argparse
import glob
Lianmin Zheng's avatar
Lianmin Zheng committed
3
from dataclasses import dataclass
4
5
6

from sglang.test.test_utils import run_unittest_files

Lianmin Zheng's avatar
Lianmin Zheng committed
7
8
9
10
11
12
13

@dataclass
class TestFile:
    name: str
    estimated_time: float = 60


14
# NOTE: please sort the test cases alphabetically by the test file name
15
suites = {
Lianmin Zheng's avatar
Lianmin Zheng committed
16
    "per-commit-1-gpu": [
17
        TestFile("debug_utils/test_tensor_dump_forward_hook.py", 15),
18
        TestFile("function_call/test_json_schema_constraint.py", 30),
19
        TestFile("hicache/test_hicache.py", 116),
20
        TestFile("hicache/test_hicache_eagle.py", 150),
21
22
        TestFile("hicache/test_hicache_mla.py", 127),
        TestFile("hicache/test_hicache_storage.py", 127),
23
24
        TestFile("layers/attention/mamba/test_causal_conv1d.py", 25),
        TestFile("layers/attention/mamba/test_mamba_ssm.py", 50),
25
26
27
28
        TestFile("layers/attention/mamba/test_mamba_ssm_ssd.py", 20),
        TestFile("lora/test_lora.py", 150),
        TestFile("lora/test_lora_eviction.py", 240),
        TestFile("lora/test_lora_update.py", 600),
29
        TestFile("lora/test_lora_backend.py", 99),
30
31
32
        TestFile("lora/test_multi_lora_backend.py", 60),
        TestFile("models/test_compressed_tensors_models.py", 42),
        TestFile("models/test_cross_encoder_models.py", 100),
33
        TestFile("models/test_embedding_models.py", 73),
34
        TestFile("models/test_encoder_embedding_models.py", 460),
Lianmin Zheng's avatar
Lianmin Zheng committed
35
        TestFile("models/test_generation_models.py", 103),
36
        TestFile("models/test_nvidia_nemotron_nano_v2.py", 160),
Lianmin Zheng's avatar
Lianmin Zheng committed
37
        TestFile("models/test_qwen_models.py", 82),
Lianmin Zheng's avatar
Lianmin Zheng committed
38
        TestFile("models/test_reward_models.py", 132),
39
        TestFile("models/test_transformers_models.py", 320),
40
        TestFile("models/test_vlm_models.py", 741),
41
42
        TestFile("openai_server/basic/test_openai_embedding.py", 79),
        TestFile("openai_server/basic/test_openai_server.py", 270),
43
44
45
46
47
        TestFile("openai_server/basic/test_protocol.py", 10),
        TestFile("openai_server/basic/test_serving_chat.py", 10),
        TestFile("openai_server/basic/test_serving_completions.py", 10),
        TestFile("openai_server/basic/test_serving_embedding.py", 10),
        TestFile("openai_server/features/test_enable_thinking.py", 70),
48
49
50
        TestFile("openai_server/features/test_json_constrained.py", 120),
        TestFile("openai_server/features/test_json_mode.py", 120),
        TestFile("openai_server/features/test_openai_server_ebnf.py", 20),
51
52
53
        TestFile("openai_server/features/test_openai_server_hidden_states.py", 240),
        TestFile("openai_server/features/test_reasoning_content.py", 89),
        TestFile("openai_server/function_call/test_openai_function_calling.py", 60),
54
        TestFile("openai_server/function_call/test_tool_choice.py", 120),
55
56
57
58
        TestFile("openai_server/validation/test_large_max_new_tokens.py", 41),
        TestFile("openai_server/validation/test_matched_stop.py", 60),
        TestFile("openai_server/validation/test_openai_server_ignore_eos.py", 85),
        TestFile("openai_server/validation/test_request_length_validation.py", 31),
59
60
61
        TestFile("quant/test_block_int8.py", 22),
        TestFile("quant/test_fp8_kernel.py", 8),
        TestFile("quant/test_int8_kernel.py", 8),
62
        TestFile("quant/test_triton_scaled_mm.py", 8),
63
        TestFile("quant/test_w8a8_quantization.py", 160),
64
        TestFile("quant/test_autoround.py", 60),
65
        TestFile("rl/test_fp32_lm_head.py", 30),
66
67
68
        TestFile("rl/test_update_weights_from_disk.py", 210),
        TestFile("rl/test_update_weights_from_tensor.py", 80),
        TestFile("test_abort.py", 190),
69
        TestFile("test_build_eagle_tree.py", 8),
70
        TestFile("test_chunked_prefill.py", 410),
71
        TestFile("test_create_kvindices.py", 2),
72
        TestFile("test_deterministic.py", 320),
73
        TestFile("test_eagle_infer_a.py", 370),
74
        TestFile("test_eagle_infer_b.py", 500),
75
        TestFile("test_eagle_infer_beta.py", 90),
76
        TestFile("test_ebnf_constrained.py", 80),
Lianmin Zheng's avatar
Lianmin Zheng committed
77
        TestFile("test_eval_fp8_accuracy.py", 303),
78
79
80
        TestFile("test_fa3.py", 420),
        TestFile("test_flashmla.py", 230),
        TestFile("rotary_embedding/test_mrope.py", 10),
81
        TestFile("test_function_call_parser.py", 10),
82
83
        TestFile("test_fused_moe.py", 80),
        TestFile("test_gpt_oss_1gpu.py", 750),
84
        TestFile("test_harmony_parser.py", 20),
85
        TestFile("test_hidden_states.py", 55),
86
        TestFile("test_hybrid_attn_backend.py", 379),
Lianmin Zheng's avatar
Lianmin Zheng committed
87
        TestFile("test_input_embeddings.py", 38),
88
        TestFile("test_io_struct.py", 8),
89
        TestFile("test_jinja_template_utils.py", 1),
90
        TestFile("test_mamba_unittest.py", 4),
91
        TestFile("test_metrics.py", 32),
92
        TestFile("test_metrics_utils.py", 1),
93
        TestFile("test_mla.py", 180),
Lianmin Zheng's avatar
Lianmin Zheng committed
94
        TestFile("test_mla_deepseek_v3.py", 500),
95
96
        TestFile("test_mla_flashinfer.py", 302),
        TestFile("test_mla_fp8.py", 93),
97
        TestFile("test_mla_int8_deepseek_v3.py", 300),
98
        TestFile("test_modelopt_loader.py", 30),
99
        TestFile("test_multi_tokenizer.py", 230),
100
        TestFile("test_ngram_speculative_decoding.py", 290),
Lianmin Zheng's avatar
Lianmin Zheng committed
101
        TestFile("test_no_chunked_prefill.py", 108),
102
        TestFile("test_no_overlap_scheduler.py", 234),
103
        TestFile("test_original_logprobs.py", 41),
Lianmin Zheng's avatar
Lianmin Zheng committed
104
        TestFile("test_page_size.py", 60),
105
        TestFile("test_penalty.py", 82),
106
        TestFile("test_priority_scheduling.py", 130),
Lianmin Zheng's avatar
Lianmin Zheng committed
107
        TestFile("test_pytorch_sampling_backend.py", 66),
108
        TestFile("test_radix_attention.py", 105),
109
        TestFile("test_radix_cache_unit.py", 5),
110
        TestFile("test_reasoning_parser.py", 5),
111
        TestFile("test_regex_constrained.py", 64),
112
        TestFile("test_request_queue_validation.py", 30),
113
        TestFile("test_retract_decode.py", 450),
114
        TestFile("test_score_api.py", 310),
Lianmin Zheng's avatar
Lianmin Zheng committed
115
        TestFile("test_server_args.py", 1),
116
        TestFile("test_speculative_registry.py", 1),
117
        TestFile("test_skip_tokenizer_init.py", 117),
Lianmin Zheng's avatar
Lianmin Zheng committed
118
        TestFile("test_srt_endpoint.py", 130),
119
        TestFile("test_srt_engine.py", 261),
120
        TestFile("test_standalone_speculative_decoding.py", 150),
121
        TestFile("test_start_profile.py", 60),
122
123
        TestFile("test_profile_merger.py", 60),
        TestFile("test_profile_merger_http_api.py", 15),
124
        TestFile("test_swa_unittest.py", 1),
Lianmin Zheng's avatar
Lianmin Zheng committed
125
        TestFile("test_torch_compile.py", 76),
126
        TestFile("test_torch_compile_moe.py", 210),
127
        TestFile("test_torch_native_attention_backend.py", 123),
Lianmin Zheng's avatar
Lianmin Zheng committed
128
        TestFile("test_torchao.py", 70),
129
        TestFile("test_triton_attention_backend.py", 150),
130
        TestFile("test_triton_attention_kernels.py", 4),
Lianmin Zheng's avatar
Lianmin Zheng committed
131
        TestFile("test_triton_moe_channel_fp8_kernel.py", 25),
132
        TestFile("test_triton_sliding_window.py", 100),
133
        TestFile("test_utils_update_weights.py", 48),
134
135
        TestFile("test_vision_chunked_prefill.py", 170),
        TestFile("test_vision_openai_server_a.py", 900),
136
        TestFile("test_vlm_input_format.py", 300),
137
138
        TestFile("test_modelopt_loader.py", 30),
        TestFile("test_modelopt_export.py", 30),
139
    ],
Lianmin Zheng's avatar
Lianmin Zheng committed
140
    "per-commit-2-gpu": [
141
        TestFile("ep/test_moe_ep.py", 140),
142
143
        TestFile("hicache/test_hicache_storage_3fs_backend.py", 200),
        TestFile("hicache/test_hicache_storage_file_backend.py", 200),
144
        TestFile("hicache/test_hicache_storage_mooncake_backend.py", 300),
145
        TestFile("layers/attention/mamba/test_mamba2_mixer.py", 50),
146
        TestFile("lora/test_lora_tp.py", 116),
147
        TestFile("models/test_glm4_moe_models.py", 100),
Ke Bao's avatar
Ke Bao committed
148
        TestFile("models/test_kimi_linear_models.py", 90),
149
        TestFile("rl/test_update_weights_from_distributed.py", 103),
Lianmin Zheng's avatar
Lianmin Zheng committed
150
        TestFile("test_data_parallelism.py", 73),
151
        TestFile("test_disaggregation_basic.py", 400),
152
        TestFile("test_dp_attention.py", 350),
153
        TestFile("test_load_weights_from_remote_instance.py", 72),
Lianmin Zheng's avatar
Lianmin Zheng committed
154
        TestFile("test_patch_torch.py", 19),
155
        TestFile("test_release_memory_occupation.py", 200),
156
        TestFile("test_eagle_dp_attention.py", 200),
Lianmin Zheng's avatar
Lianmin Zheng committed
157
158
    ],
    "per-commit-4-gpu": [
159
160
        TestFile("models/test_qwen3_next_models.py", 291),
        TestFile("test_disaggregation_dp_attention.py", 155),
Lianmin Zheng's avatar
Lianmin Zheng committed
161
162
        TestFile("test_gpt_oss_4gpu.py", 300),
        TestFile("test_local_attn.py", 411),
Lianmin Zheng's avatar
Lianmin Zheng committed
163
        TestFile("test_multi_instance_release_memory_occupation.py", 64),
164
        TestFile("test_pp_single_node.py", 481),
Lianmin Zheng's avatar
Lianmin Zheng committed
165
    ],
166
    "per-commit-8-gpu-h200": [
167
168
        TestFile("test_deepseek_v3_basic.py", 275),
        TestFile("test_deepseek_v3_mtp.py", 275),
169
        TestFile("test_disaggregation_hybrid_attention.py", 200),
Lianmin Zheng's avatar
Lianmin Zheng committed
170
    ],
171
    "per-commit-8-gpu-h20": [
172
        TestFile("quant/test_w4a8_deepseek_v3.py", 520),
173
174
175
        TestFile("test_disaggregation_different_tp.py", 600),
        TestFile("test_disaggregation_pp.py", 140),
    ],
Yineng Zhang's avatar
Yineng Zhang committed
176
    "per-commit-4-gpu-b200": [
177
        TestFile("test_deepseek_v3_fp4_4gpu.py", 3600),
Kangyan-Zhou's avatar
Kangyan-Zhou committed
178
179
        TestFile("test_flash_attention_4.py", 300),
        TestFile("test_gpt_oss_4gpu.py", 600),
180
        TestFile("test_llama31_fp4.py", 300),
Lianmin Zheng's avatar
Lianmin Zheng committed
181
    ],
182
183
184
    "per-commit-4-gpu-gb200": [
        TestFile("test_deepseek_v3_fp4_4gpu.py", 3600),
    ],
Lianmin Zheng's avatar
Lianmin Zheng committed
185
    "per-commit-4-gpu-deepep": [
186
        TestFile("ep/test_deepep_small.py", 531),
187
        TestFile("ep/test_mooncake_ep_small.py", 450),
Lianmin Zheng's avatar
Lianmin Zheng committed
188
    ],
189
    "per-commit-8-gpu-h200-deepep": [
190
        TestFile("ep/test_deepep_large.py", 338),
Lianmin Zheng's avatar
Lianmin Zheng committed
191
    ],
192
    "per-commit-8-gpu-h200-deepseek-v32": [
193
        TestFile("test_deepseek_v32_basic.py", 275),
194
        TestFile("test_deepseek_v32_mtp.py", 275),
195
        TestFile("test_deepseek_v32_nsabackend.py", 600),
196
    ],
Lianmin Zheng's avatar
Lianmin Zheng committed
197
    "vllm_dependency_test": [
198
        TestFile("quant/test_awq.py", 163),
Lianmin Zheng's avatar
Lianmin Zheng committed
199
200
201
        TestFile("test_bnb.py", 5),
        TestFile("test_gptqmodel_dynamic.py", 102),
        TestFile("test_vllm_dependency.py", 185),
202
        TestFile("test_gguf.py", 96),
Lianmin Zheng's avatar
Lianmin Zheng committed
203
    ],
Lianmin Zheng's avatar
Lianmin Zheng committed
204
    # If the test cases take too long, considering adding them to nightly tests instead of per-commit tests
205
206
    "nightly-1-gpu": [
        TestFile("lora/test_lora_qwen3.py", 97),
207
        TestFile("lora/test_lora_qwen3_vl.py", 200),
208
209
210
211
212
213
214
        TestFile("lora/test_lora_radix_cache.py", 200),
        TestFile("lora/test_lora_eviction_policy.py", 200),
        TestFile("lora/test_lora_openai_api.py", 30),
        TestFile("openai_server/features/test_lora_openai_compatible.py", 150),
        TestFile("batch_invariant/test_batch_invariant_ops.py", 10),
        TestFile("test_deepseek_v3_deterministic.py", 240),
    ],
Lianmin Zheng's avatar
Lianmin Zheng committed
215
    "nightly-8-gpu": [],
Lianmin Zheng's avatar
Lianmin Zheng committed
216
217
218
}

# Add AMD tests
219
# NOTE: please sort the test cases alphabetically by the test file name
Lianmin Zheng's avatar
Lianmin Zheng committed
220
suite_amd = {
221
    "per-commit-amd": [
222
        TestFile("function_call/test_json_schema_constraint.py", 30),
223
224
225
        TestFile("hicache/test_hicache.py", 116),
        TestFile("hicache/test_hicache_mla.py", 127),
        TestFile("hicache/test_hicache_storage.py", 127),
226
        TestFile("lora/test_lora.py", 150),
227
228
        TestFile("lora/test_lora_backend.py", 99),
        TestFile("lora/test_lora_cuda_graph.py", 250),
229
        TestFile("lora/test_lora_eviction.py", 240),
230
        TestFile("lora/test_lora_qwen3.py", 97),
231
        TestFile("lora/test_multi_lora_backend.py", 60),
232
        TestFile("models/test_compressed_tensors_models.py", 42),
233
234
        TestFile("models/test_qwen_models.py", 82),
        TestFile("models/test_reward_models.py", 132),
235
        TestFile("models/test_transformers_models.py", 320),
236
237
        TestFile("openai_server/basic/test_openai_embedding.py", 79),
        TestFile("openai_server/basic/test_openai_server.py", 270),
238
239
240
241
        TestFile("openai_server/basic/test_protocol.py", 10),
        TestFile("openai_server/basic/test_serving_chat.py", 10),
        TestFile("openai_server/basic/test_serving_completions.py", 10),
        TestFile("openai_server/basic/test_serving_embedding.py", 10),
242
        TestFile("openai_server/features/test_enable_thinking.py", 70),
243
244
245
        TestFile("openai_server/features/test_json_constrained.py", 120),
        TestFile("openai_server/features/test_json_mode.py", 120),
        TestFile("openai_server/features/test_openai_server_ebnf.py", 20),
246
        TestFile("openai_server/features/test_reasoning_content.py", 89),
247
        TestFile("openai_server/function_call/test_openai_function_calling.py", 60),
248
        TestFile("openai_server/function_call/test_tool_choice.py", 120),
249
        TestFile("openai_server/validation/test_large_max_new_tokens.py", 41),
250
251
        TestFile("openai_server/validation/test_matched_stop.py", 60),
        TestFile("openai_server/validation/test_openai_server_ignore_eos.py", 85),
252
        TestFile("openai_server/validation/test_request_length_validation.py", 31),
253
        TestFile("quant/test_awq_dequant.py", 2),
254
        TestFile("quant/test_block_int8.py", 22),
255
        TestFile("rl/test_update_weights_from_disk.py", 210),
256
        TestFile("test_abort.py", 51),
257
        TestFile("test_chunked_prefill.py", 410),
258
        TestFile("test_create_kvindices.py", 2),
259
        TestFile("test_ebnf_constrained.py", 80),
260
261
        TestFile("test_eval_fp8_accuracy.py", 303),
        TestFile("test_function_call_parser.py", 10),
262
        TestFile("test_fused_moe.py", 80),
263
        TestFile("test_input_embeddings.py", 38),
264
265
266
        TestFile("test_io_struct.py", 8),
        TestFile("test_jinja_template_utils.py", 1),
        TestFile("test_metrics.py", 32),
267
        TestFile("test_metrics_utils.py", 1),
268
269
        TestFile("test_mla.py", 242),
        TestFile("test_mla_deepseek_v3.py", 221),
270
271
        TestFile("test_no_chunked_prefill.py", 108),
        TestFile("test_page_size.py", 60),
272
        TestFile("test_penalty.py", 180),
273
274
        TestFile("test_pytorch_sampling_backend.py", 66),
        TestFile("test_radix_attention.py", 105),
275
        TestFile("test_reasoning_parser.py", 5),
276
        TestFile("test_regex_constrained.py", 64),
277
        TestFile("test_retract_decode.py", 450),
278
        TestFile("test_rope_rocm.py", 3),
279
280
        TestFile("test_server_args.py", 1),
        TestFile("test_skip_tokenizer_init.py", 117),
281
        TestFile("test_srt_endpoint.py", 130),
282
        TestFile("test_srt_engine.py", 261),
283
        TestFile("test_torch_compile.py", 169),
284
        TestFile("test_torch_compile_moe.py", 210),
285
        TestFile("test_torch_native_attention_backend.py", 123),
286
        TestFile("test_triton_attention_backend.py", 250),
287
        TestFile("test_wave_attention_kernels.py", 2),
288
289
290
291
292
293
        # Disabled temporarily
        # TestFile("models/test_embedding_models.py", 73), # Disabled temporarily, see https://github.com/sgl-project/sglang/issues/11127
        # TestFile("openai_server/features/test_openai_server_hidden_states.py", 240),
        # TestFile("rl/test_update_weights_from_tensor.py", 48),
        # TestFile("test_no_overlap_scheduler.py", 234), # Disabled temporarily and track in #7703
        # TestFile("test_vision_chunked_prefill.py", 175), # Disabled temporarily and track in #7701
Sai Enduri's avatar
Sai Enduri committed
294
        # TestFile("test_wave_attention_backend.py", 150), # Disabled temporarily, see https://github.com/sgl-project/sglang/issues/11127
295
    ],
296
    "per-commit-amd-mi35x": [
297
        TestFile("test_gpt_oss_1gpu.py", 750),
298
        TestFile("test_mla.py", 242),
299
    ],
300
    "per-commit-2-gpu-amd": [
301
302
        TestFile("lora/test_lora_tp.py", 116),
        TestFile("rl/test_update_weights_from_distributed.py", 103),
303
        TestFile("test_data_parallelism.py", 73),
304
        TestFile("test_load_weights_from_remote_instance.py", 72),
Sai Enduri's avatar
Sai Enduri committed
305
        # TestFile("test_patch_torch.py", 19), # Disabled temporarily, see https://github.com/sgl-project/sglang/issues/11127
306
    ],
307
308
309
    "per-commit-4-gpu-amd": [
        TestFile("test_pp_single_node.py", 150),
    ],
310
    "per-commit-8-gpu-amd": [
311
312
        TestFile("test_deepseek_v3_basic.py", 275),
        TestFile("test_deepseek_v3_mtp.py", 275),
313
    ],
Lianmin Zheng's avatar
Lianmin Zheng committed
314
315
    "nightly-amd": [
        TestFile("test_nightly_gsm8k_eval_amd.py"),
fzyzcjy's avatar
fzyzcjy committed
316
    ],
Lianmin Zheng's avatar
Lianmin Zheng committed
317
318
319
}

# Add Intel Xeon tests
320
# NOTE: please sort the test cases alphabetically by the test file name
Lianmin Zheng's avatar
Lianmin Zheng committed
321
suite_xeon = {
322
323
    "per-commit-cpu": [
        TestFile("cpu/test_activation.py"),
324
        TestFile("cpu/test_binding.py"),
325
326
327
        TestFile("cpu/test_decode.py"),
        TestFile("cpu/test_extend.py"),
        TestFile("cpu/test_gemm.py"),
328
        TestFile("cpu/test_mla.py"),
329
330
331
        TestFile("cpu/test_moe.py"),
        TestFile("cpu/test_norm.py"),
        TestFile("cpu/test_qkv_proj_with_rope.py"),
332
        TestFile("cpu/test_rope.py"),
333
        TestFile("cpu/test_shared_expert.py"),
334
        TestFile("cpu/test_topk.py"),
335
336
337
338
        TestFile("cpu/test_cpu_graph.py"),
        TestFile("cpu/test_intel_amx_attention_backend_a.py"),
        TestFile("cpu/test_intel_amx_attention_backend_b.py"),
        TestFile("cpu/test_intel_amx_attention_backend_c.py"),
339
    ],
Lianmin Zheng's avatar
Lianmin Zheng committed
340
341
}

342
343
344
345
346
347
348
# Add Intel XPU tests
suite_xpu = {
    "per-commit-xpu": [
        TestFile("xpu/test_intel_xpu_backend.py"),
    ],
}

Lianmin Zheng's avatar
Lianmin Zheng committed
349
# Add Ascend NPU tests
350
# NOTE: please sort the test cases alphabetically by the test file name
Lianmin Zheng's avatar
Lianmin Zheng committed
351
352
suite_ascend = {
    "per-commit-1-ascend-npu": [
353
        TestFile("ascend/test_ascend_graph_tp1_bf16.py", 400),
354
        TestFile("ascend/test_ascend_tp1_bf16.py", 400),
355
    ],
Lianmin Zheng's avatar
Lianmin Zheng committed
356
    "per-commit-2-ascend-npu": [
357
        TestFile("ascend/test_ascend_graph_tp2_bf16.py", 400),
358
        TestFile("ascend/test_ascend_mla_fia_w8a8int8.py", 400),
359
360
        TestFile("ascend/test_ascend_tp2_bf16.py", 400),
        TestFile("ascend/test_ascend_tp2_fia_bf16.py", 400),
361
    ],
Lianmin Zheng's avatar
Lianmin Zheng committed
362
    "per-commit-4-ascend-npu": [
363
        TestFile("ascend/test_ascend_mla_w8a8int8.py", 400),
364
        TestFile("ascend/test_ascend_tp4_bf16.py", 400),
365
    ],
366
367
    "per-commit-16-ascend-a3": [
        TestFile("ascend/test_ascend_deepep.py", 400),
368
        TestFile("ascend/test_ascend_deepseek_mtp.py", 400),
369
    ],
370
371
}

Lianmin Zheng's avatar
Lianmin Zheng committed
372
373
374
suites.update(suite_amd)
suites.update(suite_xeon)
suites.update(suite_ascend)
375
suites.update(suite_xpu)
Lianmin Zheng's avatar
Lianmin Zheng committed
376

Lianmin Zheng's avatar
Lianmin Zheng committed
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420

def auto_partition(files, rank, size):
    """
    Partition files into size sublists with approximately equal sums of estimated times
    using stable sorting, and return the partition for the specified rank.

    Args:
        files (list): List of file objects with estimated_time attribute
        rank (int): Index of the partition to return (0 to size-1)
        size (int): Number of partitions

    Returns:
        list: List of file objects in the specified rank's partition
    """
    weights = [f.estimated_time for f in files]

    if not weights or size <= 0 or size > len(weights):
        return []

    # Create list of (weight, original_index) tuples
    # Using negative index as secondary key to maintain original order for equal weights
    indexed_weights = [(w, -i) for i, w in enumerate(weights)]
    # Stable sort in descending order by weight
    # If weights are equal, larger (negative) index comes first (i.e., earlier original position)
    indexed_weights = sorted(indexed_weights, reverse=True)

    # Extract original indices (negate back to positive)
    indexed_weights = [(w, -i) for w, i in indexed_weights]

    # Initialize partitions and their sums
    partitions = [[] for _ in range(size)]
    sums = [0.0] * size

    # Greedy approach: assign each weight to partition with smallest current sum
    for weight, idx in indexed_weights:
        # Find partition with minimum sum
        min_sum_idx = sums.index(min(sums))
        partitions[min_sum_idx].append(idx)
        sums[min_sum_idx] += weight

    # Return the files corresponding to the indices in the specified rank's partition
    indices = partitions[rank]
    return [files[i] for i in indices]

421
422
423
424
425
426

if __name__ == "__main__":
    arg_parser = argparse.ArgumentParser()
    arg_parser.add_argument(
        "--timeout-per-file",
        type=int,
427
        default=1200,
428
429
430
431
432
433
434
435
436
        help="The time limit for running one file in seconds.",
    )
    arg_parser.add_argument(
        "--suite",
        type=str,
        default=list(suites.keys())[0],
        choices=list(suites.keys()) + ["all"],
        help="The suite to run",
    )
437
438
439
440
441
442
443
444
445
446
447
448
    arg_parser.add_argument(
        "--range-begin",
        type=int,
        default=0,
        help="The begin index of the range of the files to run.",
    )
    arg_parser.add_argument(
        "--range-end",
        type=int,
        default=None,
        help="The end index of the range of the files to run.",
    )
Lianmin Zheng's avatar
Lianmin Zheng committed
449
450
451
452
453
454
455
456
457
458
    arg_parser.add_argument(
        "--auto-partition-id",
        type=int,
        help="Use auto load balancing. The part id.",
    )
    arg_parser.add_argument(
        "--auto-partition-size",
        type=int,
        help="Use auto load balancing. The number of parts.",
    )
459
    args = arg_parser.parse_args()
Lianmin Zheng's avatar
Lianmin Zheng committed
460
    print(f"{args=}")
461
462
463
464
465
466

    if args.suite == "all":
        files = glob.glob("**/test_*.py", recursive=True)
    else:
        files = suites[args.suite]

Lianmin Zheng's avatar
Lianmin Zheng committed
467
468
469
470
    if args.auto_partition_size:
        files = auto_partition(files, args.auto_partition_id, args.auto_partition_size)
    else:
        files = files[args.range_begin : args.range_end]
471

Lianmin Zheng's avatar
Lianmin Zheng committed
472
    print("The running tests are ", [f.name for f in files])
473

474
475
    exit_code = run_unittest_files(files, args.timeout_per_file)
    exit(exit_code)