Struct ExecutionStepRepository 

pub struct ExecutionStepRepository { /* private fields */ }

Implementations

impl ExecutionStepRepository

pub fn new(db: &DbPool) -> Result<Self>

pub async fn create(&self, step: &ExecutionStep) -> Result<()>

pub async fn get(&self, step_id: &StepId) -> Result<Option<ExecutionStep>>

pub async fn list_by_task(&self, task_id: &TaskId) -> Result<Vec<ExecutionStep>>

pub async fn complete_step( &self, step_id: &StepId, started_at: DateTime<Utc>, tool_result: Option<Value>, ) -> Result<()>

pub async fn fail_step( &self, step_id: &StepId, started_at: DateTime<Utc>, error_message: &str, ) -> Result<()>

pub async fn fail_in_progress_steps_for_task( &self, task_id: &TaskId, error_message: &str, ) -> Result<u64>

pub async fn complete_planning_step( &self, step_id: &StepId, started_at: DateTime<Utc>, reasoning: Option<String>, planned_tools: Option<Vec<PlannedTool>>, ) -> Result<ExecutionStep>

pub async fn mcp_execution_id_exists( &self, mcp_execution_id: &str, ) -> Result<bool>

Trait Implementations

impl Clone for ExecutionStepRepository

fn clone(&self) -> ExecutionStepRepository

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ExecutionStepRepository

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.