bump: to 0.6.0-rc.4

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "apalis"
-version = "0.6.0-rc.3"
+version = "0.6.0-rc.4"
 authors = ["Geoffrey Mureithi <[email protected]>"]
 description = "Simple, extensible multithreaded background job processing for Rust"
 repository = "https://github.com/geofmureithi/apalis"
@@ -54,7 +54,7 @@ layers = [
 docsrs = ["document-features"]
 
 [dependencies.apalis-core]
-version = "0.6.0-rc.3"
+version = "0.6.0-rc.4"
 default-features = false
 path = "./packages/apalis-core"
 

packages/apalis-core/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "apalis-core"
-version = "0.6.0-rc.3"
+version = "0.6.0-rc.4"
 authors = ["Njuguna Mureithi <[email protected]>"]
 edition = "2021"
 license = "MIT"

packages/apalis-core/src/lib.rs

@@ -174,7 +174,6 @@ impl crate::executor::Executor for TestExecutor {
 pub mod test_utils {
     use crate::error::BoxDynError;
     use crate::request::Request;
-    use crate::storage::Storage;
     use crate::task::task_id::TaskId;
     use crate::worker::WorkerId;
     use crate::Backend;

packages/apalis-cron/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "apalis-cron"
-version = "0.6.0-rc.3"
+version = "0.6.0-rc.4"
 edition = "2021"
 authors = ["Njuguna Mureithi <[email protected]>"]
 license = "MIT"
@@ -9,7 +9,7 @@ description = "A simple yet extensible library for cron-like job scheduling for
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
 [dependencies]
-apalis-core = { path = "../../packages/apalis-core", version = "0.6.0-rc.3", default-features = false, features = [
+apalis-core = { path = "../../packages/apalis-core", version = "0.6.0-rc.4", default-features = false, features = [
     "sleep",
 ] }
 cron = "0.12.1"

packages/apalis-cron/src/lib.rs

@@ -47,7 +47,7 @@
 //!     let worker = WorkerBuilder::new("morning-cereal")
 //!         .layer(RetryLayer::new(RetryPolicy::retries(5)))
 //!         .data(FakeService)
-//!         .stream(CronStream::new(schedule).into_stream())
+//!         .backend(CronStream::new(schedule))
 //!         .build_fn(send_reminder);
 //!     Monitor::<TokioExecutor>::new()
 //!         .register(worker)

packages/apalis-redis/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "apalis-redis"
-version = "0.6.0-rc.3"
+version = "0.6.0-rc.4"
 authors = ["Njuguna Mureithi <[email protected]>"]
 edition = "2021"
 readme = "../../README.md"
@@ -11,7 +11,7 @@ description = "Redis Storage for apalis: use Redis for background jobs and messa
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
 [dependencies]
-apalis-core = { path = "../../packages/apalis-core", version = "0.6.0-rc.3", default-features = false, features = [
+apalis-core = { path = "../../packages/apalis-core", version = "0.6.0-rc.4", default-features = false, features = [
     "sleep",
     "json",
 ] }

packages/apalis-sql/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "apalis-sql"
-version = "0.6.0-rc.3"
+version = "0.6.0-rc.4"
 authors = ["Njuguna Mureithi <[email protected]>"]
 edition = "2021"
 readme = "../../README.md"
@@ -25,7 +25,7 @@ features = ["chrono"]
 [dependencies]
 serde = { version = "1", features = ["derive"] }
 serde_json = "1"
-apalis-core = { path = "../../packages/apalis-core", version = "0.6.0-rc.3", default-features = false, features = [
+apalis-core = { path = "../../packages/apalis-core", version = "0.6.0-rc.4", default-features = false, features = [
     "sleep",
     "json",
 ] }

packages/apalis-sql/src/from_row.rs

@@ -131,7 +131,6 @@ impl<'r, T: Decode<'r, sqlx::Postgres> + Type<sqlx::Postgres>>
     fn from_row(row: &'r sqlx::postgres::PgRow) -> Result<Self, sqlx::Error> {
         use sqlx::Row;
         use std::str::FromStr;
-        type Timestamp = i64;
 
         let job: T = row.try_get("job")?;
         let id: TaskId =