buua436
f37b6fc439
fix: account for checkpointed ingestion progress ( #18667 )
...
Preserve completed component progress when an ingestion task resumes from a checkpoint. Checkpointed operators are skipped and do not emit lifecycle events again, which previously caused the document progress to
remain below 100%.
2026-08-24 14:28:05 +08:00
Jin Hai
53e83dcadf
Go: add context, part4 ( #17381 )
...
Signed-off-by: Jin Hai <haijin.chn@gmail.com >
2026-07-26 18:31:56 +08:00
Jack
cfacaccad7
Refactor: message processing ( #16852 )
...
### Summary
1. refactor message processing
2. delete un-used componentIndexMap
3. unfold (delete) internal/ingestion/task/task_handler.go
2026-07-13 16:32:34 +08:00
Jack
3c0f8fc192
Refactor: refactor dataflow_service.go and guard nats message re-delivery ( #16826 )
...
### Summary
1. refactor dataflow_service.go
2. guard nats message re-delivery
3. support document parse cancelling & re-run
2026-07-13 11:08:04 +08:00
