Upload folder using huggingface_hub

Dockerfile

@@ -0,0 +1,28 @@
+# Builder worker using Kaniko for daemonless Docker builds
+FROM gcr.io/kaniko-project/executor:v1.23.2 AS kaniko
+
+FROM python:3.11-slim
+
+# Copy Kaniko executor
+COPY --from=kaniko /kaniko /kaniko
+
+# Install dependencies
+RUN apt-get update && apt-get install -y --no-install-recommends \
+    git \
+    ca-certificates \
+    && rm -rf /var/lib/apt/lists/*
+
+WORKDIR /app
+
+COPY requirements.txt .
+RUN pip install --no-cache-dir -r requirements.txt
+
+COPY app.py .
+
+# Kaniko needs this
+ENV PATH="/kaniko:${PATH}"
+ENV DOCKER_CONFIG="/kaniko/.docker"
+
+EXPOSE 7860
+
+CMD ["python", "app.py"]

README.md

@@ -1,10 +1,54 @@
 ---
 title: Builder
-emoji: 💻
-colorFrom: purple
-colorTo: blue
 sdk: docker
 pinned: false
 ---
 
-Check out the configuration reference at https://huggingface.co/docs/hub/spaces-config-reference
+# Kaniko Image Builder
+
+Daemonless Docker image builder using Kaniko. Builds and pushes images to GHCR without requiring Docker daemon access.
+
+## Configuration
+
+Set these as HuggingFace Secrets:
+
+- `REGISTRY_USER`: GitHub username
+- `REGISTRY_PASSWORD`: GitHub PAT with `packages:write` scope
+- `UPSTASH_REDIS_REST_URL`: (optional) Redis URL for build queue
+- `UPSTASH_REDIS_REST_TOKEN`: (optional) Redis token
+
+## Usage
+
+### Via Web UI
+Navigate to the Space and use the build form.
+
+### Via API
+```bash
+curl -X POST https://jonathanagustin-builder.hf.space/build \
+  -H "Authorization: Bearer $HF_TOKEN" \
+  -H "Content-Type: application/json" \
+  -d '{
+    "repo_url": "https://github.com/jonathanagustin/lawforge",
+    "image_name": "jonathanagustin/lawforge-worker",
+    "branch": "main",
+    "tags": ["latest"],
+    "dockerfile": "Dockerfile",
+    "context_path": "jobs/worker"
+  }'
+```
+
+### Via Taskfile
+```bash
+# Build worker image
+task builder:build:worker
+
+# Build any image
+REPO_URL=https://github.com/user/repo IMAGE_NAME=user/image task builder:build
+```
+
+## Endpoints
+
+- `GET /` - Web UI
+- `GET /api/status` - Builder status JSON
+- `POST /build` - Trigger a build
+- `POST /api/queue` - Queue a build (requires Redis)

app.py

@@ -0,0 +1,716 @@
+#!/usr/bin/env python3
+"""Docker image builder using Kaniko - no Docker daemon required.
+
+Builds Docker images and pushes to container registries (GHCR, Docker Hub, etc.)
+Can be triggered via API or run builds from a queue in Redis.
+
+Environment variables:
+  - REGISTRY_USER: Registry username (e.g., GitHub username for GHCR)
+  - REGISTRY_PASSWORD: Registry password/token (e.g., GitHub PAT with packages:write)
+  - REGISTRY_URL: Registry URL (default: ghcr.io)
+  - UPSTASH_REDIS_REST_URL: Redis URL for build queue
+  - UPSTASH_REDIS_REST_TOKEN: Redis token
+"""
+
+import json
+import os
+import shutil
+import subprocess
+import tempfile
+import threading
+import time
+import uuid
+from datetime import datetime, timezone
+from pathlib import Path
+
+from flask import Flask, jsonify, render_template_string, request
+import git
+
+# =============================================================================
+# Configuration
+# =============================================================================
+
+RUNNER_ID = os.environ.get("RUNNER_ID", str(uuid.uuid4())[:8])
+RUNNER_NAME = os.environ.get("RUNNER_NAME", f"Builder {RUNNER_ID}")
+REGISTRY_URL = os.environ.get("REGISTRY_URL", "ghcr.io")
+REGISTRY_USER = os.environ.get("REGISTRY_USER", "")
+REGISTRY_PASSWORD = os.environ.get("REGISTRY_PASSWORD", "")
+AUTO_START = os.environ.get("AUTO_START", "false").lower() == "true"
+
+# Global state
+state = {
+    "status": "idle",
+    "current_build": None,
+    "builds_completed": 0,
+    "builds_failed": 0,
+    "last_build": None,
+    "logs": [],
+    "redis_connected": False,
+}
+state_lock = threading.Lock()
+
+app = Flask(__name__)
+redis_client = None
+
+
+def log(msg: str):
+    """Thread-safe logging."""
+    with state_lock:
+        ts = datetime.now().strftime("%H:%M:%S")
+        state["logs"].append(f"[{ts}] {msg}")
+        if len(state["logs"]) > 200:
+            state["logs"] = state["logs"][-200:]
+    print(f"[{ts}] {msg}")
+
+
+# =============================================================================
+# Redis Integration
+# =============================================================================
+
+def init_redis():
+    """Initialize Redis for build queue."""
+    global redis_client
+
+    redis_url = os.environ.get("UPSTASH_REDIS_REST_URL", "")
+    redis_token = os.environ.get("UPSTASH_REDIS_REST_TOKEN", "")
+
+    if not redis_url or not redis_token:
+        log("Redis not configured - queue mode disabled")
+        return None
+
+    try:
+        from upstash_redis import Redis
+        redis_client = Redis.from_env()
+        redis_client.ping()
+        with state_lock:
+            state["redis_connected"] = True
+        log("✓ Redis connected - queue mode enabled")
+        return redis_client
+    except Exception as e:
+        log(f"Redis connection failed: {e}")
+        return None
+
+
+def get_next_build():
+    """Get next build from Redis queue."""
+    if not redis_client:
+        return None
+
+    try:
+        # Pop from build queue
+        build_json = redis_client.lpop("builds:queue")
+        if build_json:
+            return json.loads(build_json)
+    except Exception as e:
+        log(f"Queue error: {e}")
+    return None
+
+
+def queue_build(build_config: dict) -> str:
+    """Add a build to the queue."""
+    build_id = str(uuid.uuid4())[:8]
+    build_config["id"] = build_id
+    build_config["queued_at"] = datetime.now(timezone.utc).isoformat()
+
+    if redis_client:
+        try:
+            redis_client.rpush("builds:queue", json.dumps(build_config))
+            log(f"Build {build_id} queued")
+        except Exception as e:
+            log(f"Failed to queue build: {e}")
+    return build_id
+
+
+# =============================================================================
+# Docker Registry Auth
+# =============================================================================
+
+def setup_registry_auth():
+    """Configure Kaniko registry authentication."""
+    if not REGISTRY_USER or not REGISTRY_PASSWORD:
+        log("⚠️ Registry credentials not configured")
+        return False
+
+    # Create Docker config for Kaniko
+    docker_config_dir = Path("/kaniko/.docker")
+    docker_config_dir.mkdir(parents=True, exist_ok=True)
+
+    import base64
+    auth = base64.b64encode(f"{REGISTRY_USER}:{REGISTRY_PASSWORD}".encode()).decode()
+
+    config = {
+        "auths": {
+            REGISTRY_URL: {"auth": auth},
+            f"https://{REGISTRY_URL}": {"auth": auth},
+        }
+    }
+
+    config_path = docker_config_dir / "config.json"
+    with open(config_path, "w") as f:
+        json.dump(config, f)
+
+    log(f"✓ Registry auth configured for {REGISTRY_URL}")
+    return True
+
+
+# =============================================================================
+# Build Logic
+# =============================================================================
+
+def clone_repo(repo_url: str, branch: str = "main", target_dir: Path = None) -> Path:
+    """Clone a git repository."""
+    if target_dir is None:
+        target_dir = Path(tempfile.mkdtemp())
+
+    log(f"Cloning {repo_url} ({branch})...")
+
+    try:
+        git.Repo.clone_from(
+            repo_url,
+            target_dir,
+            branch=branch,
+            depth=1,
+            single_branch=True
+        )
+        log(f"✓ Cloned to {target_dir}")
+        return target_dir
+    except Exception as e:
+        log(f"✗ Clone failed: {e}")
+        raise
+
+
+def build_and_push(
+    context_dir: str,
+    image_name: str,
+    dockerfile: str = "Dockerfile",
+    tags: list = None,
+    build_args: dict = None,
+) -> bool:
+    """Build Docker image using Kaniko and push to registry."""
+
+    if tags is None:
+        tags = ["latest"]
+
+    # Full image name with registry
+    full_image = f"{REGISTRY_URL}/{image_name}"
+
+    log(f"Building {full_image}...")
+    log(f"  Context: {context_dir}")
+    log(f"  Dockerfile: {dockerfile}")
+    log(f"  Tags: {tags}")
+
+    with state_lock:
+        state["status"] = "building"
+        state["current_build"] = {
+            "image": full_image,
+            "tags": tags,
+            "started_at": datetime.now(timezone.utc).isoformat(),
+        }
+
+    # Build Kaniko command
+    cmd = [
+        "/kaniko/executor",
+        f"--context=dir://{context_dir}",
+        f"--dockerfile={context_dir}/{dockerfile}",
+    ]
+
+    # Add destination tags
+    for tag in tags:
+        cmd.append(f"--destination={full_image}:{tag}")
+
+    # Add build args
+    if build_args:
+        for key, value in build_args.items():
+            cmd.append(f"--build-arg={key}={value}")
+
+    # Kaniko options
+    cmd.extend([
+        "--cache=true",
+        "--cache-ttl=24h",
+        "--compressed-caching=false",
+        "--snapshot-mode=redo",
+        "--use-new-run",
+    ])
+
+    log(f"Executing: {' '.join(cmd[:5])}...")
+
+    try:
+        process = subprocess.Popen(
+            cmd,
+            stdout=subprocess.PIPE,
+            stderr=subprocess.STDOUT,
+            text=True,
+        )
+
+        # Stream output
+        for line in process.stdout:
+            line = line.strip()
+            if line:
+                log(f"  {line[:100]}")
+
+        process.wait()
+
+        if process.returncode == 0:
+            log(f"✓ Build successful: {full_image}")
+            with state_lock:
+                state["builds_completed"] += 1
+                state["last_build"] = {
+                    "image": full_image,
+                    "tags": tags,
+                    "status": "success",
+                    "completed_at": datetime.now(timezone.utc).isoformat(),
+                }
+            return True
+        else:
+            log(f"✗ Build failed with exit code {process.returncode}")
+            with state_lock:
+                state["builds_failed"] += 1
+                state["last_build"] = {
+                    "image": full_image,
+                    "tags": tags,
+                    "status": "failed",
+                    "exit_code": process.returncode,
+                    "completed_at": datetime.now(timezone.utc).isoformat(),
+                }
+            return False
+
+    except Exception as e:
+        log(f"✗ Build error: {e}")
+        with state_lock:
+            state["builds_failed"] += 1
+        return False
+    finally:
+        with state_lock:
+            state["status"] = "idle"
+            state["current_build"] = None
+
+
+def run_build(build_config: dict) -> bool:
+    """Run a build from config."""
+    repo_url = build_config.get("repo_url")
+    branch = build_config.get("branch", "main")
+    image_name = build_config.get("image_name")
+    dockerfile = build_config.get("dockerfile", "Dockerfile")
+    context_path = build_config.get("context_path", ".")
+    tags = build_config.get("tags", ["latest"])
+    build_args = build_config.get("build_args", {})
+
+    if not repo_url or not image_name:
+        log("✗ Missing repo_url or image_name")
+        return False
+
+    tmpdir = None
+    try:
+        # Clone repo
+        tmpdir = clone_repo(repo_url, branch)
+
+        # Set context directory
+        context_dir = str(tmpdir / context_path) if context_path != "." else str(tmpdir)
+
+        # Build and push
+        return build_and_push(
+            context_dir=context_dir,
+            image_name=image_name,
+            dockerfile=dockerfile,
+            tags=tags,
+            build_args=build_args,
+        )
+
+    finally:
+        if tmpdir and tmpdir.exists():
+            shutil.rmtree(tmpdir, ignore_errors=True)
+
+
+# =============================================================================
+# Queue Worker
+# =============================================================================
+
+def queue_worker():
+    """Process builds from the queue."""
+    log("Queue worker started")
+
+    while True:
+        if state["status"] == "idle":
+            build = get_next_build()
+            if build:
+                log(f"Processing queued build: {build.get('id')}")
+                run_build(build)
+
+        time.sleep(5)
+
+
+# =============================================================================
+# Web UI
+# =============================================================================
+
+HTML_TEMPLATE = """
+<!DOCTYPE html>
+<html lang="en">
+<head>
+    <meta charset="UTF-8">
+    <meta name="viewport" content="width=device-width, initial-scale=1.0">
+    <title>Builder</title>
+    <script src="https://unpkg.com/htmx.org@1.9.10"></script>
+    <style>
+        :root {
+            --bg: #09090b;
+            --surface: #18181b;
+            --border: #27272a;
+            --text: #fafafa;
+            --text-muted: #71717a;
+            --accent: #f59e0b;
+            --green: #4ade80;
+            --red: #f87171;
+        }
+        * { box-sizing: border-box; margin: 0; padding: 0; }
+        body {
+            font-family: ui-sans-serif, system-ui, -apple-system, BlinkMacSystemFont, sans-serif;
+            background: var(--bg);
+            color: var(--text);
+            min-height: 100vh;
+            display: flex;
+            flex-direction: column;
+        }
+        .main { flex: 1; padding: 2rem; max-width: 900px; margin: 0 auto; width: 100%; }
+        .header { margin-bottom: 2rem; }
+        .header h1 { font-size: 1.5rem; font-weight: 600; letter-spacing: -0.025em; }
+        .header-meta { display: flex; flex-wrap: wrap; gap: 1rem; margin-top: 0.5rem; font-size: 0.8125rem; color: var(--text-muted); }
+
+        .status-card {
+            background: var(--surface);
+            border: 1px solid var(--border);
+            border-radius: 0.75rem;
+            padding: 1.5rem;
+            margin-bottom: 1rem;
+        }
+        .status-header {
+            display: flex;
+            justify-content: space-between;
+            align-items: center;
+            margin-bottom: 1.5rem;
+        }
+        .status-info { display: flex; align-items: center; gap: 0.75rem; }
+        .dot {
+            width: 10px;
+            height: 10px;
+            border-radius: 50%;
+            flex-shrink: 0;
+        }
+        .dot.idle { background: var(--text-muted); }
+        .dot.building { background: var(--accent); animation: pulse 1.5s infinite; }
+        @keyframes pulse {
+            0%, 100% { opacity: 1; transform: scale(1); }
+            50% { opacity: 0.5; transform: scale(0.95); }
+        }
+        .status-text { font-size: 0.875rem; font-weight: 500; text-transform: uppercase; letter-spacing: 0.025em; }
+
+        .stats { display: grid; grid-template-columns: repeat(3, 1fr); gap: 1rem; }
+        .stat { text-align: center; padding: 1rem; background: var(--bg); border-radius: 0.5rem; }
+        .stat-value { font-size: 1.75rem; font-weight: 600; font-variant-numeric: tabular-nums; }
+        .stat-value.success { color: var(--green); }
+        .stat-value.failed { color: var(--red); }
+        .stat-label { font-size: 0.6875rem; color: var(--text-muted); text-transform: uppercase; letter-spacing: 0.05em; margin-top: 0.25rem; }
+
+        .form-card {
+            background: var(--surface);
+            border: 1px solid var(--border);
+            border-radius: 0.75rem;
+            padding: 1.5rem;
+            margin-bottom: 1rem;
+        }
+        .form-title { font-size: 0.875rem; font-weight: 500; margin-bottom: 1.25rem; }
+        .form-grid { display: grid; grid-template-columns: 1fr 1fr; gap: 1rem; }
+        .form-group { margin-bottom: 1rem; }
+        .form-group.full { grid-column: span 2; }
+        .form-group label {
+            display: block;
+            margin-bottom: 0.375rem;
+            color: var(--text-muted);
+            font-size: 0.75rem;
+            text-transform: uppercase;
+            letter-spacing: 0.025em;
+        }
+        .form-group input {
+            width: 100%;
+            padding: 0.625rem 0.75rem;
+            background: var(--bg);
+            border: 1px solid var(--border);
+            border-radius: 0.5rem;
+            color: var(--text);
+            font-size: 0.875rem;
+            font-family: ui-monospace, SFMono-Regular, "SF Mono", Menlo, monospace;
+            transition: border-color 0.15s;
+        }
+        .form-group input:focus {
+            outline: none;
+            border-color: var(--accent);
+        }
+        .form-group input::placeholder { color: var(--text-muted); opacity: 0.5; }
+
+        .btn {
+            background: var(--accent);
+            color: var(--bg);
+            border: none;
+            padding: 0.75rem 1.5rem;
+            border-radius: 0.5rem;
+            font-size: 0.875rem;
+            font-weight: 500;
+            cursor: pointer;
+            transition: opacity 0.15s, transform 0.15s;
+            width: 100%;
+        }
+        .btn:hover { opacity: 0.9; }
+        .btn:active { transform: scale(0.98); }
+        .btn:disabled { opacity: 0.4; cursor: not-allowed; }
+
+        .logs-panel {
+            background: var(--surface);
+            border: 1px solid var(--border);
+            border-radius: 0.75rem;
+            overflow: hidden;
+        }
+        .logs-header {
+            display: flex;
+            justify-content: space-between;
+            align-items: center;
+            padding: 0.75rem 1rem;
+            border-bottom: 1px solid var(--border);
+            background: rgba(0,0,0,0.2);
+        }
+        .logs-title { font-size: 0.8125rem; font-weight: 500; color: var(--text-muted); }
+        .logs {
+            font-family: ui-monospace, SFMono-Regular, "SF Mono", Menlo, monospace;
+            font-size: 0.75rem;
+            line-height: 1.5;
+            padding: 1rem;
+            max-height: 300px;
+            overflow-y: auto;
+            background: var(--bg);
+        }
+        .log-line { color: var(--text-muted); white-space: pre-wrap; word-break: break-all; }
+        .log-line:hover { color: var(--text); }
+
+        @media (max-width: 640px) {
+            .form-grid { grid-template-columns: 1fr; }
+            .form-group.full { grid-column: span 1; }
+            .stats { grid-template-columns: 1fr; }
+        }
+    </style>
+</head>
+<body>
+    <div class="main">
+        <div class="header">
+            <h1>Builder</h1>
+            <div class="header-meta">
+                <span>{{ runner_id }}</span>
+                <span>{{ registry_url }}</span>
+                {% if redis_connected %}<span style="color: var(--green);">Redis</span>{% endif %}
+            </div>
+        </div>
+
+        <div class="status-card" id="status-panel" hx-get="/status" hx-trigger="every 2s" hx-swap="innerHTML">
+            <div class="status-header">
+                <div class="status-info">
+                    <div class="dot {{ status }}"></div>
+                    <div class="status-text">{{ status }}</div>
+                </div>
+            </div>
+            <div class="stats">
+                <div class="stat">
+                    <div class="stat-value success">{{ builds_completed }}</div>
+                    <div class="stat-label">Completed</div>
+                </div>
+                <div class="stat">
+                    <div class="stat-value failed">{{ builds_failed }}</div>
+                    <div class="stat-label">Failed</div>
+                </div>
+                <div class="stat">
+                    <div class="stat-value">{{ 'Yes' if current_build else '-' }}</div>
+                    <div class="stat-label">Active</div>
+                </div>
+            </div>
+        </div>
+
+        <div class="form-card">
+            <div class="form-title">Trigger Build</div>
+            <form hx-post="/build" hx-swap="none">
+                <div class="form-grid">
+                    <div class="form-group full">
+                        <label>Repository URL</label>
+                        <input type="text" name="repo_url" placeholder="https://github.com/user/repo" required>
+                    </div>
+                    <div class="form-group">
+                        <label>Branch</label>
+                        <input type="text" name="branch" value="main">
+                    </div>
+                    <div class="form-group">
+                        <label>Image Name</label>
+                        <input type="text" name="image_name" placeholder="username/repo" required>
+                    </div>
+                    <div class="form-group">
+                        <label>Tags</label>
+                        <input type="text" name="tags" value="latest" placeholder="latest, v1.0">
+                    </div>
+                    <div class="form-group">
+                        <label>Dockerfile</label>
+                        <input type="text" name="dockerfile" value="Dockerfile">
+                    </div>
+                    <div class="form-group full">
+                        <button type="submit" class="btn" {% if status == 'building' %}disabled{% endif %}>
+                            {% if status == 'building' %}Building...{% else %}Build & Push{% endif %}
+                        </button>
+                    </div>
+                </div>
+            </form>
+        </div>
+
+        <div class="logs-panel">
+            <div class="logs-header">
+                <span class="logs-title">Logs</span>
+            </div>
+            <div id="logs" class="logs" hx-get="/logs" hx-trigger="every 2s" hx-swap="innerHTML">
+                {% for line in logs %}<div class="log-line">{{ line }}</div>{% endfor %}
+            </div>
+        </div>
+    </div>
+</body>
+</html>
+"""
+
+
+@app.route("/")
+def index():
+    with state_lock:
+        return render_template_string(
+            HTML_TEMPLATE,
+            runner_name=RUNNER_NAME,
+            runner_id=RUNNER_ID,
+            registry_url=REGISTRY_URL,
+            redis_connected=state["redis_connected"],
+            status=state["status"],
+            builds_completed=state["builds_completed"],
+            builds_failed=state["builds_failed"],
+            current_build=state["current_build"],
+            logs=state["logs"][-50:],
+        )
+
+
+@app.route("/status")
+def status():
+    with state_lock:
+        return render_template_string("""
+            <div class="status-header">
+                <div class="status-info">
+                    <div class="dot {{ status }}"></div>
+                    <div class="status-text">{{ status }}</div>
+                </div>
+            </div>
+            <div class="stats">
+                <div class="stat">
+                    <div class="stat-value success">{{ builds_completed }}</div>
+                    <div class="stat-label">Completed</div>
+                </div>
+                <div class="stat">
+                    <div class="stat-value failed">{{ builds_failed }}</div>
+                    <div class="stat-label">Failed</div>
+                </div>
+                <div class="stat">
+                    <div class="stat-value">{{ 'Yes' if current_build else '-' }}</div>
+                    <div class="stat-label">Active</div>
+                </div>
+            </div>
+        """,
+            status=state["status"],
+            builds_completed=state["builds_completed"],
+            builds_failed=state["builds_failed"],
+            current_build=state["current_build"],
+        )
+
+
+@app.route("/logs")
+def logs():
+    with state_lock:
+        return "".join(f'<div class="log-line">{line}</div>' for line in state["logs"][-50:])
+
+
+@app.route("/build", methods=["POST"])
+def trigger_build():
+    """Trigger a build via API or form."""
+    if state["status"] == "building":
+        return jsonify({"error": "Build already in progress"}), 409
+
+    # Get build config from form or JSON
+    if request.is_json:
+        config = request.json
+    else:
+        config = {
+            "repo_url": request.form.get("repo_url"),
+            "branch": request.form.get("branch", "main"),
+            "image_name": request.form.get("image_name"),
+            "dockerfile": request.form.get("dockerfile", "Dockerfile"),
+            "tags": [t.strip() for t in request.form.get("tags", "latest").split(",")],
+        }
+
+    if not config.get("repo_url") or not config.get("image_name"):
+        return jsonify({"error": "repo_url and image_name required"}), 400
+
+    # Run build in background
+    threading.Thread(target=run_build, args=(config,), daemon=True).start()
+
+    return jsonify({"status": "started", "config": config}), 202
+
+
+@app.route("/api/status")
+def api_status():
+    with state_lock:
+        return jsonify({
+            "runner_id": RUNNER_ID,
+            "runner_name": RUNNER_NAME,
+            "status": state["status"],
+            "current_build": state["current_build"],
+            "builds_completed": state["builds_completed"],
+            "builds_failed": state["builds_failed"],
+            "last_build": state["last_build"],
+            "redis_connected": state["redis_connected"],
+        })
+
+
+@app.route("/api/queue", methods=["POST"])
+def api_queue():
+    """Queue a build for later processing."""
+    if not request.is_json:
+        return jsonify({"error": "JSON required"}), 400
+
+    config = request.json
+    build_id = queue_build(config)
+    return jsonify({"status": "queued", "build_id": build_id}), 202
+
+
+# =============================================================================
+# Startup
+# =============================================================================
+
+def startup():
+    log(f"Builder started: {RUNNER_NAME} ({RUNNER_ID})")
+    log(f"Registry: {REGISTRY_URL}")
+
+    # Initialize Redis
+    init_redis()
+
+    # Setup registry auth
+    if REGISTRY_USER:
+        setup_registry_auth()
+    else:
+        log("⚠️ REGISTRY_USER not set - pushes will fail")
+
+    # Start queue worker if Redis is configured
+    if redis_client:
+        threading.Thread(target=queue_worker, daemon=True).start()
+
+    log("Ready for builds!")
+
+
+threading.Thread(target=startup, daemon=True).start()
+
+if __name__ == "__main__":
+    app.run(host="0.0.0.0", port=7860)

requirements.txt

@@ -0,0 +1,5 @@
+flask>=3.0.0
+huggingface_hub>=0.24.0
+httpx>=0.27.0
+gitpython>=3.1.0
+upstash-redis>=1.0.0