add .dockerignore

main.py

@@ -1,16 +1,7 @@
-"""ModelHub XC 适配智能体 —— 单任务提交器
+"""ModelHub XC 适配智能体 —— 低排队算力批次（5 条）
 
-启动后向 ModelHub XC 提交 1 条模型适配验证任务，随后保持 /health 存活等待平台停止。
+每条任务分配一张低排队算力卡，并选用该卡历史通过率较高的框架。
-
+OSP 系列 max_position_embeddings=2048，配置里的 max_model_len 已由 4096 下调为 2048。
-提交内容（已查重，非重复模型）：
-  模型：https://www.modelscope.cn/models/qnguyen3/qwq-1.5b-grpo  (Qwen2 / 1.5B)
-  算力：Ascend_910-b4      框架：vllm      任务类型：text-generation
-
-平台契约：
-  - 根目录 Dockerfile，监听 8080
-  - GET /health 探活
-  - 读取平台注入的 STRATEGY_ID
-  - 正确处理 SIGTERM
 """
 import json
 import os
@@ -22,160 +13,65 @@ from http.server import BaseHTTPRequestHandler, ThreadingHTTPServer
 
 import requests
 
-# ─────────────────────────── 业务配置 ───────────────────────────
 BASE_URL = os.environ.get("BASE_URL", "https://modelhub.org.cn")
 ADD_TASK_ENDPOINT = "/api/adapt/task/add"
-
 XC_TOKEN = os.environ.get("XC_TOKEN", "6616dfe75c874e61987b1f7c908e6d77")
 STRATEGY_ID = os.environ.get("STRATEGY_ID", "")
-
-MODEL_ADDRESS = "https://www.modelscope.cn/models/qnguyen3/qwq-1.5b-grpo"
 TASK_TYPE = "text-generation"
-TARGET_GPU = "Ascend_910-b4"
-FRAMEWORK = "vllm"
 
-# 与 POST /api/adapt/task/build-config?gpuType=Ascend_910-b4&framework=vllm&taskType=text-generation 输出一致
+TASKS = [
-CONFIG_PARAMS = """framework: vllm
+    {
-api: completion
+        "label": "OSP-1.4B-100B-Muon-SSNorm-EmbProj",
-max_tokens: 1024
+        "model": "https://www.modelscope.cn/models/dmis-lab/OSP-1.4B-100B-Muon-SSNorm-EmbProj",
-temperature: 0.7
+        "gpu": "Biren_166m",
-repetition_penalty: 1.2
+        "framework": "vllm_fix_tokenizer",
-top_p: 0.9
+        "config": "framework: vllm_fix_tokenizer\nlang: en\nmax_model_len: 2048\nsut_config:\n  gpu_num: 1\n  values:\n    command:\n    - /opt/entrypoint.sh    - /model\n    - --port\n    - '80'\n    - --served-model-name\n    - llm\n    - --max-model-len\n    - '2048'\n    - --enforce-eager\n    - --trust-remote-code\n    - -tp\n    - '1'\nref_config:\n  gpu_num: 1\n  values:\n    command:\n    - /opt/entrypoint.sh    - /model\n    - --port\n    - '80'\n    - --served-model-name\n    - llm\n    - --max-model-len\n    - '2048'\n    - --enforce-eager\n    - --trust-remote-code\n    - -tp\n    - '1'"
-lang: zh
+    }
-max_model_len: 2048
+]
-sut_config:
-  gpu_num: 1
-  values:
-    command:
-    - vllm
-    - serve
-    - /model
-    - --port
-    - '8000'
-    - --served-model-name
-    - llm
-    - --max-model-len
-    - '2048'
-    - --dtype
-    - auto
-    - --gpu-memory-utilization
-    - '0.95'
-    - -tp
-    - '1'
-    - --enforce-eager
-    - --trust-remote-code
-ref_config:
-  gpu_num: 1
-  values:
-    command:
-    - vllm
-    - serve
-    - /model
-    - --port
-    - '8000'
-    - --served-model-name
-    - llm
-    - --max-model-len
-    - '2048'
-    - --dtype
-    - auto
-    - --gpu-memory-utilization
-    - '0.95'
-    - -tp
-    - '1'
-    - --enforce-eager
-    - --trust-remote-code
-"""
 
 HEADERS = {"Content-Type": "application/json", "Xc-Token": XC_TOKEN}
-
 HTTP_HOST, HTTP_PORT = "0.0.0.0", 8080
-MAX_ATTEMPTS = 5
+GAP = 4
-RETRY_GAP = 15  # 秒
-
-_state = {
-    "strategy_id": STRATEGY_ID,
-    "phase": "starting",       # starting | submitting | done | error
-    "model_address": MODEL_ADDRESS,
-    "target_gpu": TARGET_GPU,
-    "framework": FRAMEWORK,
-    "attempts": 0,
-    "attempt_log": [],
-    "task_id": None,
-    "started_at": None,
-    "finished_at": None,
-}
 _shutdown = threading.Event()
-_submitting = threading.Lock()
+_state = {"phase": "starting", "total": len(TASKS), "submitted": 0, "failed": 0, "results": []}
-_submitted = False
 
 
-def submit_task():
+def submit_one(t):
-    """提交一次；已提交过则直接返回。"""
+    body = {
-    global _submitted
+        "configParams": t["config"],
-    with _submitting:
+        "framework": t["framework"],
-        if _submitted:
+        "modelAddress": t["model"],
-            return True
+        "targetGpu": t["gpu"],
-
-    payload = {
-        "configParams": CONFIG_PARAMS,
-        "framework": FRAMEWORK,
-        "modelAddress": MODEL_ADDRESS,
-        "targetGpu": TARGET_GPU,
         "taskType": TASK_TYPE,
         "strategyId": STRATEGY_ID,
     }
+    try:
+        r = requests.post(BASE_URL + ADD_TASK_ENDPOINT, headers=HEADERS, json=body, timeout=90)
+        j = r.json()
+    except Exception as e:  # noqa: BLE001
+        j = {"code": -1, "message": "exception: %s" % e}
+    tid = (j.get("data") or {}).get("id")
+    print("[submit] %s gpu=%s fw=%s code=%s msg=%s taskId=%s"
+          % (t["label"], t["gpu"], t["framework"], j.get("code"), j.get("message"), tid), flush=True)
+    return j.get("code"), tid
 
+
+def run():
     _state["phase"] = "submitting"
-    _state["started_at"] = datetime.utcnow().isoformat()
+    for i, t in enumerate(TASKS, 1):
-
-    for i in range(1, MAX_ATTEMPTS + 1):
         if _shutdown.is_set():
             break
-        _state["attempts"] = i
+        code, tid = submit_one(t)
-        try:
+        _state["results"].append({"label": t["label"], "gpu": t["gpu"],
-            resp = requests.post(BASE_URL + ADD_TASK_ENDPOINT, headers=HEADERS,
+                                  "framework": t["framework"], "code": code, "task_id": tid})
-                                 json=payload, timeout=60)
+        _state["submitted" if code == 0 else "failed"] += 1
-            body = resp.json()
+        if i < len(TASKS):
-        except Exception as e:  # noqa: BLE001
+            time.sleep(GAP)
-            body = {"code": -1, "message": "exception: %s" % e}
+    _state["phase"] = "done"
-
+    print("[batch] 完成 submitted=%d failed=%d" % (_state["submitted"], _state["failed"]), flush=True)
-        code = body.get("code")
-        msg = body.get("message", "")
-        entry = {"attempt": i, "time": datetime.utcnow().isoformat(),
-                 "http_status": None, "code": code, "message": msg}
-        try:
-            entry["http_status"] = resp.status_code
-        except Exception:  # noqa: BLE001
-            pass
-        _state["attempt_log"].append(entry)
-        print("[submit] #%d code=%s message=%s" % (i, code, msg), flush=True)
-
-        if code == 0:
-            data = body.get("data") or {}
-            _state["task_id"] = data.get("id")
-            _state["phase"] = "done"
-            _state["finished_at"] = datetime.utcnow().isoformat()
-            _submitted = True
-            print("[submit] 提交成功 taskId=%s" % _state["task_id"], flush=True)
-            return True
-
-        # 已存在/重复等不可重试错误，直接退出
-        if code not in (-1, 60014, 50000):
-            _state["phase"] = "error"
-            _state["finished_at"] = datetime.utcnow().isoformat()
-            print("[submit] 终止：不可重试错误", flush=True)
-            return False
-
-        if i < MAX_ATTEMPTS and not _shutdown.is_set():
-            time.sleep(RETRY_GAP)
-
-    _state["phase"] = "error"
-    _state["finished_at"] = datetime.utcnow().isoformat()
-    return False
 
 
-class Handler(BaseHTTPRequestHandler):
+class H(BaseHTTPRequestHandler):
     def do_GET(self):
         if self.path == "/health":
             self._json({"status": "ok"})
@@ -184,56 +80,29 @@ class Handler(BaseHTTPRequestHandler):
         else:
             self._json({"error": "not found"}, 404)
 
-    def do_POST(self):
+    def _json(self, b, c=200):
-        if self.path == "/task":
+        raw = json.dumps(b, ensure_ascii=False, default=str).encode()
-            submit_task()
+        self.send_response(c)
-            self._json(_state)
-        else:
-            self._json({"error": "not found"}, 404)
-
-    def _json(self, body, code=200):
-        raw = json.dumps(body, ensure_ascii=False, default=str).encode()
-        self.send_response(code)
         self.send_header("Content-Type", "application/json")
         self.send_header("Content-Length", str(len(raw)))
         self.end_headers()
         self.wfile.write(raw)
 
-    def log_message(self, fmt, *args):
+    def log_message(self, *a):
-        print(self.address_string() + " - " + (fmt % args), flush=True)
+        pass
-
-
-def _handle_signal(signum, _frame):
-    print("[main] 收到信号 %s，准备退出" % signum, flush=True)
-    _shutdown.set()
 
 
 def main():
-    signal.signal(signal.SIGTERM, _handle_signal)
+    signal.signal(signal.SIGTERM, lambda *_: _shutdown.set())
-    signal.signal(signal.SIGINT, _handle_signal)
+    print("[main] strategy_id=%s tasks=%d" % (STRATEGY_ID, len(TASKS)), flush=True)
-
+    for t in TASKS:
-    print("[main] strategy_id=%s" % STRATEGY_ID, flush=True)
+        print("[main] 计划: %s @ %s / %s" % (t["label"], t["gpu"], t["framework"]), flush=True)
-    print("[main] model=%s gpu=%s framework=%s" % (MODEL_ADDRESS, TARGET_GPU, FRAMEWORK), flush=True)
+    srv = ThreadingHTTPServer((HTTP_HOST, HTTP_PORT), H)
-
+    srv.timeout = 1
-    http_thread = threading.Thread(target=_run_http, daemon=False)
+    threading.Thread(target=run, daemon=True).start()
-    http_thread.start()
-
-    worker = threading.Thread(target=submit_task, daemon=True)
-    worker.start()
-
-    _shutdown.wait()
-    print("[main] 退出", flush=True)
-
-
-def _run_http():
-    server = ThreadingHTTPServer((HTTP_HOST, HTTP_PORT), Handler)
-    server.timeout = 1
-    print("[http] 监听 %s:%d" % (HTTP_HOST, HTTP_PORT), flush=True)
     while not _shutdown.is_set():
-        server.handle_request()
+        srv.handle_request()
-    server.server_close()
+    srv.server_close()
-    print("[http] 已关闭", flush=True)
 
 
-if __name__ == "__main__":
+main()
-    main()