Multi-Agent Stateless Orchestration for Distributed Data Pipelines Implementation
摘要
This paper introduces a stateless orchestration architecture and mechanism for managing distributed data pipelines in multi-agent systems. Workflows are decomposed into independent subworkflows by a splitting module. A caching mechanism preserves execution context without relying on local state, supporting true statelessness. Communication is event-driven via Apache Kafka, and a unified data model ensures consistent interaction among components. The architecture is validated on a Kubernetes environment, showing scaling and low-latency features. This approach combines the control of orchestration with the scalability of event-driven systems, offering a robust solution for modular workflow execution.