update

Author: cn-kali-team

Cargo.toml

@@ -2,7 +2,8 @@
 resolver = "2"
 members = [
     "asynq",
-    "asynq-macros"
+    "asynq-macros",
+    "asynq-server"
 ]
 [workspace.package]
 homepage = "https://github.com/emo-crab/asynq"

asynq-server/src/handler.rs

@@ -7,10 +7,9 @@ use crate::config::TenantConfig;
 use crate::error::{Error, Result};
 use crate::message::{
   AddToGroupRequest, AddToGroupUniqueRequest, AggregationCheckRequest, ArchiveRequest,
-  ClientMessage, DeleteAggregationSetRequest, DequeueRequest, EnqueueRequest,
-  EnqueueUniqueRequest, ListGroupsRequest, ReadAggregationSetRequest, RetryRequest,
-  ScheduleRequest, ScheduleUniqueRequest, ServerMessage, TaskDoneRequest, TaskInfoResponse,
-  TaskMessageResponse,
+  ClientMessage, DeleteAggregationSetRequest, DequeueRequest, EnqueueRequest, EnqueueUniqueRequest,
+  ListGroupsRequest, ReadAggregationSetRequest, RetryRequest, ScheduleRequest,
+  ScheduleUniqueRequest, ServerMessage, TaskDoneRequest, TaskInfoResponse, TaskMessageResponse,
 };
 use crate::server::CURRENT_TENANT;
 use asynq::base::Broker;
@@ -300,7 +299,13 @@ impl MessageHandler {
     let max_delay = Duration::from_secs(req.max_delay_seconds);
     let set_id = self
       .broker
-      .aggregation_check(&queue, &req.group, aggregation_delay, max_delay, req.max_size)
+      .aggregation_check(
+        &queue,
+        &req.group,
+        aggregation_delay,
+        max_delay,
+        req.max_size,
+      )
       .await?;
     Ok(ServerMessage::AggregationSetId(set_id))
   }
@@ -315,8 +320,10 @@ impl MessageHandler {
       .broker
       .read_aggregation_set(&queue, &req.group, &req.set_id)
       .await?;
-    let responses: Vec<TaskMessageResponse> =
-      tasks.iter().map(|msg| self.task_message_to_response(msg)).collect();
+    let responses: Vec<TaskMessageResponse> = tasks
+      .iter()
+      .map(|msg| self.task_message_to_response(msg))
+      .collect();
     Ok(ServerMessage::AggregationSet(responses))
   }
 

asynq/Cargo.toml

@@ -63,7 +63,6 @@ rand = "0.9"
 cron = "0.15.0"
 phf = { version = "0.13.1", features = ["macros"] }
 # PostgresSQL support (optional)
-sqlx = { version = "0.8", features = ["runtime-tokio", "postgres", "chrono"], optional = true }
 sea-orm = { version = "1.1", features = ["sqlx-postgres", "runtime-tokio-rustls", "macros"], optional = true }
 # Optional dependencies for WebSocket backend
 tokio-tungstenite = { version = "0.28", optional = true }
@@ -76,7 +75,7 @@ macros = ["asynq-macros"]
 cluster = ["redis/cluster-async"]
 sentinel = ["redis/sentinel"]
 tls = ["rustls", "redis/tls-rustls", "redis/tokio-rustls-comp", "redis/tls-rustls-webpki-roots", "redis/tls-rustls-insecure"]
-postgresql = ["sqlx", "sea-orm", "serde_json"]
+postgresql = ["sea-orm", "serde_json"]
 websocket = ["tokio-tungstenite", "base64", "serde_json"]
 acl = []
 

asynq/src/error.rs

@@ -21,12 +21,6 @@ pub enum Error {
   #[error("Redis parsing error: {0}")]
   RedisParsing(#[from] redis::ParsingError),
 
-  #[cfg(feature = "postgresql")]
-  /// PostgresSQL 错误 (sqlx)
-  /// PostgresSQL error (sqlx)
-  #[error("PostgresSQL error: {0}")]
-  Postgres(#[from] sqlx::Error),
-
   #[cfg(feature = "postgresql")]
   /// SeaORM 数据库错误
   /// SeaORM database error
@@ -216,8 +210,6 @@ impl Error {
       Error::InvalidMessage(_) => {}
       Error::Broker(_) => {}
       #[cfg(feature = "postgresql")]
-      Error::Postgres(_) => {}
-      #[cfg(feature = "postgresql")]
       Error::SeaOrm(_) => {}
       #[cfg(feature = "json")]
       Error::Serialization(_) => {}