Compare commits
3 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
5bb32e6bdb | ||
|
|
75ba3bb301 | ||
|
|
e28f2e3eca |
62
main.py
62
main.py
@@ -31,7 +31,7 @@ PORT = 8080
|
|||||||
STRATEGY_ID = os.getenv("STRATEGY_ID", "")
|
STRATEGY_ID = os.getenv("STRATEGY_ID", "")
|
||||||
|
|
||||||
# 目标GPU
|
# 目标GPU
|
||||||
TARGET_GPU = "Iluvatar_bi-150"
|
TARGET_GPU = "Iluvatar_bi-100"
|
||||||
|
|
||||||
# 账号Token
|
# 账号Token
|
||||||
TARGET_TOKEN = "f45f1aae2c094426be237c88b1085015"
|
TARGET_TOKEN = "f45f1aae2c094426be237c88b1085015"
|
||||||
@@ -47,7 +47,7 @@ SUPPORTED_SPECIAL_ARCHS = ['Eagle3Speculator', 'LlamaForCausalLMEagle3']
|
|||||||
MODELHUB_API = "https://modelhub.org.cn/api"
|
MODELHUB_API = "https://modelhub.org.cn/api"
|
||||||
|
|
||||||
# 搜索关键词
|
# 搜索关键词
|
||||||
SEARCH_KEYWORDS = ['qwen', 'Qwen2', 'Qwen3', 'Qwen3.5', 'Qwen1.5', 'Qwen-']
|
SEARCH_KEYWORDS = ['qwen', 'Qwen2', 'Qwen3', 'Qwen3.5', 'Llama-3', 'Llama-3.1', 'Mistral', 'DeepSeek']
|
||||||
|
|
||||||
# ============================================================
|
# ============================================================
|
||||||
# 全局状态
|
# 全局状态
|
||||||
@@ -254,25 +254,26 @@ def check_queue_available() -> int:
|
|||||||
|
|
||||||
|
|
||||||
def build_config_params() -> str:
|
def build_config_params() -> str:
|
||||||
"""构建 YAML 配置 - 完全匹配平台自动生成的格式(只支持vllm)"""
|
"""构建 YAML 配置 - llama.cpp (支持 GGUF)"""
|
||||||
params = {
|
params = {
|
||||||
'framework': 'vllm',
|
'framework': 'llama.cpp',
|
||||||
'nv_framework': 'vllm',
|
'nv_framework': 'llama.cpp',
|
||||||
'api': 'completion',
|
'api': 'completion',
|
||||||
'max_tokens': 1024,
|
'max_tokens': 1024,
|
||||||
'temperature': 0.7,
|
'temperature': 0.7,
|
||||||
'repetition_penalty': 1.2,
|
'repetition_penalty': 1.2,
|
||||||
'top_p': 0.9,
|
'top_p': 0.9,
|
||||||
'lang': 'zh',
|
'lang': 'zh',
|
||||||
'max_model_len': 2048,
|
'max_model_len': 4096,
|
||||||
'sut_config': {
|
'sut_config': {
|
||||||
'gpu_num': 1,
|
'gpu_num': 1,
|
||||||
'values': {
|
'values': {
|
||||||
'command': [
|
'command': [
|
||||||
'vllm', 'serve', '/model', '--port', '8000',
|
'llama-server', '--model', '/model', '--alias', 'llm',
|
||||||
'--served-model-name', 'llm', '--max-model-len', '2048',
|
'--threads', '20', '--n-gpu-layers', '999', '--prio', '3',
|
||||||
'--dtype', 'auto', '--gpu-memory-utilization', '0.95',
|
'--min_p', '0.01', '--ctx-size', '4096',
|
||||||
'-tp', '1', '--enforce-eager', '--trust-remote-code',
|
'--host', '0.0.0.0', '--port', '8000',
|
||||||
|
'--jinja', '--flash-attn', 'off',
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
@@ -280,9 +281,9 @@ def build_config_params() -> str:
|
|||||||
'gpu_num': 1,
|
'gpu_num': 1,
|
||||||
'values': {
|
'values': {
|
||||||
'command': [
|
'command': [
|
||||||
'vllm', 'serve', '/model', '--port', '80',
|
'llama-server', '--model', '/model', '--alias', 'llm',
|
||||||
'--served-model-name', 'llm', '--max-model-len', '4096',
|
'--threads', '20', '--n-gpu-layers', '999',
|
||||||
'--enforce-eager', '--trust-remote-code', '-tp', '1',
|
'--ctx-size', '4096', '--host', '0.0.0.0', '--port', '8000',
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
@@ -302,7 +303,7 @@ def submit_model(model_url: str) -> tuple:
|
|||||||
'modelAddress': normalize_model_url(model_url),
|
'modelAddress': normalize_model_url(model_url),
|
||||||
'taskType': 'text-generation',
|
'taskType': 'text-generation',
|
||||||
'targetGpu': TARGET_GPU,
|
'targetGpu': TARGET_GPU,
|
||||||
'framework': 'vllm',
|
'framework': 'llama.cpp',
|
||||||
'strategyId': STRATEGY_ID,
|
'strategyId': STRATEGY_ID,
|
||||||
'configParams': build_config_params(),
|
'configParams': build_config_params(),
|
||||||
}
|
}
|
||||||
@@ -347,11 +348,11 @@ def run_pipeline(submit_limit: int = 2):
|
|||||||
time.sleep(0.3)
|
time.sleep(0.3)
|
||||||
log(f"搜索完成: {len(seen)} 个唯一模型, {len(all_models)} 个下载量{DOWNLOAD_MIN}-{DOWNLOAD_MAX}")
|
log(f"搜索完成: {len(seen)} 个唯一模型, {len(all_models)} 个下载量{DOWNLOAD_MIN}-{DOWNLOAD_MAX}")
|
||||||
|
|
||||||
# 2. 格式筛选(排除 GGUF/GPTQ/AWQ)
|
# 2. 格式筛选(排除 GPTQ/AWQ,保留 GGUF 和 HuggingFace)
|
||||||
log("\n--- 阶段2: 格式筛选 ---")
|
log("\n--- 阶段2: 格式筛选 ---")
|
||||||
hf_models = []
|
hf_models = []
|
||||||
format_skipped = 0
|
format_skipped = 0
|
||||||
SKIP_FORMATS = ['GGUF', 'GPTQ', 'AWQ']
|
SKIP_FORMATS = ['GPTQ', 'AWQ']
|
||||||
for m in all_models:
|
for m in all_models:
|
||||||
mid_upper = m['model_id'].upper()
|
mid_upper = m['model_id'].upper()
|
||||||
skip = False
|
skip = False
|
||||||
@@ -363,27 +364,16 @@ def run_pipeline(submit_limit: int = 2):
|
|||||||
break
|
break
|
||||||
if not skip:
|
if not skip:
|
||||||
hf_models.append(m)
|
hf_models.append(m)
|
||||||
log(f"格式筛选: {len(hf_models)} 通过, {format_skipped} 跳过 (GGUF/GPTQ/AWQ)")
|
log(f"格式筛选: {len(hf_models)} 通过, {format_skipped} 跳过 (GPTQ/AWQ)")
|
||||||
|
|
||||||
# 3. 架构筛选(排除 Qwen3.5 在 Iluvatar 上不支持)
|
# 3. 架构筛选(参考检查,不做严格过滤,让平台决定兼容性)
|
||||||
log("\n--- 阶段3: 架构筛选 ---")
|
log("\n--- 阶段3: 架构检查 ---")
|
||||||
arch_passed = []
|
|
||||||
arch_rejected = 0
|
|
||||||
SKIP_ARCHS = ['qwen3_5', 'Qwen3_5', 'Qwen3.5']
|
|
||||||
for m in hf_models:
|
for m in hf_models:
|
||||||
ok, reason = check_architecture(m['model_id'])
|
ok, reason = check_architecture(m['model_id'])
|
||||||
if not ok:
|
if not ok:
|
||||||
arch_rejected += 1
|
log(f" ! {m['model_id']}: {reason} (仍保留)")
|
||||||
log(f" x {m['model_id']}: {reason}")
|
time.sleep(0.1)
|
||||||
continue
|
log(f"架构检查: {len(hf_models)} 个模型进入下一阶段")
|
||||||
arch_str = str(reason).upper()
|
|
||||||
if any(a.upper() in arch_str for a in SKIP_ARCHS):
|
|
||||||
arch_rejected += 1
|
|
||||||
log(f" x {m['model_id']}: Qwen3.5(Iluvatar不支持)")
|
|
||||||
continue
|
|
||||||
arch_passed.append(m)
|
|
||||||
time.sleep(0.15)
|
|
||||||
log(f"架构筛选: {len(arch_passed)} 通过, {arch_rejected} 拒绝")
|
|
||||||
|
|
||||||
# 4. 筛选并提交(只针对目标GPU)
|
# 4. 筛选并提交(只针对目标GPU)
|
||||||
log(f"\n--- 阶段4: 筛选并提交 [{TARGET_GPU}] ---")
|
log(f"\n--- 阶段4: 筛选并提交 [{TARGET_GPU}] ---")
|
||||||
@@ -397,7 +387,7 @@ def run_pipeline(submit_limit: int = 2):
|
|||||||
|
|
||||||
# 筛选
|
# 筛选
|
||||||
to_submit = []
|
to_submit = []
|
||||||
for m in arch_passed:
|
for m in hf_models:
|
||||||
model_id = m['model_id']
|
model_id = m['model_id']
|
||||||
|
|
||||||
# 检查全平台验证状态
|
# 检查全平台验证状态
|
||||||
@@ -577,7 +567,7 @@ class AgentHandler(BaseHTTPRequestHandler):
|
|||||||
'modelAddress': 'https://www.modelscope.cn/models/Qwen/Qwen3-8B',
|
'modelAddress': 'https://www.modelscope.cn/models/Qwen/Qwen3-8B',
|
||||||
'taskType': 'text-generation',
|
'taskType': 'text-generation',
|
||||||
'targetGpu': TARGET_GPU,
|
'targetGpu': TARGET_GPU,
|
||||||
'framework': 'vllm',
|
'framework': 'llama.cpp',
|
||||||
'strategyId': STRATEGY_ID,
|
'strategyId': STRATEGY_ID,
|
||||||
'configParams': build_config_params(),
|
'configParams': build_config_params(),
|
||||||
},
|
},
|
||||||
@@ -695,7 +685,7 @@ def main():
|
|||||||
json={
|
json={
|
||||||
'modelAddress': 'https://www.modelscope.cn/models/Qwen/Qwen3-8B',
|
'modelAddress': 'https://www.modelscope.cn/models/Qwen/Qwen3-8B',
|
||||||
'taskType': 'text-generation', 'targetGpu': TARGET_GPU,
|
'taskType': 'text-generation', 'targetGpu': TARGET_GPU,
|
||||||
'framework': 'vllm', 'strategyId': STRATEGY_ID,
|
'framework': 'llama.cpp', 'strategyId': STRATEGY_ID,
|
||||||
'configParams': build_config_params(),
|
'configParams': build_config_params(),
|
||||||
}, timeout=10
|
}, timeout=10
|
||||||
)
|
)
|
||||||
|
|||||||
Reference in New Issue
Block a user