18 Commits

Author SHA1 Message Date
efee86e49c submit 24 models on zhoushasha: ppu_zw_810e(18)/hygon_k100-ai(4)/MetaX_c-500(1)/Biren_166m(1)
Candidate pool is the 24711 already-downloaded models, which satisfies
mechanism A's precondition that the model be present in platform storage.

Strict and relaxed condition-2 give identical results this round: of the 24007
pooled models with verify records, 24006 already have 已验证 on some card, so
relaxing to include 验证中 adds just one. The binding constraint is now how few
models lack a record on each card - Kunlunxin_p-800, Cambricon_mlu-370-x8 and
Iluvatar_bi-150 are all at zero and are left out of GPU_JOBS.

Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>
2026-09-20 18:27:33 +08:00
793c49aea3 submit round-24 filter results on zhoushasha: MetaX_c-500(63)/Kunlunxin_p-800(1)/Cambricon_mlu-370-x8(1)/Biren_166m(95) + ppu_zw_810e(57), 217 models total
Also add a hygon_k100-ai config branch and HYGON_MODELS list (kept available but
excluded from GPU_JOBS per request). Refresh the expired AUTH_TOKEN.

Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>
2026-09-15 17:25:35 +08:00
d5f576fac7 submit MetaX_c-500(7) + Biren_166m(95) non-quantized models; refresh AUTH_TOKEN 2026-08-31 15:18:39 +08:00
965783957e add self-looping quota retry: retry quota-blocked models every 30min in-process, no redeploy needed 2026-08-19 13:59:54 +08:00
cd5c7a2435 submit entire remaining ppu_zw_810e candidate pool (5424 models); run to natural quota exhaustion 2026-08-19 11:19:18 +08:00
cdbacf5a46 submit next batch of ppu_zw_810e (200 models) 2026-08-19 01:15:33 +08:00
5bfc0fc53e submit next batch of ppu_zw_810e (200 models) 2026-08-19 01:07:58 +08:00
606655b876 submit entire remaining ppu_zw_810e candidate pool (6220 models); run to natural quota exhaustion 2026-08-18 15:55:51 +08:00
eee9e5813c submit next batch of ppu_zw_810e (250 models, matches remaining ~2000-slot quota headroom) 2026-08-18 15:43:55 +08:00
32122cd866 submit next batch of ppu_zw_810e (360 models, supersedes stuck v1.0.28 build) 2026-08-18 15:34:19 +08:00
ebc9f400e0 submit next batch of ppu_zw_810e (250 models); refresh AUTH_TOKEN 2026-08-18 11:13:33 +08:00
b546ad980f submit next batch of ppu_zw_810e (300 models) 2026-08-13 16:56:17 +08:00
54adf4f956 submit next batch of ppu_zw_810e (200 models) 2026-08-11 14:30:02 +08:00
66f378bdc0 submit next batch of ppu_zw_810e (200 models); refresh AUTH_TOKEN 2026-08-10 17:07:48 +08:00
d49bf186ae submit next batch of ppu_zw_810e (200 models) 2026-08-07 11:23:46 +08:00
1b95e92f72 add next batch of ppu_zw_810e submission (500 models, lines 601-1100 of source list) 2026-08-06 13:06:23 +08:00
dd9db6b4d2 add ppu_zw_810e submission (600 models), refresh AUTH_TOKEN; skip other 4 GPUs this run 2026-08-04 20:54:10 +08:00
5c9f5d9ad7 refresh all 4 GPU model lists with latest filter results 2026-07-29 17:36:02 +08:00

339
main.py
View File

