Alan-Jowett / LexonGraph / 30310809129

82%

Build Type

push

github

Committed by web-flow

Commit Message

Add v3 cooperative cancellation (#215)

* Add v3 cooperative cancellation

Introduce a run-scoped cancellation handle for the constrained v3 streaming indexer path and surface explicit cancellation as a terminal error.

Wire cooperative cancellation checks through long-running v3 ingest, classification, planning, materialization, and assembly checkpoints while preserving the standalone clustering public APIs.

Update the streaming-indexer requirements, design, and validation specs plus implementation tests to keep spec-to-code traceability intact.

Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com>

* Use relaxed cancellation atomics

Switch the v3 cancellation handle from SeqCst to Relaxed because the flag does not synchronize any additional shared state.

Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com>

* Make v3 cancellation test deterministic

Replace the time-based PR cancellation test with a deterministic observer-signaled cancellation path so it does not depend on host timing.

Ran cargo fmt, cargo clippy -p lexongraph-streaming-indexer --all-targets -- -D warnings, and cargo test -p lexongraph-streaming-indexer before this commit.

Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com>

* Avoid hanging v3 cancellation test

Trigger cancellation directly from the observer at the deterministic train-ingest phase boundary instead of routing through a helper thread that could block forever waiting on a channel.

Ran cargo fmt --package lexongraph-streaming-indexer, cargo clippy -p lexongraph-streaming-indexer --all-targets -- -D warnings, and cargo test -p lexongraph-streaming-indexer before this commit.

Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com>

---------

Co-authored-by: Alan Jowett <alan.jowett@microsoft.com>
Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com>

Coverage Stats

199 of 297 new or added lines in 2 files covered. (67.0%)

2 existing lines in 1 file now uncovered.

32441 of 39991 relevant lines covered (81.12%)

386244.52 hits per line