Method execute

workflow/executor/dag_executor.py:40–44

Execute the DAG workflow.

(self)

        self.parallel_executor = ParallelExecutor(log_manager, nodes)
    
    def execute(self) -> None:
        """Execute the DAG workflow."""
        for layer_idx, layer_nodes in enumerate(self.layers):
            self.log_manager.debug(f"Executing Layer {layer_idx} with nodes: {layer_nodes}")
            self._execute_layer(layer_nodes)
    
    def _execute_layer(self, layer_nodes: List[str]) -> None:
        """Execute a single topological layer."""