diff --git a/jobs-core/Cargo.toml b/jobs-core/Cargo.toml index 1bfc8c8..25ea011 100644 --- a/jobs-core/Cargo.toml +++ b/jobs-core/Cargo.toml @@ -1,7 +1,7 @@ [package] name = "background-jobs-core" description = "Core types for implementing an asynchronous jobs processor" -version = "0.18.0" +version = "0.18.1" license = "AGPL-3.0" authors = ["asonix "] repository = "https://git.asonix.dog/asonix/background-jobs" @@ -19,7 +19,7 @@ error-logging = [] [dependencies] async-trait = "0.1.24" -event-listener = "4" +event-listener = "5" metrics = "0.22.0" time = { version = "0.3", features = ["serde-human-readable"] } tracing = "0.1" diff --git a/jobs-core/src/storage.rs b/jobs-core/src/storage.rs index 8101afa..80e58db 100644 --- a/jobs-core/src/storage.rs +++ b/jobs-core/src/storage.rs @@ -41,7 +41,6 @@ pub mod memory_storage { convert::Infallible, future::Future, ops::Bound, - pin::Pin, sync::Arc, sync::Mutex, time::Duration, @@ -107,7 +106,7 @@ pub mod memory_storage { .map(|(job_info, _)| job_info.clone()) } - fn listener(&self, pop_queue: String) -> (Pin>, Duration) { + fn listener(&self, pop_queue: String) -> (EventListener, Duration) { let lower_bound = QueueTimeId(Uuid::new_v7(Timestamp::from_unix(NoContext, 0, 0))); let now = OffsetDateTime::now_utc();