/ crates / arroyo-controller / src / states / compiling.rs
compiling.rs
 1  use crate::states::StateError;
 2  
 3  use super::{scheduling::Scheduling, JobContext, State, Transition};
 4  
 5  #[derive(Debug)]
 6  pub struct Compiling;
 7  
 8  #[async_trait::async_trait]
 9  impl State for Compiling {
10      fn name(&self) -> &'static str {
11          "Compiling"
12      }
13  
14      async fn next(self: Box<Self>, _ctx: &mut JobContext) -> Result<Transition, StateError> {
15          return Ok(Transition::next(*self, Scheduling {}));
16      }
17  }