bump: to v1.0.0-rc.11

CHANGELOG.md

@@ -7,7 +7,12 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [Unreleased]
 
+
+## [1.0.0-rc.11] - 2026-10-07
+
+- bump: to v1.0.0-rc.11
 - ci(deps): bump cargo-bins/cargo-binstall from 1.23.0 to 1.24.0 ([#115](https://github.com/apalis-dev/apalis-sqlite/pull/115))
+
 ## [1.0.0-rc.10] - 2026-10-02
 
 - fix: compile alongside sqlx PostgreSQL driver when pushing tasks (#112)

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "apalis-sqlite"
-version = "1.0.0-rc.10"
+version = "1.0.0-rc.11"
 authors = ["Njuguna Mureithi <mureithinjuguna@gmail.com>"]
 readme = "README.md"
 edition = "2024"
@@ -31,21 +31,21 @@ features = ["sqlite"]
 [dependencies]
 serde = { version = "1", features = ["derive"] }
 serde_json = { version = "1" }
-apalis-codec = { version = "0.1.0-rc.10", default-features = false }
-apalis-core = { version = "1.0.0-rc.10", features = ["sleep", "ulid"] }
+apalis-codec = { version = "0.1.0-rc.11", default-features = false }
+apalis-core = { version = "1.0.0-rc.11", features = ["sleep", "ulid"] }
 log = "0.4.34"
 futures = "0.3.34"
 tokio = { version = "1", features = ["rt", "net"], optional = true }
 async-std = { version = "1.13.2", optional = true }
-thiserror = "2.0.20"
+thiserror = "2.0.21"
 pin-project = "1.1.13"
 ulid = { version = "3", features = ["serde"] }
 
 [dev-dependencies]
 tokio = { version = "1", features = ["macros", "rt-multi-thread"] }
-apalis = { version = "1.0.0-rc.10", features = ["retry"] }
-apalis-workflow = { version = "0.1.0-rc.10" }
-apalis-codec = { version = "0.1.0-rc.10", features = ["msgpack", "bincode"] }
+apalis = { version = "1.0.0-rc.11", features = ["retry", "task-context"] }
+apalis-workflow = { version = "0.1.0-rc.11" }
+apalis-codec = { version = "0.1.0-rc.11", features = ["msgpack", "bincode"] }
 futures-util = "0.3.34"
 tracing-subscriber = { version = "0.3.23", features = ["env-filter"] }
 

examples/unique_jobs.rs

@@ -18,8 +18,8 @@ async fn main() {
     backend.push_task(task_2).await.unwrap();
 
     async fn task(task: u32, worker: WorkerContext) -> Result<(), BoxDynError> {
-        apalis_core::timer::sleep(std::time::Duration::from_secs(1)).await;
         assert_eq!(task, 42);
+        apalis_core::timer::sleep(std::time::Duration::from_secs(1)).await;
         worker.stop()?;
         Ok(())
     }

queries/backend/vacuum_before.sql

@@ -0,0 +1,16 @@
+DELETE from
+    Jobs
+WHERE
+    (
+        status = 'Done'
+        OR status = 'Killed'
+        OR (
+            status = 'Failed'
+            AND max_attempts <= attempts
+        )
+    )
+    AND (
+        run_at < datetime('now', '-' || ?1 || ' seconds')
+    );
+
+VACUUM;

src/queries/vacuum.rs

@@ -1,3 +1,5 @@
+use std::time::Duration;
+
 use apalis_core::backend::{Backend, Vacuum};
 
 use crate::{Error, SqliteStorage};
@@ -13,4 +15,14 @@ where
             .await?;
         Ok(res.rows_affected() as usize)
     }
+
+    async fn vacuum_before(&mut self, duration: Duration) -> Result<usize, Self::Error> {
+        let res = sqlx::query_file!(
+            "queries/backend/vacuum_before.sql",
+            duration.as_secs() as i64
+        )
+        .execute(&self.persistence.pool)
+        .await?;
+        Ok(res.rows_affected() as usize)
+    }
 }

src/queries/wait_for.rs

@@ -25,7 +25,7 @@ where
     O: Send + 'static + serde::de::DeserializeOwned,
 {
     type ResultStream = BoxStream<'static, Result<TaskResult<O>, Self::Error>>;
-    fn wait_for(&self, task_ids: impl IntoIterator<Item = TaskId>) -> Self::ResultStream {
+    fn wait_for(&mut self, task_ids: impl IntoIterator<Item = TaskId>) -> Self::ResultStream {
         let pool = self.persistence.pool.clone();
         let ids: HashSet<String> = task_ids.into_iter().map(|id| id.to_string()).collect();
 
@@ -74,7 +74,7 @@ where
 
     // Implementation of check_status
     fn check_status(
-        &self,
+        &mut self,
         task_ids: impl IntoIterator<Item = TaskId> + Send,
     ) -> impl Future<Output = Result<Vec<TaskResult<O>>, Self::Error>> + Send {
         let pool = self.persistence.pool.clone();

supply-chain/config.toml

@@ -16,23 +16,23 @@ version = "0.2.21"
 criteria = "safe-to-deploy"
 
 [[exemptions.apalis]]
-version = "1.0.0-rc.10"
+version = "1.0.0-rc.11"
 criteria = "safe-to-run"
 
 [[exemptions.apalis-codec]]
-version = "0.1.0-rc.10"
+version = "0.1.0-rc.11"
 criteria = "safe-to-deploy"
 
 [[exemptions.apalis-core]]
-version = "1.0.0-rc.10"
+version = "1.0.0-rc.11"
 criteria = "safe-to-deploy"
 
 [[exemptions.apalis-sqlite]]
 version = "1.0.0-rc.2"
 criteria = "safe-to-deploy"
 
 [[exemptions.apalis-workflow]]
-version = "0.1.0-rc.10"
+version = "0.1.0-rc.11"
 criteria = "safe-to-run"
 
 [[exemptions.async-channel]]
@@ -124,7 +124,7 @@ version = "1.12.1"
 criteria = "safe-to-deploy"
 
 [[exemptions.cc]]
-version = "1.5.1"
+version = "1.6.0"
 criteria = "safe-to-deploy"
 
 [[exemptions.cfg-if]]
@@ -184,7 +184,7 @@ version = "0.2.2"
 criteria = "safe-to-deploy"
 
 [[exemptions.ctutils]]
-version = "0.4.2"
+version = "0.4.3"
 criteria = "safe-to-deploy"
 
 [[exemptions.dashmap]]
@@ -208,7 +208,7 @@ version = "0.15.7"
 criteria = "safe-to-deploy"
 
 [[exemptions.either]]
-version = "1.18.0"
+version = "1.19.0"
 criteria = "safe-to-deploy"
 
 [[exemptions.equivalent]]
@@ -436,7 +436,7 @@ version = "1.5.1"
 criteria = "safe-to-run"
 
 [[exemptions.libc]]
-version = "0.2.189"
+version = "0.2.190"
 criteria = "safe-to-deploy"
 
 [[exemptions.libsqlite3-sys]]
@@ -472,7 +472,7 @@ version = "2.8.3"
 criteria = "safe-to-deploy"
 
 [[exemptions.mio]]
-version = "1.2.3"
+version = "1.2.4"
 criteria = "safe-to-deploy"
 
 [[exemptions.native-tls]]
@@ -776,7 +776,7 @@ version = "1.13.3"
 criteria = "safe-to-deploy"
 
 [[exemptions.tokio]]
-version = "1.53.1"
+version = "1.53.2"
 criteria = "safe-to-deploy"
 
 [[exemptions.tokio-macros]]
@@ -864,7 +864,7 @@ version = "1.0.4"
 criteria = "safe-to-deploy"
 
 [[exemptions.uuid]]
-version = "1.26.1"
+version = "1.27.0"
 criteria = "safe-to-deploy"
 
 [[exemptions.valuable]]
@@ -992,7 +992,7 @@ version = "0.1.8"
 criteria = "safe-to-deploy"
 
 [[exemptions.zeroize]]
-version = "1.9.0"
+version = "1.9.1"
 criteria = "safe-to-deploy"
 
 [[exemptions.zerotrie]]

supply-chain/imports.lock

@@ -28,3 +28,7 @@ audited_as = "1.0.0-rc.8"
 [[unpublished.apalis-sqlite]]
 version = "1.0.0-rc.10"
 audited_as = "1.0.0-rc.9"
+
+[[unpublished.apalis-sqlite]]
+version = "1.0.0-rc.11"
+audited_as = "1.0.0-rc.10"