Comfy SDKs

pip install comfy-sdk

npm i @comfyorg/sdk

from comfy_sdk import Comfy

# Comfy Cloud
client = Comfy(api_key="comfyui-...")

wf = client.workflows.from_file("workflow_api.json")

asset = client.assets.from_file("photo.png")
wf.set_input("10", "image", asset)

job = client.run(wf)
for output in job.get_outputs("9"):
    output.to_file(output.name)

import { Comfy } from "@comfyorg/sdk";

// Comfy Cloud
const client = new Comfy({ apiKey: "comfyui-..." });

const wf = await client.workflows.fromFile("workflow_api.json");

const asset = client.assets.fromFile("photo.png");
wf.setInput("10", "image", asset);

const job = await client.run(wf);
await job.getOutputs("9")[0].toFile("out.png");

client = Comfy(api_key="comfyui-...")

const client = new Comfy({ apiKey: "comfyui-..." });

import uuid
from comfy_sdk import IdempotencyKeyReuse

# 두 값 모두 요청이 당신에게 의미하는 바를 기준으로 당신의 저장소에 보관합니다.
# `key`는 첫 번째 시도에서 한 번만 발급되고, `job_id`는 submit이 반환되는 즉시
# 채워집니다.
state = load_submission_state()  # {"key": ..., "job_id": ...} or {}
key = state.get("key") or str(uuid.uuid4())
save_submission_state(key=key)

try:
    job = client.submit(wf, idempotency_key=key)
    save_submission_state(key=key, job_id=job.id)
except IdempotencyKeyReuse:
    # 이 키를 사용한 이전 시도가 이미 제출까지 도달했으므로 작업이 존재할 수
    # 있습니다. 다시 제출하지 말고 찾아가세요.
    job_id = state.get("job_id")
    if job_id is None:
        raise  # 조회할 기록이 없음. 사람의 개입이 필요합니다
    job = client.jobs.get(job_id)

import { IdempotencyKeyReuse } from "@comfyorg/sdk";

// 두 값 모두 요청이 당신에게 의미하는 바를 기준으로 당신의 저장소에 보관합니다.
// `key`는 첫 번째 시도에서 한 번만 발급되고, `jobId`는 submit이 반환되는 즉시
// 채워집니다.
const state = await loadSubmissionState(); // { key?, jobId? }
const key = state.key ?? crypto.randomUUID();
await saveSubmissionState({ key });

let job;
try {
  job = await client.submit(wf, { idempotencyKey: key });
  await saveSubmissionState({ key, jobId: job.id });
} catch (err) {
  // 이 키를 사용한 이전 시도가 이미 제출까지 도달했으므로 작업이 존재할 수
  // 있습니다. 다시 제출하지 말고 찾아가세요.
  if (!(err instanceof IdempotencyKeyReuse) || !state.jobId) throw err;
  job = await client.jobs.get(state.jobId);
}

from comfy_sdk import Progress, Preview, OutputReady, StatusChange

job = client.submit(wf)

for event in job.events():
    match event:
        case Progress() as p:
            print(f"{p.value:.0%} {p.message}")
        case Preview() as pv:
            image = pv.to_pil()
        case OutputReady() as o:
            o.output.to_file(f"partial/{o.output.name}")
        case StatusChange(status="succeeded"):
            break

result = job.result()

const job = await client.submit(wf);

// 라벨이 필요합니다: switch 안의 일반 `break`는 루프가 아니라
// switch만 빠져나갑니다.
eventLoop: for await (const event of job.events()) {
  switch (event.kind) {
    case "progress":
      console.log(event.value);
      break;
    case "outputReady":
      await event.output.toFile(`${event.output.name}`);
      break;
    case "statusChange":
      if (event.status === "succeeded") break eventLoop;
  }
}

output = job.outputs[0]
output.job_id          # 이 파일을 생성한 작업

const output = job.outputs[0];
output.jobId; // 이 파일을 생성한 작업

wf = job.get_workflow()

if wf.format == "save":
    ...  # 작성된 그대로의 워크플로, 캔버스 레이아웃과 Note 노드 유지
else:
    ...  # 실행된 API 형식 그래프

const wf = await job.getWorkflow();

if (wf.format === "save") {
  // 작성된 그대로의 워크플로, 캔버스 레이아웃과 Note 노드 유지
} else {
  // 실행된 API 형식 그래프
}