Expand description
Pure functional utilities for MapReduce execution
This module contains pure functions extracted from the MapReduce executor to improve testability, reusability, and maintainability.
Modulesยง
- aggregation
- These functions operate on AgentResult data structures to calculate statistics, filter results, and group by error types.
- dependency_
analysis - Pure dependency analysis for command parallelization
- formatting
- Pure functions for formatting output messages
- interpolation
- Pure functions for variable interpolation
- parallel_
execution - Parallel execution patterns using Effects
- phase_
parallelization - Phase parallelization using dependency analysis
- planning
- Pure functions for execution planning
- work_
planning - Pure work assignment planning for MapReduce execution