diff --git a/simulator/generation/plan.rs b/simulator/generation/plan.rs index fa5ba86c0..60e4a7da6 100644 --- a/simulator/generation/plan.rs +++ b/simulator/generation/plan.rs @@ -446,7 +446,9 @@ impl Interaction { StepResult::Done => { break; } - StepResult::Busy => {} + StepResult::Busy => { + return Err(turso_core::LimboError::Busy); + } } } @@ -579,7 +581,10 @@ impl Interaction { StepResult::Done => { break; } - StepResult::Interrupt | StepResult::Busy => {} + StepResult::Busy => { + return Err(turso_core::LimboError::Busy); + } + StepResult::Interrupt => {} } } @@ -646,7 +651,10 @@ impl Interaction { StepResult::Done => { break; } - StepResult::Interrupt | StepResult::Busy => {} + StepResult::Busy => { + return Err(turso_core::LimboError::Busy); + } + StepResult::Interrupt => {} } } diff --git a/simulator/runner/execution.rs b/simulator/runner/execution.rs index 6b4442a57..ef87e25bc 100644 --- a/simulator/runner/execution.rs +++ b/simulator/runner/execution.rs @@ -268,7 +268,9 @@ fn limbo_integrity_check(conn: &Arc) -> Result<()> { StepResult::Done => { break; } - StepResult::Busy => {} + StepResult::Busy => { + return Err(LimboError::Busy); + } } }