@@ -1,10 +1,19 @@
"""
xc_validation_strategy — 主入口
启动后针对 4 张 GPU 卡Biren_166m / Cambricon_mlu-370-x8 / MetaX_c-500 /
Kunlunxin_p-800分别批量提交各自筛选出的模型验证任务/adminApi/async/task/create-contest-task
启动后针对 GPU_JOBS 中配置的 GPU 卡分别批量提交各自筛选出的模型验证任务
(当前仅提交 ppu_zw_810e其余 4 张卡 Biren_166m/Cambricon_mlu-370-x8/MetaX_c-500/
Kunlunxin_p-800 的 config_content 模板和模型列表仍保留在代码中,未列入本次 GPU_JOBS
/adminApi/async/task/create-contest-task
Bearer Token 认证),之后保持 HTTP 服务存活。
同时暴露 /healthK8s 探活)和 /status运行状态
账号额度自动重试:如果某个模型提交时命中"当前等待中或运行中的异步模型验证
任务数量已达上限"(账号额度已满),不算永久失败,会被留到下一轮;额度耗尽后
本进程会原地等待 30 分钟,再自动重试所有因额度问题未提交成功的模型,如此循环,
直至全部提交成功或进程被平台关闭——不需要重新部署新策略,循环逻辑在本进程内完成。
非额度原因的失败(如模型已在验证中等)不会重试。
同时暴露 /healthK8s 探活)和 /status运行状态含当前轮次/待重试数/下次重试时间)。
"""
import json
@@ -24,7 +33,7 @@ BASE_URL = os.environ.get("BASE_URL", "https://modelhub.org.cn")
SUBMIT_ENDPOINT = "/adminApi/async/task/create-contest-task"
# 通过 curl -X POST https://modelhub.org.cn/adminApi/user/login 获取后填入
AUTH_TOKEN = "eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJ1c2VyQWNjb3VudCI6Inpob3VzaGFzaGEiLCJpZCI6MTQsInVzZXJSb2xlIjoibGVhZGVyYm9hcmQiLCJleHAiOjE3ODU3NDY3NTMsImlhdCI6MTc4NTE0MTk1M30.KwUuefNAFSNwq3_Pnaw2nef8ZC6WgsECQ_LMeQnKk2c"
AUTH_TOKEN = "eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJ1c2VyQWNjb3VudCI6Inpob3VzaGFzaGEiLCJpZCI6MTQsInVzZXJSb2xlIjoibGVhZGVyYm9hcmQiLCJleHAiOjE3OTAwNjkxMjAsImlhdCI6MTc4OTQ2NDMyMH0.KzJac6ddaZdtLvjD6ZnoK1PNEKFoXdyDn9Hh4FxU9ic"
CONTEST_API_TOKEN = "ef1ef82f3c9efee413d602345fbe224d"
CONTRIBUTORS = "zhoushasha"
TASK_TYPE = "text-generation"
@@ -37,124 +46,61 @@ HTTP_PORT = 8080
# 各 GPU 的模型列表(来自 filter_verified_models 脚本的筛选结果)
# ══════════════════════════════════════════════════════════
BIREN_MODELS = [
"BigRatz/LOL-AI-2026",
"aimeri/spoomplesmaxx-cardmaker-v1",
"Alibaba-DT/Logics-STEM-8B-SFT",
"Muneebmn123/insurance-voice-qwen25-1_5b",
"AnkitBirGurung/NEMO-12B-SFT-Further",
"danilarudenko/editorai-mini",
"EphemeralYou/Prompt-Refine-MiniCPM5-1B",
"mtepe01/mentorx-mistral-7b-automata-merged",
"DarkArtsForge/Helix-SCE-12B-jh",
"rpant/iolai26-solve",
"NithinAI12/NithinX-Omni-LLM-v1",
"ConvexAI/Luminex-34B-v0.2",
"codellama/CodeLlama-34b-hf",
"Lipas007/iol-ai-2026-qwen14b-awq",
"D-Z-W/finetuned-teacher",
"huan1999/ziya-llama-13b-medical-merged",
"codellama/CodeLlama-34b-Python-hf",
"ld4ad/gemma-2-9b-dunhuang",
"harindhar10/Olmo-7b_1M_Smiles_lora",
"allenai/Olmo-3-7B-Think-DPO",
"allenai/Olmo-3-32B-Think-DPO",
"RedHatAI/gemma-2-9b-it",
"prashanthsura/gemma-2-2b-legal-financial-sft",
"pfnet/plamo-2-8b",
"sail/Sailor2-20B-128K-SFT",
"facebook/layerskip-llama3.2-1B",
"Qwen/Qwen2.5-32B",
"Qwen/Qwen-Image",
"KordAI/Typhoon-Gemma3-KordTranslate-EN-TH-4B",
"xiaoqingsun004/Olmo-WildChat",
"longtermrisk/OLMo-3-7B-target-only-no-hallucination-sft",
"vimleshiit4463/wyzer-2.0-smollm2-135m",
"trl-lib/pythia-1b-deduped-tldr-sft",
"zipaltrivedi/dotnet-coder-14b",
]
CAMBRICON_MODELS = [
"clear-blue-sky/evolai-reborn-tfm-008",
"clear-blue-sky/evolai-reborn-tfm-010",
"BigRatz/LOL-AI-2026",
"clear-blue-sky/evolai-reborn-tfm-001",
"clear-blue-sky/evolai-reborn-tfm-019",
"clear-blue-sky/evolai-reborn-tfm-007",
"aimeri/spoomplesmaxx-cardmaker-v1",
"aipatseer/inst_ft_qwen_0.6b_summ",
"clear-blue-sky/evolai-reborn-tfm-003",
"clear-blue-sky/evolai-reborn-tfm-004",
"Alibaba-DT/Logics-STEM-8B-SFT",
"clear-blue-sky/evolai-reborn-tfm-002",
"prism-ml/Ternary-Bonsai-4B-unpacked",
"Muneebmn123/insurance-voice-qwen25-1_5b",
"AnkitBirGurung/NEMO-12B-SFT-Further",
"danilarudenko/editorai-mini",
"rpant/iolai26-solve",
]
METAX_MODELS = [
"Phoenix9781/evolai-tf-model-105",
"clear-blue-sky/evolai-reborn-tfm-008",
"clear-blue-sky/evolai-reborn-tfm-010",
"BigRatz/LOL-AI-2026",
"clear-blue-sky/evolai-reborn-tfm-001",
"clear-blue-sky/evolai-reborn-tfm-019",
"clear-blue-sky/evolai-reborn-tfm-007",
"clear-blue-sky/evolai-reborn-tfm-005",
"Lin2es/evolai-tfm-03o",
"clear-blue-sky/evolai-reborn-tfm-009",
"aimeri/spoomplesmaxx-cardmaker-v1",
"aipatseer/inst_ft_qwen_0.6b_summ",
"reaperdoesntknow/DualMind-TKD-Agentic-1.7B",
"clear-blue-sky/evolai-reborn-tfm-011",
"clear-blue-sky/evolai-reborn-tfm-003",
"clear-blue-sky/evolai-reborn-tfm-004",
"clear-blue-sky/evolai-reborn-tfm-002",
"amd/ReasonLite-0.6B",
"prism-ml/Ternary-Bonsai-4B-unpacked",
"Muneebmn123/insurance-voice-qwen25-1_5b",
"danilarudenko/editorai-mini",
"rpant/iolai26-solve",
"zipaltrivedi/dotnet-coder-14b",
]
HYGON_MODELS = [
"zipaltrivedi/dotnet-coder-14b",
"cds-jb/qwen3-14b-butterfly-subliminal-fullft",
"lllqaq/Qwen2.5-Coder-14B-Instruct-num11-v1-v2-v3-pairs-v3-triples-post-r2egym",
"deepmako/Mako-32B-Conductor",
]
KUNLUNXIN_MODELS = [
"Patriae/patriae-cuban-dialect-model",
"Phoenix9781/evolai-tf-model-105",
"clear-blue-sky/evolai-reborn-tfm-008",
"clear-blue-sky/evolai-reborn-tfm-010",
"clear-blue-sky/evolai-reborn-tfm-001",
"clear-blue-sky/evolai-reborn-tfm-019",
"clear-blue-sky/evolai-reborn-tfm-007",
"clear-blue-sky/evolai-reborn-tfm-005",
"Lin2es/evolai-tfm-03o",
"clear-blue-sky/evolai-reborn-tfm-009",
"aimeri/spoomplesmaxx-cardmaker-v1",
"aipatseer/inst_ft_qwen_0.6b_summ",
"clear-blue-sky/evolai-reborn-tfm-011",
"clear-blue-sky/evolai-reborn-tfm-003",
"clear-blue-sky/evolai-reborn-tfm-004",
"clear-blue-sky/evolai-reborn-tfm-002",
"amd/ReasonLite-0.6B",
"prism-ml/Ternary-Bonsai-4B-unpacked",
"EthanGao123/CellHermes-v1.0",
"RecursiveMAS/Mixture-Science-BioMistral-7B",
"chenyitian-shanshu/SIRL-Gurobi",
"RedHatAI/gemma-2-9b-it",
"gaunernst/gemma-3-27b-it-qat-autoawq",
"promotion/qwen3-8b-simpo-avg-b2p5-g1p0-s42",
"llamaindex/vdr-2b-multi-v1",
"KordAI/Typhoon-Gemma3-KordTranslate-EN-TH-4B",
"TheDrummer/UnslopNemo-12B-v3",
"gradients-io-tournaments/tournament-tourn_c5d86c82ce819a79_20260706-b78a01d4-0a6a-49e1-9190-5e88ae329937-5DS6XMVr",
"ArliAI/Mistral-Nemo-12B-ArliAI-RPMax-v1.1",
]
# 按顺序处理Biren → Cambricon → MetaX → Kunlunxin
PPU_MODELS = [
"fpadovani/eng-latn-100mb-after-ppt-Dp-10mb-ckpt500_seed10",
"fpadovani/ita-latn-10mb-after-ppt-Dp-100mb-ckpt500_seed3407",
"fpadovani/ita-latn-10mb-after-ppt-Dp-10mb-ckpt500_seed3407",
"richardr1126/spider-skeleton-wizard-coder-merged",
"fpadovani/dan-latn-10mb-after-ppt-shuff-dyck-10mb-ckpt500_seed3407",
"fpadovani/ita-latn-10mb-after-ppt-shuff-dyck-100mb-ckpt500_seed3407",
"omerkaragulmez/XbyK-0.1",
"fpadovani/eng-latn-10mb-after-ppt-Dp-10mb-ckpt500_seed10",
"fpadovani/eng-latn-10mb-100mb_seed10",
"flax-community/gpt2-medium-indonesian",
"RedHatAI/QwQ-32B-Preview-quantized.w8a8",
"fractalego/fact-checking",
"KoboldAI/GPT-J-6B-Adventure",
"EasierAI/Falcon-3-1B",
"theprint/mistral-7b-cthulhu",
"iwalton3/phoenix",
"renzhenzhen/internLM2-for-triples",
"u2mithrandir/epsi_tmall",
]
# 本轮提交ppu_zw_810e(18) / hygon_k100-ai(4) / MetaX_c-500(1) / Biren_166m(1)共24个。
#
# 候选池是 api_verify_model_download_status_a.txt 里那 24711 个【已下载】的模型,
# 正好满足机制A「模型必须已下载到平台存储」的前提v1.0.37 那次157个失败就是因为没下载
#
# 本轮严格口径与放宽口径别的卡「已验证」vs「已验证或验证中」结果完全相同
# 这批已下载模型里 24007 个有验证记录的24006 个都已至少一张卡「已验证」,
# 放宽只多捞出 1 个;真正的瓶颈是各卡「无记录」的模型太少——
# Kunlunxin_p-800 / Cambricon_mlu-370-x8 / Iluvatar_bi-150 均为 0故不列入 GPU_JOBS。
GPU_JOBS: List[Tuple[str, List[str]]] = [
("Biren_166m", BIREN_MODELS),
("Cambricon_mlu-370-x8", CAMBRICON_MODELS),
("ppu_zw_810e", PPU_MODELS),
("hygon_k100-ai", HYGON_MODELS),
("MetaX_c-500", METAX_MODELS),
("Kunlunxin_p-800", KUNLUNXIN_MODELS),
("Biren_166m", BIREN_MODELS),
]
TOTAL_MODELS = sum(len(models) for _, models in GPU_JOBS)
@@ -163,13 +109,16 @@ TOTAL_MODELS = sum(len(models) for _, models in GPU_JOBS)
# ══════════════════════════════════════════════════════════
_state = {
"strategy_id": STRATEGY_ID,
"phase": "starting", # starting | submitting | done | error
"phase": "starting", # starting | submitting | waiting_retry | done | error
"total": TOTAL_MODELS,
"submitted": 0,
"failed": 0,
"per_gpu": {gpu: 0 for gpu, _ in GPU_JOBS},
"started_at": None,
"finished_at": None,
"round": 0, # 当前是第几轮提交
"quota_blocked_remaining": 0, # 因额度上限暂未提交成功、等待下一轮重试的模型数
"next_retry_at": None, # 下一轮重试的预计时间(额度耗尽等待期间)
}
_shutdown = threading.Event()
@@ -306,6 +255,96 @@ ref_config:
values:
command: [vllm, serve, /model, --port, '80', --served-model-name, llm, --max-model-len, '4096', --enforce-eager, --trust-remote-code, -tp, '1']
"""
elif gpu_type == "hygon_k100-ai":
return f"""
docker_image: harbor.4pd.io/modelhubxc/enginex-hygon/vllm:0.9.2-patch-tokenizer
nv_docker_image: harbor.4pd.io/modelhubxc/enginex-nvidia/vllm:0.11.0-patch-tokenizer
framework: vllm
storage: gpfs
max_model_len: 4096
sut_config:
gpu_num: 1
values:
command: ['vllm', 'serve', '/model', '--port', '20644', '--served-model-name', 'llm', '--max-model-len', '4096', '--enforce-eager', '--trust-remote-code' ,'-tp', '1' ]
ref_config:
gpu_num: 1
values:
command: ['vllm', 'serve', '/model', '--port', '80', '--served-model-name', 'llm', '--max-model-len', '4096', '--enforce-eager', '--trust-remote-code', '-tp', '1']
"""
elif gpu_type == "ppu_zw_810e":
return f"""gpu_type: ppu_zw_810e
framework: vllm
docker_image: harbor.4pd.io/hardcore-tech/asllm:1.10.1-pytorch2.10.0-ubuntu24.04-sail2.1.0-cuda13.0-sglang0.5.10-vllm0.19.0-py312
nv_docker_image: harbor-contest.4pd.io/sunruoxi/vllm-openai-fix-tokenizer:v0.11.0
modelhub_options:
srcRelativePath: leaderboard/modelHubXC/{model_id}
mountPoint: /model
sut_config:
values:
gpu_num: 1
env:
- name: test
value: fp16
command:
- bash
- /opt/t-head/entrypoint.sh
- python3
- -m
- asllm.entrypoints.api_server
- --model
- /model
- --port
- '30000'
- --host
- 0.0.0.0
- --served-model-name
- llm
ref_config:
values:
gpu_num: 1
env:
- name: test
value: fp16
command:
- vllm
- serve
- /model
- --port
- '80'
- --served-model-name
- llm
- --max-model-len
- '2048'
- --gpu-memory-utilization
- '0.9'
- --enforce-eager
- --trust-remote-code
- -tp
- '1'
"""
elif gpu_type == "Iluvatar_bi-150":
return f"""docker_image: harbor-contest.4pd.io/luopingyi/enginex-iluvatar-bi150/vllm:0.8.3
nv_docker_image: harbor.4pd.io/dooke/vllm/vllm/vllm-openai:v0.11.0
framework: vllm
api: completion
temperature: 0.7
repetition_penalty: 1.2
top_p: 0.9
max_model_len: 4096
max_tokens: 1024
sut_config:
gpu_num: 1
values:
command: ['vllm', 'serve', '/model', '--port', '80', '--served-model-name', 'llm', '--max-model-len', '4096', '--gpu-memory-utilization', '0.9', '--enforce-eager', '--trust-remote-code' ,'-tp', '1']
ref_config:
gpu_num: 1
values:
command: ['vllm', 'serve', '/model', '--port', '80', '--served-model-name', 'llm', '--max-model-len', '4096', '--enforce-eager', '--trust-remote-code', '-tp', '1']
"""
else:
raise ValueError(f"未知的 GPU_TYPE: {gpu_type}")
@@ -316,7 +355,14 @@ ref_config:
# ══════════════════════════════════════════════════════════
# 业务逻辑
# ══════════════════════════════════════════════════════════
def _submit_task(token: str, gpu_type: str, model_id: str) -> Tuple[bool, str]:
# 账号"等待中/运行中"任务数已达上限时平台返回的业务错误信息(子串匹配);
# 命中这个的模型不算永久失败,会在额度腾出空位后自动重试,不会被记作 failed
QUOTA_FULL_MSG = "当前等待中或运行中的异步模型验证任务数量已达上限"
# 额度耗尽后,隔多久自动重试一次剩余(因额度问题未提交成功)的模型
RETRY_INTERVAL_SECONDS = 30 * 60 # 30 分钟
def _submit_task(token: str, gpu_type: str, model_id: str) -> Tuple[bool, str, str]:
headers = {
"Content-Type": "application/json",
"Authorization": f"Bearer {token}",
@@ -349,13 +395,14 @@ def _submit_task(token: str, gpu_type: str, model_id: str) -> Tuple[bool, str]:
if result.get("code") == 0:
task_id = result.get("data", {}).get("id", "")
print(f"[worker] OK {model_id} (GPU={gpu_type}) task_id={task_id}", flush=True)
return True, task_id
return True, task_id, ""
else:
print(f"[worker] FAIL {model_id} (GPU={gpu_type}): {result.get('message')}", flush=True)
return False, ""
message = result.get("message") or ""
print(f"[worker] FAIL {model_id} (GPU={gpu_type}): {message}", flush=True)
return False, "", message
except Exception as e:
print(f"[worker] ERROR {model_id} (GPU={gpu_type}): {e}", flush=True)
return False, ""
return False, "", str(e)
def _run_worker():
@@ -366,35 +413,69 @@ def _run_worker():
token = AUTH_TOKEN
print("[worker] 使用预设 Token跳过登录", flush=True)
for gpu_type, model_list in GPU_JOBS:
if _shutdown.is_set():
break
print(f"\n{'='*60}\n🚀 开始处理 GPU={gpu_type},共 {len(model_list)} 个模型\n{'='*60}", flush=True)
# 待提交队列:保持 GPU_JOBS 里原有的 (gpu_type, model_id) 顺序
pending: List[Tuple[str, str]] = [
(gpu_type, model_id)
for gpu_type, model_list in GPU_JOBS
for model_id in model_list
]
for model_id in model_list:
round_num = 0
while pending and not _shutdown.is_set():
round_num += 1
_state["round"] = round_num
_state["phase"] = "submitting"
_state["next_retry_at"] = None
print(
f"\n{'='*60}\n🚀 第 {round_num} 轮,待提交 {len(pending)} 个模型\n{'='*60}",
flush=True,
)
quota_blocked: List[Tuple[str, str]] = []
for gpu_type, model_id in pending:
if _shutdown.is_set():
break
ok, task_id = _submit_task(token, gpu_type, model_id)
ok, task_id, message = _submit_task(token, gpu_type, model_id)
if ok:
_state["submitted"] += 1
_state["per_gpu"][gpu_type] += 1
successful.append((task_id, gpu_type, model_id))
elif QUOTA_FULL_MSG in message:
# 账号额度暂时满了,不算永久失败,留到下一轮重试
quota_blocked.append((gpu_type, model_id))
else:
# 非额度原因失败(如重复提交等),不再重试
_state["failed"] += 1
# 写入结果文件
try:
with open("submitted_validation_tasks.txt", "w", encoding="utf-8") as f:
for tid, gpu, mid in successful:
f.write(f"{tid}\t{gpu}\t{mid}\n")
except Exception:
pass
pending = quota_blocked
_state["quota_blocked_remaining"] = len(pending)
# 每轮结束都把已成功的结果落盘一次,避免中途重启丢失记录
try:
with open("submitted_validation_tasks.txt", "w", encoding="utf-8") as f:
for tid, gpu, mid in successful:
f.write(f"{tid}\t{gpu}\t{mid}\n")
except Exception:
pass
if pending and not _shutdown.is_set():
next_retry = datetime.utcnow().timestamp() + RETRY_INTERVAL_SECONDS
_state["next_retry_at"] = datetime.utcfromtimestamp(next_retry).isoformat()
_state["phase"] = "waiting_retry"
print(
f"[worker] 第 {round_num} 轮结束:{len(pending)} 个模型因账号额度上限暂未提交,"
f"{RETRY_INTERVAL_SECONDS // 60} 分钟后自动重试(不部署新策略,本进程内循环)...",
flush=True,
)
_shutdown.wait(RETRY_INTERVAL_SECONDS)
_state["finished_at"] = datetime.utcnow().isoformat()
_state["phase"] = "done"
_state["quota_blocked_remaining"] = len(pending)
print(
f"[worker] 完成 submitted={_state['submitted']} failed={_state['failed']} "
f"total={_state['total']} per_gpu={_state['per_gpu']}",
f"total={_state['total']} per_gpu={_state['per_gpu']} "
f"仍因额度未提交(如遇shutdown中断)={len(pending)}",
flush=True,
)
# 提交完成后继续保持进程存活,等待平台停止