pub fn run_pending(
catalog: &Catalog,
extract_worker: &ExtractionWorker<'_>,
chunk_worker: &ChunkAndIndexWorker<'_>,
embed_worker: Option<&EmbeddingWorker<'_>>,
limit: u32,
) -> OrbokResult<u64>Expand description
Run all queued jobs until the queue is empty or limit jobs have
been processed. Returns the number of jobs that succeeded.
This is the legacy synchronous dispatch loop, retained for tests
and simple callers. Production code should use Scheduler::tick()
for resource-aware dispatch (RFC-036).