Implement the chosen primitive #90

New issue

Closed

opened 2026-06-26 20:50:52 +00:00 by Mark · 0 comments

Mark commented

2026-06-26 20:50:52 +00:00

Owner

Phase 1: Implement the chosen primitive

Implement the design from P1. Whichever path is chosen, this is the
substance of the change.

Files:

Modify: src/main_pipeline.py (refactor process() to support the
chosen API)
New: src/main_pipeline_async.py (if the choice was a separate
async wrapper instead of refactoring process())
Modify: src/service/handlers/digitize.py (issue #31 P2 handler
consumes the new API)

Acceptance:

The chosen API works as documented in P1.
5 concurrent digitize requests on a 4-core box complete in < 6× the
serial time per request (parallelism is real, not serialized).
Cancellation: if the caller cancels mid-request, the worker thread
is interrupted (or the result is discarded) within 1 second.

Depends on: P1 (decision).

Decomposed from easystitch#34

Decomposed from easystitch#52

## Phase 1: Implement the chosen primitive Implement the design from P1. Whichever path is chosen, this is the substance of the change. **Files:** - Modify: `src/main_pipeline.py` (refactor `process()` to support the chosen API) - New: `src/main_pipeline_async.py` (if the choice was a separate async wrapper instead of refactoring `process()`) - Modify: `src/service/handlers/digitize.py` (issue #31 P2 handler consumes the new API) **Acceptance:** - The chosen API works as documented in P1. - 5 concurrent digitize requests on a 4-core box complete in < 6× the serial time per request (parallelism is real, not serialized). - Cancellation: if the caller cancels mid-request, the worker thread is interrupted (or the result is discarded) within 1 second. **Depends on:** P1 (decision). --- --- _Decomposed from [easystitch#34](https://forgejo.tail018ac4.ts.net/Mark/easystitch/issues/34)_ --- _Decomposed from [easystitch#52](https://forgejo.tail018ac4.ts.net/Mark/easystitch/issues/52)_