imroving workers

oiwn · Feb 4, 2025 · 71d589c · 71d589c
1 parent c1932e7
commit 71d589c
Show file tree

Hide file tree

Showing 3 changed files with 352 additions and 121 deletions.
diff --git a/capp-queue/src/queue.rs b/capp-queue/src/queue.rs
@@ -18,7 +18,6 @@ where
     async fn pop(&self) -> Result<Task<Data>, TaskQueueError>;
     async fn ack(&self, task_id: &TaskId) -> Result<(), TaskQueueError>;
     async fn nack(&self, task: &Task<Data>) -> Result<(), TaskQueueError>;
-    // NOTE: probably need to move into different trait
     async fn set(&self, task: &Task<Data>) -> Result<(), TaskQueueError>;
 }
 

diff --git a/capp/Cargo.toml b/capp/Cargo.toml
@@ -47,10 +47,9 @@ serde_yaml = "0.9"
 rustis = { version = "0.13", features = ["tokio-runtime"], optional = true }
 mongodb = { version = "3", optional = true }
 sqlx = { version = "0.8", features = [ "runtime-tokio", "postgres", "json", "uuid", "chrono" ], optional = true }
-tracing-futures = "0.2"
 
 [dev-dependencies]
-capp = { path = ".", features = ["http", "router", "healthcheck", "mongodb", "redis", "postgres"] }
+capp = { path = ".", features = ["http", "router", "healthcheck", "mongodb", "redis"] }
 hyper = { version = "1.5", features = ["server", "http1"] }
 http-body-util = "0.1"
 bytes = "1.6"