The continuation dispatch in EmbedFileJob did not pass the running chunk count forward, so each batch started with job.data.chunks undefined. On the final batch, totalChunks collapsed to just that batch's result and KbIngestState.markIndexed stored a value far below what Qdrant actually held. Add chunksSoFar to EmbedFileJobParams and thread it through the continuation chain so the final markIndexed call reflects the true total across all batches. Closes #933 |
||
|---|---|---|
| .. | ||
| controllers | ||
| exceptions | ||
| jobs | ||
| middleware | ||
| models | ||
| services | ||
| utils | ||
| validators | ||