feat: use DateTime abstraction from apalis-sql

Cargo.toml

@@ -14,21 +14,22 @@ categories = ["asynchronous", "database", "network-programming"]
 publish = true
 
 [features]
-default = ["migrate", "tokio-comp"]
+default = ["migrate", "tokio-comp", "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"]
+chrono = ["apalis-sql/chrono", "sqlx/chrono"]
+time = ["apalis-sql/time", "sqlx/time"]
 
 [dependencies]
-apalis-core = { version = "1.0.0-rc.1", default-features = false, features = [
+apalis-core = { git = "https://github.com/apalis-dev/apalis", version = "1.0.0-rc.2", default-features = false, features = [
   "sleep",
 ] }
-apalis-sql = { version = "1.0.0-rc.1", default-features = false }
-apalis-codec = { version = "0.1.0-rc.1", features = ["json"] }
+apalis-sql = { git = "https://github.com/apalis-dev/apalis", version = "1.0.0-rc.2", default-features = false }
+apalis-codec = { git = "https://github.com/apalis-dev/apalis", version = "0.1.0-rc.2", features = ["json"] }
 serde = { version = "1", features = ["derive"], default-features = false }
-chrono = { version = "0.4", features = ["serde"], default-features = false }
 pin-project = "1.1.10"
 serde_json = "1"
 futures = "0.3.30"
@@ -44,11 +45,11 @@ ulid = { version = "1", features = ["serde"] }
 [dependencies.sqlx]
 version = "0.8.1"
 default-features = false
-features = ["chrono", "postgres", "json"]
+features = ["postgres", "json"]
 
 [dev-dependencies]
 tokio = { version = "1", features = ["macros", "rt-multi-thread"] }
 once_cell = "1.19.0"
-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.2" }
+apalis-workflow = { git = "https://github.com/apalis-dev/apalis", version = "0.1.0-rc.2" }
 futures-util = "0.3.30"

src/from_row.rs

@@ -1,4 +1,5 @@
-use chrono::{DateTime, Utc};
+use apalis_sql::{DateTime, TaskRow};
+
 #[derive(Debug)]
 pub struct PgTaskRow {
     pub job: Option<Vec<u8>>,
@@ -7,19 +8,19 @@ pub struct PgTaskRow {
     pub status: Option<String>,
     pub attempts: Option<i32>,
     pub max_attempts: Option<i32>,
-    pub run_at: Option<DateTime<Utc>>,
+    pub run_at: Option<DateTime>,
     pub last_result: Option<serde_json::Value>,
-    pub lock_at: Option<DateTime<Utc>>,
+    pub lock_at: Option<DateTime>,
     pub lock_by: Option<String>,
-    pub done_at: Option<DateTime<Utc>>,
+    pub done_at: Option<DateTime>,
     pub priority: Option<i32>,
     pub metadata: Option<serde_json::Value>,
 }
-impl TryInto<apalis_sql::from_row::TaskRow> for PgTaskRow {
+impl TryInto<TaskRow> for PgTaskRow {
     type Error = sqlx::Error;
 
-    fn try_into(self) -> Result<apalis_sql::from_row::TaskRow, Self::Error> {
-        Ok(apalis_sql::from_row::TaskRow {
+    fn try_into(self) -> Result<TaskRow, Self::Error> {
+        Ok(TaskRow {
             job: self.job.unwrap_or_default(),
             id: self
                 .id