From 0d23b18114f9b12dd1f3d34be1c231f03a6a170d Mon Sep 17 00:00:00 2001 From: geofmureithi Date: Sat, 3 Aug 2024 15:36:05 +0300 Subject: [PATCH] fix: minor updates --- packages/apalis-sql/src/lib.rs | 5 +---- packages/apalis-sql/src/sqlite.rs | 2 +- 2 files changed, 2 insertions(+), 5 deletions(-) diff --git a/packages/apalis-sql/src/lib.rs b/packages/apalis-sql/src/lib.rs index b0aaa47..b671bb1 100644 --- a/packages/apalis-sql/src/lib.rs +++ b/packages/apalis-sql/src/lib.rs @@ -164,10 +164,7 @@ macro_rules! sql_storage_tests { .unwrap(); let (job_id, res) = storage.execute_next().await; - assert_eq!( - res, - Err("AbortError: Invalid character.".to_owned()) - ); + assert_eq!(res, Err("AbortError: Invalid character.".to_owned())); apalis_core::sleep(Duration::from_secs(1)).await; let job = storage.fetch_by_id(&job_id).await.unwrap().unwrap(); let ctx = job.get::().unwrap(); diff --git a/packages/apalis-sql/src/sqlite.rs b/packages/apalis-sql/src/sqlite.rs index c88ac83..27dcb2a 100644 --- a/packages/apalis-sql/src/sqlite.rs +++ b/packages/apalis-sql/src/sqlite.rs @@ -667,7 +667,7 @@ mod tests { assert!(ctx.done_at().is_none()); assert!(ctx.lock_by().is_some()); assert!(ctx.lock_at().is_some()); - assert_eq!(*ctx.last_error(), Some("".to_string())); //TODO: Fix this + assert_eq!(*ctx.last_error(), None); } #[tokio::test]