INNER CODE UNIT · Python

api_enrich_start

Nuclear-Marmalade/dataforge · forge/dashboard/app.py:478

async def api_enrich_start(
    request: Request,
    mode: str = Form("both"),
    workers: int = Form(50),
):
    """Start enrichment in a background thread."""
    global _enrichment_thread

    with _enrichment_lock:
        if _enrichment_stats["running"]:
            return HTMLResponse(
                '<div class="forge-card text-amber-400 text-center py-3">'
                "Enrichment is already running</div>"
            )
        _enrichment_stats["running"] = True  # Set BEFORE releasing lock to prevent TOCTOU race

    _enrichment_stop.clear()
    _enrichment_thread = threading.Thread(

View source record →