kjuulh/drift
1
0
Fork 0
Code Issues 1 Pull Requests 1 Actions Packages Projects Releases 7 Wiki Activity

fix: time formatting
All checks were successful
continuous-integration/drone/push Build is passing
Details

Browse Source
This commit is contained in:
kjuulh 2025-03-27 13:29:53 +01:00
parent b75a3da94d
commit ad0081846e
2 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Cargo.lock generated
View File

@ -249,7 +249,7 @@ dependencies = [
[[package]]
name = "nodrift"
version = "0.3.0"
version = "0.3.1"
dependencies = [
"anyhow",
"async-trait",

7
crates/drift/src/lib.rs
View File

@ -1,7 +1,8 @@
use std::{sync::Arc, time::Duration};
use anyhow::Context;
use async_trait::async_trait;
use chrono::{DateTime, Local};
use chrono::{DateTime, Local, TimeDelta};
use std::future::Future;
use tokio::time;
use tokio_util::sync::CancellationToken;
@ -76,9 +77,9 @@ where
wait = interval.saturating_sub(elapsed);
let now: DateTime<Local> = Local::now();
let next: Option<DateTime<Local>> = std::time::SystemTime::now().checked_add(wait).map(|next| next.into());
let next: Option<DateTime<Local>> = now.checked_add_signed(TimeDelta::from_std(wait).expect("to be able to convert duration into time delta"));
tracing::debug!(?now, ?next, "job took: {}ms, waiting: {}ms for next run", elapsed.as_millis(), wait.as_millis() );
tracing::debug!(now=now.to_string(), next=next.map(|n| n.to_string()), "job took: {}ms, waiting: {}ms for next run", elapsed.as_millis(), wait.as_millis() );
}
}