fix: tests failing because of tests

geofmureithi · Jul 16, 2024 · 3634805 · 3634805
1 parent e0c6e25
commit 3634805
Show file tree

Hide file tree

Showing 4 changed files with 9 additions and 0 deletions.
diff --git a/packages/apalis-redis/src/storage.rs b/packages/apalis-redis/src/storage.rs
@@ -1082,6 +1082,7 @@ mod tests {
                 acknowledger: job_id.clone(),
                 result: Ok("Success".to_string()),
                 worker: worker_id.clone(),
+                attempts: Attempt::new_with_value(0)
             })
             .await
             .expect("failed to acknowledge the job");

diff --git a/packages/apalis-sql/src/mysql.rs b/packages/apalis-sql/src/mysql.rs
@@ -513,6 +513,7 @@ mod tests {
     use crate::context::State;
 
     use super::*;
+    use apalis_core::task::attempt::Attempt;
     use email_service::Email;
     use futures::StreamExt;
 
@@ -646,6 +647,7 @@ mod tests {
                 acknowledger: job_id.clone(),
                 result: Ok("Success".to_string()),
                 worker: worker_id.clone(),
+                attempts: Attempt::new_with_value(0)
             })
             .await
             .expect("failed to acknowledge the job");

diff --git a/packages/apalis-sql/src/postgres.rs b/packages/apalis-sql/src/postgres.rs
@@ -611,6 +611,7 @@ mod tests {
     use crate::context::State;
 
     use super::*;
+    use apalis_core::task::attempt::Attempt;
     use email_service::Email;
     use chrono::Utc;
 
@@ -729,6 +730,8 @@ mod tests {
                 acknowledger: job_id.clone(),
                 result: Ok("Success".to_string()),
                 worker: worker_id.clone(),
+                attempts: Attempt::new_with_value(0)
+
             })
             .await
             .expect("failed to acknowledge the job");

diff --git a/packages/apalis-sql/src/sqlite.rs b/packages/apalis-sql/src/sqlite.rs
@@ -505,6 +505,7 @@ mod tests {
     use crate::context::State;
 
     use super::*;
+    use apalis_core::task::attempt::Attempt;
     use email_service::Email;
     use futures::StreamExt;
     use chrono::Utc;
@@ -619,6 +620,8 @@ mod tests {
                 acknowledger: job_id.clone(),
                 result: Ok("Success".to_string()),
                 worker: worker_id.clone(),
+                attempts: Attempt::new_with_value(0)
+
             })
             .await
             .expect("failed to acknowledge the job");