Introduce staged parallelism in ingestion pipeline (classification → judge → weaver)