Files
cleveragents-core/docs/reference/large_project_decomposition.md

2.2 KiB

Large-Project Decomposition

Overview

The large-project decomposition subsystem breaks large file sets into bounded subplans suitable for independent execution. It provides hierarchical decomposition with 4+ levels, clustering heuristics, dependency closure computation, and DAG execution ordering.

Configuration

Setting Default Description
planner_max_depth 4 Maximum recursion depth
planner_max_files_per_subplan 500 Upper file count per leaf
planner_max_tokens_per_subplan 100000 Upper token count per leaf
planner_min_files_per_subplan 10 Threshold below which decomposition is skipped

Clustering Strategies

Three complementary strategies partition files into bounded clusters:

  • Directory — Groups files by common directory prefix. Splits oversized buckets into chunks of max_files_per_subplan.
  • Language — Groups files by file extension. Useful for polyglot projects.
  • Size — Groups files by cumulative estimated token count.

A deterministic sort ensures clusters are always produced in the same order.

Dependency Closure

DependencyClosureComputer computes bounded transitive closures on file dependency graphs:

  • compute_closure(graph, roots, cutoff) — BFS forward closure with optional size limit. Results are memoised for repeated queries.
  • topological_sort(graph) — Kahn's algorithm for DAG execution ordering.
  • detect_cycles(graph) — DFS colouring to find elementary cycles.

Decision Recording

DecompositionService.record_decisions() persists two types of decisions:

  1. strategy_choice — The overall decomposition strategy.
  2. subplan_spawn — One per leaf node in the decomposition tree.

API

from cleveragents.application.services.decomposition_service import (
    DecompositionService,
)
from cleveragents.application.services.decomposition_models import (
    DecompositionConfig,
)

svc = DecompositionService(decision_service=ds)
result = svc.decompose(files, DecompositionConfig(max_depth=4))
svc.record_decisions(plan_id, result)