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.

错误:搜索内容不能为空,请输入英文关键词
错误:关键词超出字数限制,请精简
高级检索

Multi-Agent Stateless Orchestration for Distributed Data Pipelines Implementation

  • Nicolò Bertozzi,
  • Anna Geraci,
  • Marco Sacchet,
  • Enrico Ferrera,
  • Claudio Pastrone

摘要

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.