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

# Add AMD tests
203
# NOTE: please sort the test cases alphabetically by the test file name
Lianmin Zheng's avatar
Lianmin Zheng committed
204
suite_amd = {
205
    "per-commit-amd": [
206
        TestFile("function_call/test_json_schema_constraint.py", 30),
207
208
209
        TestFile("hicache/test_hicache.py", 116),
        TestFile("hicache/test_hicache_mla.py", 127),
        TestFile("hicache/test_hicache_storage.py", 127),
210
        TestFile("lora/test_lora.py", 200),
211
212
        TestFile("lora/test_lora_backend.py", 99),
        TestFile("lora/test_lora_cuda_graph.py", 250),
213
        TestFile("lora/test_lora_eviction.py", 200),
214
        TestFile("lora/test_lora_qwen3.py", 97),
215
        TestFile("lora/test_multi_lora_backend.py", 60),
216
        TestFile("models/test_compressed_tensors_models.py", 42),
217
218
        TestFile("models/test_qwen_models.py", 82),
        TestFile("models/test_reward_models.py", 132),
219
        TestFile("models/test_transformers_models.py", 320),
220
221
        TestFile("openai_server/basic/test_openai_embedding.py", 141),
        TestFile("openai_server/basic/test_openai_server.py", 149),
222
223
224
225
        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),
226
        TestFile("openai_server/features/test_enable_thinking.py", 70),
227
228
229
        TestFile("openai_server/features/test_json_constrained.py", 98),
        TestFile("openai_server/features/test_json_mode.py", 90),
        TestFile("openai_server/features/test_openai_server_ebnf.py", 95),
230
        TestFile("openai_server/features/test_reasoning_content.py", 89),
231
232
        TestFile("openai_server/function_call/test_openai_function_calling.py", 60),
        TestFile("openai_server/function_call/test_tool_choice.py", 226),
233
        TestFile("openai_server/validation/test_large_max_new_tokens.py", 41),
234
235
        TestFile("openai_server/validation/test_matched_stop.py", 60),
        TestFile("openai_server/validation/test_openai_server_ignore_eos.py", 85),
236
        TestFile("openai_server/validation/test_request_length_validation.py", 31),
237
        TestFile("quant/test_awq_dequant.py", 2),
238
        TestFile("quant/test_block_int8.py", 22),
239
        TestFile("rl/test_update_weights_from_disk.py", 114),
240
241
        TestFile("test_abort.py", 51),
        TestFile("test_chunked_prefill.py", 313),
242
        TestFile("test_create_kvindices.py", 2),
243
        TestFile("test_ebnf_constrained.py", 108),
244
245
        TestFile("test_eval_fp8_accuracy.py", 303),
        TestFile("test_function_call_parser.py", 10),
246
        TestFile("test_fused_moe.py", 30),
247
        TestFile("test_input_embeddings.py", 38),
248
249
250
        TestFile("test_io_struct.py", 8),
        TestFile("test_jinja_template_utils.py", 1),
        TestFile("test_metrics.py", 32),
251
        TestFile("test_metrics_utils.py", 1),
252
253
        TestFile("test_mla.py", 242),
        TestFile("test_mla_deepseek_v3.py", 221),
254
255
        TestFile("test_no_chunked_prefill.py", 108),
        TestFile("test_page_size.py", 60),
256
        TestFile("test_penalty.py", 41),
257
258
        TestFile("test_pytorch_sampling_backend.py", 66),
        TestFile("test_radix_attention.py", 105),
259
        TestFile("test_reasoning_parser.py", 5),
260
        TestFile("test_regex_constrained.py", 64),
261
        TestFile("test_retract_decode.py", 54),
262
        TestFile("test_rope_rocm.py", 3),
263
264
        TestFile("test_server_args.py", 1),
        TestFile("test_skip_tokenizer_init.py", 117),
265
        TestFile("test_srt_endpoint.py", 130),
266
        TestFile("test_srt_engine.py", 261),
267
        TestFile("test_torch_compile.py", 169),
268
        TestFile("test_torch_compile_moe.py", 172),
269
270
        TestFile("test_torch_native_attention_backend.py", 123),
        TestFile("test_triton_attention_backend.py", 150),
271
        TestFile("test_wave_attention_kernels.py", 2),
272
273
274
275
276
277
        # 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
278
        # TestFile("test_wave_attention_backend.py", 150), # Disabled temporarily, see https://github.com/sgl-project/sglang/issues/11127
279
    ],
280
281
    "per-commit-amd-mi35x": [
        TestFile("test_gpt_oss_1gpu.py", 600),
282
        TestFile("test_mla.py", 242),
283
    ],
