Function wrap_timer

components/scheduler/src/interval_timer_manager.rs:234–255

(timer: IntervalTimer)

}

fn wrap_timer(timer: IntervalTimer) -> Result<WrappedIntervalTimer, Error> {
    let interval_type = match &timer.interval {
        IntervalType::Minutes(mins) => ParsedIntervalType::Minutes(*mins),
        IntervalType::Cron(c) => {
            let parsed =
                cron::Schedule::from_str(format!("0 {c}").as_str()).map_err(Error::Cron)?;
            ParsedIntervalType::Cron(c.clone(), Box::new(parsed))
        }
    };

    let next = if let Some(next) = interval_type.next_run_time(timer.last_run) {
        next
    } else {
        return Err(Error::NoNextTime);
    };

    Ok(WrappedIntervalTimer {
        inner: timer,
        next_run: next,
        parsed_type: interval_type,
    })
}

impl WrappedIntervalTimer {
    fn is_triggered(&self, t: DateTime<Utc>) -> bool {