diff --git a/src/scheduler/mod.rs b/src/scheduler/mod.rs index ca43c89..2102fbb 100644 --- a/src/scheduler/mod.rs +++ b/src/scheduler/mod.rs @@ -23,7 +23,7 @@ pub fn next_run_for_schedule(schedule: &Schedule, from: i64) -> Option { Schedule::Every { every_ms } => Some(from + *every_ms as i64), Schedule::Cron { expr, tz } => { let cron_schedule = cron::Schedule::from_str(expr.as_str()).ok()?; - let from_secs = (from / 1000) as i64; + let from_secs = from / 1000; let from_nanos = ((from % 1000) * 1_000_000) as u32; let from_dt = Utc.timestamp_opt(from_secs, from_nanos).single()?; diff --git a/src/scheduler/store.rs b/src/scheduler/store.rs index b061c76..f7d5dd9 100644 --- a/src/scheduler/store.rs +++ b/src/scheduler/store.rs @@ -109,7 +109,7 @@ impl SchedulerStore { .fetch_optional(pool) .await? .ok_or_else(|| anyhow::anyhow!("job not found: {id}"))?; - Ok(row_to_job(&row)?) + row_to_job(&row) } /// List all jobs, ordered by next_run_at ascending.