Coop concurrency#14

Draft

rpanfili wants to merge 24 commits intomainfrom

coop_concurrency

Commits on Mar 18, 2026

refactor: pre-load SHACL and validate in-memory to avoid I/O
rpanfili
committed
feat: run SHACL validation in a process pool to bypass GIL and parallelize across CPUs
rpanfili
committed
feat: add separate pool size settings for postprocessors and SHACL validation
rpanfili
committed
feat: track SHACL process pool queue wait and execution time separately in timing log
rpanfili
committed
feat: add inprocess postprocessor runtime for running processors in the same process
rpanfili
committed
feat: run postprocessors on a dedicated thread pool instead of the default executor
rpanfili
committed
fix: handle SHACL process pool timeout and broken executor errors gracefully
rpanfili
committed
fix: offload graph hashing to executor to avoid blocking the event loop
rpanfili
committed
fix: enable stop_after_attempt(5) retry limit on graph queue put
rpanfili
committed
fix: disable morph_kgc internal multiprocessing to prevent fork deadlocks in threaded context
rpanfili
committed
fix: offload RML mapping to dedicated thread pool to prevent blocking the event loop
rpanfili
committed
fix: serialize morph_kgc calls with a lock to prevent thread-safety issues in pyparsing
rpanfili
committed
Revert "fix: offload RML mapping to dedicated thread pool to prevent blocking the event loop"
rpanfili
committed
perf: run morph_kgc in a subprocess pool for true parallelism without pyparsing lock contention
rpanfili
committed
perf: expose morph_kgc pool size setting and track subprocess queue wait in timing log
rpanfili
committed
fix: read morph_kgc queue wait from worker thread via closure to avoid thread-local race
rpanfili
committed
perf: reuse a single persistent ApiClient across requests instead of creating one per graph
rpanfili
committed
fix: create ApiClient directly on the event loop thread instead of in an executor
rpanfili
committed