feat: use SqlDateTime abstraction from apalis-sql

Cargo.toml

@@ -11,39 +11,43 @@ keywords = ["apalis", "background-jobs", "task-queue", "sqlite", "async"]
 categories = ["asynchronous", "database"]
 
 [features]
-default = ["tokio-comp", "migrate", "json"]
+default = ["tokio-comp", "migrate", "json", "chrono"]
 migrate = ["sqlx/migrate", "sqlx/macros"]
 async-std-comp = ["async-std", "sqlx/runtime-async-std-rustls"]
 async-std-comp-native-tls = ["async-std", "sqlx/runtime-async-std-native-tls"]
 tokio-comp = ["tokio", "sqlx/runtime-tokio-rustls"]
 tokio-comp-native-tls = ["tokio", "sqlx/runtime-tokio-native-tls"]
 json = ["apalis-codec/json", "sqlx/json"]
+chrono = ["apalis-sql/chrono", "sqlx/chrono"]
+time = ["apalis-sql/time", "sqlx/time"]
 
 [dependencies.sqlx]
 version = "0.8.6"
 default-features = false
-features = ["chrono", "sqlite"]
+features = ["sqlite"]
 
 [dependencies]
 serde = { version = "1", features = ["derive"] }
 serde_json = { version = "1" }
-apalis-codec = { version = "0.1.0-rc.1", default-features = false }
-apalis-core = { version = "1.0.0-rc.1", features = ["sleep"] }
-apalis-sql = { version = "1.0.0-rc.1" }
+apalis-codec = { git = "https://github.com/apalis-dev/apalis", version = "0.1.0-rc.1", default-features = false }
+apalis-core = { git = "https://github.com/apalis-dev/apalis", version = "1.0.0-rc.1", features = [
+    "sleep",
+] }
+apalis-sql = { git = "https://github.com/apalis-dev/apalis", version = "1.0.0-rc.1", default-features = false }
 log = "0.4.21"
 futures = "0.3.30"
 tokio = { version = "1", features = ["rt", "net"], optional = true }
 async-std = { version = "1.13.0", optional = true }
-chrono = { version = "0.4", features = ["serde"] }
 thiserror = "2.0.0"
 pin-project = "1.1.10"
 ulid = { version = "1", features = ["serde"] }
 
 [dev-dependencies]
 tokio = { version = "1", features = ["macros", "rt-multi-thread"] }
-apalis = { version = "1.0.0-rc.1" }
-apalis-workflow = { version = "0.1.0-rc.1" }
+apalis = { git = "https://github.com/apalis-dev/apalis", version = "1.0.0-rc.1" }
+apalis-workflow = { git = "https://github.com/apalis-dev/apalis", version = "0.1.0-rc.1" }
 futures-util = "0.3.31"
+chrono = "0.4"
 
 [package.metadata.docs.rs]
 # defines the configuration attribute `docsrs`

examples/realtime.rs

@@ -7,7 +7,7 @@ async fn main() {
     let mut backend = SqliteStorage::new_with_callback(":memory:", &config);
 
     let pool = backend.pool();
-    SqliteStorage::setup(&pool).await.unwrap();
+    SqliteStorage::setup(pool).await.unwrap();
 
     backend.push(42).await.unwrap();
 

src/fetcher.rs

@@ -11,7 +11,7 @@ use apalis_core::{
     task::Task,
     worker::context::WorkerContext,
 };
-use apalis_sql::from_row::TaskRow;
+use apalis_sql::TaskRow;
 use futures::{FutureExt, future::BoxFuture, stream::Stream};
 use pin_project::pin_project;
 use sqlx::{Pool, Sqlite, SqlitePool};