diff --git a/crates/arroyo-controller/src/states/mod.rs b/crates/arroyo-controller/src/states/mod.rs index a360f1c32..3c786866a 100644 --- a/crates/arroyo-controller/src/states/mod.rs +++ b/crates/arroyo-controller/src/states/mod.rs @@ -729,7 +729,7 @@ impl StateMachine { if let Some(tx) = &self.tx { tx.send(msg).await.map_err(|_| "State machine is inactive") } else { - Err("State machine is inactive") + Err("State machine not started") } }