pipeline-orchestrator

Pipeline Orchestrator Skill

The central coordination layer for the ComfyUI ↔ Blender ↔ Godot pipeline. Manages staging directories, triggers stage transitions, and maintains an asset manifest.

Architecture

ComfyUI Output
    ↓
pipeline/staging/comfyui_output/     ← image lands here
    ↓  [asset-format-bridge]
pipeline/staging/2d_to_3d/           ← texture pack generated
    ↓  [blender-helper]
pipeline/staging/blender_import/     ← mesh + textures applied
    ↓  [asset-format-bridge]
pipeline/staging/godot_models/       ← GLB exported
    ↓  [godot-pipeline]
Godot res:// import                  ← Godot picks up on next scan
    ↓
pipeline/staging/exports/            ← Godot final export

Core Tools

1. Pipeline State Manager

import json, os
from pathlib import Path
from datetime import datetime

MANIFEST = Path("pipeline/staging/assets_manifest.json")
LOG = Path("pipeline/pipeline.log")

def log(msg: str):
    ts = datetime.now().isoformat()
    line = f"[{ts}] {msg}"
    print(line)
    LOG.parent.mkdir(parents=True, exist_ok=True)
    LOG.open("a").write(line + "\n")

def init_pipeline():
    """Initialize empty manifest."""
    MANIFEST.parent.mkdir(parents=True, exist_ok=True)
    MANIFEST.write_text(json.dumps({"version": "1.0", "assets": [], "runs": []}, indent=2))
    log("Pipeline initialized")

def record_asset(file: str, stage: str, meta: dict = None):
    manifest = json.loads(MANIFEST.read_text())
    manifest["assets"].append({
        "file": file,
        "stage": stage,
        "timestamp": datetime.now().isoformat(),
        "meta": meta or {}
    })
    MANIFEST.write_text(json.dumps(manifest, indent=2))
    log(f"[{stage}] {file}")

def record_run(name: str, steps: list[str], status: str):
    manifest = json.loads(MANIFEST.read_text())
    manifest["runs"].append({
        "name": name,
        "steps": steps,
        "status": status,
        "timestamp": datetime.now().isoformat()
    })
    MANIFEST.write_text(json.dumps(manifest, indent=2))
    log(f"[RUN:{status}] {name} — {' → '.join(steps)}")