runtasktic 1.2.0

Command-line task management tool for execution of regular long sequential or parallel tasks.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

use chrono::Local;
use cron::Schedule;

pub trait WaitSchedule<T> {
  fn wait(&self, timezone: T);
}

impl WaitSchedule<Local> for Option<Schedule> {
  fn wait(&self, timezone: Local) {
    if let Some(cron) = self {
      cron.wait(timezone);
    }
  }
}

impl WaitSchedule<Local> for Schedule {
  fn wait(&self, timezone: Local) {
    let date = self
      .upcoming(timezone)
      .next()
      .expect("Cannot get upcoming cron date");
    debug!("Schedule wait until {date}");
    std::thread::sleep(
      (date - Local::now())
        .to_std()
        .expect("Cannot transform Duration"),
    );
  }
}