Struct LinearExecutor 

pub struct LinearExecutor { /* private fields */ }

Linear executor that runs cells sequentially in dependency order.

Implementations

impl LinearExecutor

pub fn new(state_dir: impl AsRef<Path>) -> Result<Self>

Create a new linear executor.

pub fn with_state(state: StateManager) -> Self

Create with an existing state manager.

pub fn set_callback(&mut self, callback: impl ExecutionCallback + 'static)

Set the execution callback for progress reporting.

pub fn set_abort_handle(&mut self, handle: AbortHandle)

Set the abort handle for cooperative cancellation.

pub fn abort_handle(&self) -> Option<&AbortHandle>

Get the current abort handle.

pub fn load_cell( &mut self, compiled: CompiledCell, dep_count: usize, ) -> Result<()>

Load a compiled cell for execution.

pub fn unload_cell(&mut self, cell_id: CellId) -> Option<LoadedCell>

Unload a cell (e.g., before hot-reload).

pub fn restore_cell(&mut self, cell: LoadedCell)

Restore a previously unloaded cell (for hot-reload rollback).

pub fn is_loaded(&self, cell_id: CellId) -> bool

Check if a cell is loaded.

pub fn execute_cell( &mut self, cell_id: CellId, inputs: &[Arc<BoxedOutput>], ) -> Result<BoxedOutput>

Execute a single cell with the given inputs.

Returns the serialized output on success. Returns Error::Aborted if abort was requested before execution.

pub fn execute_and_store( &mut self, cell_id: CellId, inputs: &[Arc<BoxedOutput>], ) -> Result<()>

Execute a cell and store the output in the state manager.

pub fn execute_in_order( &mut self, order: &[CellId], deps: &HashMap<CellId, Vec<CellId>>, ) -> Result<()>

Execute cells in the given order, resolving dependencies from state.

Returns Error::Aborted if abort was requested during execution.

pub fn state(&self) -> &StateManager

Get a reference to the state manager.

pub fn state_mut(&mut self) -> &mut StateManager

Get a mutable reference to the state manager.