CodeEntropy.levels.graph.level_dag module

Hierarchy-level DAG orchestration.

LevelDAG owns hierarchy-level workflow order. Static setup nodes prepare structural data. ConformationDAG computes trajectory-series conformational states. FrameScheduler executes frame-local covariance and neighbour work.

class CodeEntropy.levels.graph.level_dag.LevelDAG(universe_operations: Any | None = None)[source]

Bases: object

Execute static setup and deterministic frame map-reduce execution.

build() → LevelDAG[source]

Build the static, conformation, and frame DAG topology.

execute(shared_data: dict[str, Any], *, progress: _RichProgressSink | None = None) → dict[str, Any][source]

Execute the hierarchy workflow.

Parameters:

  • shared_data – Shared workflow data mutated by static setup, frame execution, and parent-side reductions.

  • progress – Optional progress sink passed to supported static nodes and frame scheduling.

Returns:

The same shared_data mapping after workflow execution.

Raises:

KeyError – If required shared workflow keys are missing.