Workshop paper

Structured State Management for Agentic Data Pipelines: Bounded Context, Schema Contracts, and Selective Recovery

Abstract

Agentic systems operating over heterogeneous data ecosystems face data management challenges distinct from single-turn LLM inference. When a pipeline ingests large artifacts---log streams, database query results, document corpora---into a monolithic context window, the result is unbounded, non-queryable state that is expensive to recover on failure.

We present \emph{structured state management} (SSM), a data-centric architectural pattern in which each pipeline stage reads only its declared upstream keys, every stage output is schema-validated before commit to a persistent state store, and the execution engine performs selective recovery---retrying only the failed stage over its bounded context.

We evaluate SSM on two data-intensive workloads: Kubernetes root cause analysis (84,000-record input artifact) and multi-file code debugging. Across three configurations (monolithic, static-decomposed, SSM), we find that static decomposition \emph{increases} retry cost by 80.5% over monolithic (1,632±1451{,}632 \pm 145 vs.\ 904±17904 \pm 17 tokens) due to cascading re-reads of upstream state, while SSM reduces retry cost by 73.2% over static decomposition and 51.7% over monolithic (436±132436 \pm 132 tokens). Schema contracts also create structured human-in-the-loop intervention points at every stage boundary.