284
    "per-commit-2-gpu-amd": [
285
286
        TestFile("lora/test_lora_tp.py", 116),
        TestFile("rl/test_update_weights_from_distributed.py", 103),
287
        TestFile("test_data_parallelism.py", 73),
288
        TestFile("test_load_weights_from_remote_instance.py", 72),
Sai Enduri's avatar
Sai Enduri committed
289
        # TestFile("test_patch_torch.py", 19), # Disabled temporarily, see https://github.com/sgl-project/sglang/issues/11127
290
    ],
291
292
293
    "per-commit-4-gpu-amd": [
        TestFile("test_pp_single_node.py", 150),
    ],
294
    "per-commit-8-gpu-amd": [
295
296
        TestFile("test_deepseek_v3_basic.py", 275),
        TestFile("test_deepseek_v3_mtp.py", 275),
297
    ],
Lianmin Zheng's avatar
Lianmin Zheng committed
298
299
    "nightly-amd": [
        TestFile("test_nightly_gsm8k_eval_amd.py"),
fzyzcjy's avatar
fzyzcjy committed
300
    ],
Lianmin Zheng's avatar
Lianmin Zheng committed
301
302
303
}

# Add Intel Xeon tests
304
# NOTE: please sort the test cases alphabetically by the test file name
Lianmin Zheng's avatar
Lianmin Zheng committed
305
suite_xeon = {
306
307
    "per-commit-cpu": [
        TestFile("cpu/test_activation.py"),
308
        TestFile("cpu/test_binding.py"),
309
310
311
        TestFile("cpu/test_decode.py"),
        TestFile("cpu/test_extend.py"),
        TestFile("cpu/test_gemm.py"),
312
        TestFile("cpu/test_mla.py"),
313
314
315
        TestFile("cpu/test_moe.py"),
        TestFile("cpu/test_norm.py"),
        TestFile("cpu/test_qkv_proj_with_rope.py"),
316
        TestFile("cpu/test_rope.py"),
317
        TestFile("cpu/test_shared_expert.py"),
318
        TestFile("cpu/test_topk.py"),
319
320
321
322
        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"),
323
    ],
Lianmin Zheng's avatar
Lianmin Zheng committed
324
325
}

326
327
328
329
330
331
332
# Add Intel XPU tests
suite_xpu = {
    "per-commit-xpu": [
        TestFile("xpu/test_intel_xpu_backend.py"),
    ],
}

Lianmin Zheng's avatar
Lianmin Zheng committed
333
# Add Ascend NPU tests
334
# NOTE: please sort the test cases alphabetically by the test file name
Lianmin Zheng's avatar
Lianmin Zheng committed
335
336
suite_ascend = {
    "per-commit-1-ascend-npu": [
337
        TestFile("ascend/test_ascend_graph_tp1_bf16.py", 400),
338
        TestFile("ascend/test_ascend_tp1_bf16.py", 400),
339
    ],
Lianmin Zheng's avatar
Lianmin Zheng committed
340
    "per-commit-2-ascend-npu": [
341
        TestFile("ascend/test_ascend_graph_tp2_bf16.py", 400),
342
        TestFile("ascend/test_ascend_mla_fia_w8a8int8.py", 400),
343
344
        TestFile("ascend/test_ascend_tp2_bf16.py", 400),
        TestFile("ascend/test_ascend_tp2_fia_bf16.py", 400),
345
    ],
Lianmin Zheng's avatar
Lianmin Zheng committed
346
    "per-commit-4-ascend-npu": [
347
        TestFile("ascend/test_ascend_mla_w8a8int8.py", 400),
348
        TestFile("ascend/test_ascend_tp4_bf16.py", 400),
349
    ],
350
351
352
    "per-commit-16-ascend-a3": [
        TestFile("ascend/test_ascend_deepep.py", 400),
    ],
353
354
}

Lianmin Zheng's avatar
Lianmin Zheng committed
355
356
357
suites.update(suite_amd)
suites.update(suite_xeon)
suites.update(suite_ascend)
358
suites.update(suite_xpu)
Lianmin Zheng's avatar
Lianmin Zheng committed
359

Lianmin Zheng's avatar
Lianmin Zheng committed
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
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

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]

404
405
406
407
408
409

if __name__ == "__main__":
    arg_parser = argparse.ArgumentParser()
    arg_parser.add_argument(
        "--timeout-per-file",
        type=int,
410
        default=1200,
411
412
413
414
415
416
417
418
419
        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",
    )
420
421
422
423
424
425
426
427
428
429
430
431
    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
432
433
434
435
436
437
438
439
440
441
    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.",
    )
442
    args = arg_parser.parse_args()
Lianmin Zheng's avatar
Lianmin Zheng committed
443
    print(f"{args=}")
444
445
446
447
448
449

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

Lianmin Zheng's avatar
Lianmin Zheng committed
450
451
452
453
    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]
454

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

457
458
    exit_code = run_unittest_files(files, args.timeout_per_file)
    exit(exit_code)