Compare commits

..

1 Commits

Author SHA1 Message Date
cuddle-please
69c521c1b4 chore(release): 0.3.1
All checks were successful
continuous-integration/drone/push Build is passing
continuous-integration/drone/pr Build is passing
2025-03-27 12:08:33 +00:00
4 changed files with 5 additions and 11 deletions

View File

@ -6,11 +6,6 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
## [Unreleased] ## [Unreleased]
## [0.3.2] - 2025-03-27
### Fixed
- time formatting
## [0.3.1] - 2025-03-27 ## [0.3.1] - 2025-03-27
### Added ### Added

2
Cargo.lock generated
View File

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

View File

@ -3,7 +3,7 @@ members = ["crates/*"]
resolver = "2" resolver = "2"
[workspace.package] [workspace.package]
version = "0.3.2" version = "0.3.1"
[workspace.dependencies] [workspace.dependencies]
drift = { path = "crates/drift" } drift = { path = "crates/drift" }

View File

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