Skip to main content

Module pure

Module pure 

Source
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