dullfig/xml-pipeline
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions
xml-pipeline/xml_pipeline/message_bus
History
dullfig 6790c7a46c Add shared backend for multiprocess pipeline support 
Introduces SharedBackend Protocol for cross-process state sharing:
- InMemoryBackend: default single-process storage
- ManagerBackend: multiprocessing.Manager for local multi-process
- RedisBackend: distributed deployments with TTL auto-GC

Adds ProcessPoolExecutor support for CPU-bound handlers:
- worker.py: worker process entry point
- stream_pump.py: cpu_bound handler dispatch
- Config: backend and process_pool sections in organism.yaml

ContextBuffer and ThreadRegistry now accept optional backend
parameter while maintaining full backward compatibility.

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
2026-01-20 20:18:22 -08:00
..
steps Fix XSD path for installed package (v0.3.1) 2026-01-19 22:24:36 -08:00
__init__.py Rename agentserver to xml_pipeline, add console example 2026-01-19 21:41:19 -08:00
config.py Rename agentserver to xml_pipeline, add console example 2026-01-19 21:41:19 -08:00
envelope.py Rename agentserver to xml_pipeline, add console example 2026-01-19 21:41:19 -08:00
errors.py Rename agentserver to xml_pipeline, add console example 2026-01-19 21:41:19 -08:00
message_state.py Rename agentserver to xml_pipeline, add console example 2026-01-19 21:41:19 -08:00
scheduler.py Rename agentserver to xml_pipeline, add console example 2026-01-19 21:41:19 -08:00
stream_pump.py Add shared backend for multiprocess pipeline support 2026-01-20 20:18:22 -08:00
system_pipeline.py Rename agentserver to xml_pipeline, add console example 2026-01-19 21:41:19 -08:00
thread.py Rename agentserver to xml_pipeline, add console example 2026-01-19 21:41:19 -08:00
thread_registry.py Add shared backend for multiprocess pipeline support 2026-01-20 20:18:22 -08:00
todo_registry.py Rename agentserver to xml_pipeline, add console example 2026-01-19 21:41:19 -08:00
worker.py Add shared backend for multiprocess pipeline support 2026-01-20 20:18:22 -08:00