Permalink to 异步任务异步任务

POST /v1/images/generations        ─┐
POST /v1/images/edits               │
POST /v1/videos                     ├─► 202 { "id": "job_…", "status": "queued" }
POST /v1/audio/music               ─┘
                                        │
                     GET /v1/jobs/{job_id}          ← 轮询到终态
                                        │
                     GET /v1/jobs/{job_id}/assets   ← 签名 URL，15 分钟有效

{
  "id": "job_2f81c0a4d3b57e9016ab24cf",
  "status": "queued",
  "kind": "video",
  "model": "bytedance/seedance-2",
  "progress": 0,
  "created_at": 1787824589,
  "updated_at": 1787824589,
  "finished_at": 0,
  "dispatch_deadline_at": 1787825189,
  "error_code": "",
  "error": ""
}

queued ──► running ──► succeeded
   │           └─────► failed
   └─► queue_expired

curl https://hypit.ai/v1/jobs/job_2f81c0a4d3b57e9016ab24cf \
  -H "Authorization: Bearer $HYPIT_API_KEY"

import os, time, httpx

BASE = os.environ.get("HYPIT_BASE_URL", "https://hypit.ai/v1")
AUTH = {"Authorization": f"Bearer {os.environ['HYPIT_API_KEY']}"}
TERMINAL = {"succeeded", "failed", "queue_expired"}

def wait_for(job_id: str, timeout: float = 900.0) -> dict:
    deadline = time.monotonic() + timeout
    delay = 3.0
    while True:
        r = httpx.get(f"{BASE}/jobs/{job_id}", headers=AUTH, timeout=30)
        r.raise_for_status()
        job = r.json()
        if job["status"] in TERMINAL:
            return job
        if time.monotonic() > deadline:
            raise TimeoutError(f"{job_id} 仍处于 {job['status']}")
        time.sleep(delay)
        delay = min(delay * 1.4, 15.0)

const BASE = process.env.HYPIT_BASE_URL ?? "https://hypit.ai/v1";
const AUTH = { Authorization: `Bearer ${process.env.HYPIT_API_KEY}` };
const TERMINAL = new Set(["succeeded", "failed", "queue_expired"]);

export async function waitFor(jobId, timeoutMs = 900_000) {
  const deadline = Date.now() + timeoutMs;
  let delay = 3_000;
  for (;;) {
    const r = await fetch(`${BASE}/jobs/${jobId}`, { headers: AUTH });
    if (!r.ok) throw new Error(`${r.status} ${await r.text()}`);
    const job = await r.json();
    if (TERMINAL.has(job.status)) return job;
    if (Date.now() > deadline) throw new Error(`${jobId} 仍处于 ${job.status}`);
    await new Promise((res) => setTimeout(res, delay));
    delay = Math.min(delay * 1.4, 15_000);
  }
}

curl https://hypit.ai/v1/jobs/job_2f81c0a4d3b57e9016ab24cf/assets \
  -H "Authorization: Bearer $HYPIT_API_KEY"

{
  "items": [
    {
      "id": "ast_9c3d1e7a44b0",
      "job_id": "job_2f81c0a4d3b57e9016ab24cf",
      "ordinal": 0,
      "kind": "video",
      "storage": "s3",
      "mime_type": "video/mp4",
      "bytes": 4718592,
      "width": 1920,
      "height": 1080,
      "seconds": 6,
      "url": "https://…?X-Amz-Signature=…",
      "expires_at": 1787825489,
      "created_at": 1787825189
    }
  ]
}

job = wait_for(job_id)
if job["status"] != "succeeded":
    raise RuntimeError(f"{job['status']}: {job.get('error_code')} {job.get('error')}")

assets = httpx.get(f"{BASE}/jobs/{job_id}/assets", headers=AUTH, timeout=30).json()["items"]
for a in assets:
    with httpx.stream("GET", a["url"], timeout=None, follow_redirects=True) as src:
        src.raise_for_status()
        with open(f"out-{a['ordinal']}.{a['mime_type'].split('/')[-1]}", "wb") as f:
            for chunk in src.iter_bytes():
                f.write(chunk)

curl https://hypit.ai/v1/jobs/job_2f81c0a4d3b57e9016ab24cf/assets \
  -H "Authorization: Bearer $HYPIT_API_KEY"

curl https://hypit.ai/v1/videos \
  -H "Authorization: Bearer $HYPIT_API_KEY" \
  -H "Idempotency-Key: order-4471-clip-1" \
  -H "Content-Type: application/json" \
  -d '{"model": "bytedance/seedance-2", "prompt": "水沟里漂着一只纸船", "seconds": 5}'

{
  "error": {
    "message": "too many queued or running media Jobs for this account; retry after one finishes",
    "type": "rate_limit_error",
    "code": "media_open_job_capacity",
    "param": null
  }
}