 discord9
|
6fa375021f
|
feat(flow): expose extension-owned batching execution hooks (#9171)
* fix: preserve structured query errors through distributed execution
Signed-off-by: discord9 <55937128+discord9@users.noreply.github.com>
* feat: use exact sequence ranges for capable incremental flow sources
Signed-off-by: discord9 <55937128+discord9@users.noreply.github.com>
* test: update SQL expectations for preserved query error codes
Signed-off-by: discord9 <55937128+discord9@users.noreply.github.com>
* style: format exact sequence recovery tests
Signed-off-by: discord9 <55937128+discord9@users.noreply.github.com>
* feat: merge aggregate states in incremental flows
Signed-off-by: discord9 <55937128+discord9@users.noreply.github.com>
* test: exercise dispatched exact delta failure recovery
Signed-off-by: discord9 <55937128+discord9@users.noreply.github.com>
* test: record flushed exact sequence flow results
Signed-off-by: discord9 <55937128+discord9@users.noreply.github.com>
* test: pass query engine to state merge execution tests
Signed-off-by: discord9 <55937128+discord9@users.noreply.github.com>
* feat(flow): expose extension-owned batching execution hooks
Signed-off-by: discord9 <55937128+discord9@users.noreply.github.com>
* fix(flow): correct extension matcher borrowing and regression assertions
Signed-off-by: discord9 <55937128+discord9@users.noreply.github.com>
* test: prove executed empty exact deltas keep incremental mode
Signed-off-by: discord9 <55937128+discord9@users.noreply.github.com>
* test: pass query engine to empty exact delta regression
Signed-off-by: discord9 <55937128+discord9@users.noreply.github.com>
* test: cover aggregate state merge through the full flow path
Signed-off-by: discord9 <55937128+discord9@users.noreply.github.com>
* test: pass query engine to flow batching task regression calls
Signed-off-by: discord9 <55937128+discord9@users.noreply.github.com>
---------
Signed-off-by: discord9 <55937128+discord9@users.noreply.github.com>
|
2026-09-18 04:35:29 +00:00 |
|