Add test clean up

jonhoo · Nov 30, 2024 · 4b38e81 · 4b38e81
1 parent d31972e
commit 4b38e81
Showing 1 changed file with 9 additions and 2 deletions.
diff --git a/tests/real/community.rs b/tests/real/community.rs
@@ -800,7 +800,16 @@ async fn test_jobs_with_blocking_handlers() {
 async fn test_panic_and_errors_in_handler() {
     skip_check!();
 
+    // clean up
     let local = "test_panic_and_errors_in_handler";
+    let mut c = Client::connect().await.unwrap();
+    c.requeue(
+        MutationTarget::Retries,
+        MutationFilter::builder().kind(local).build(),
+    )
+    .await
+    .unwrap();
+    c.queue_remove(&[local]).await.unwrap();
 
     let mut w = Worker::builder::<io::Error>()
         //  sync handlers
@@ -839,8 +848,6 @@ async fn test_panic_and_errors_in_handler() {
         .await
         .unwrap();
 
-    let mut c = Client::connect().await.unwrap();
-
     c.enqueue_many([
         Job::builder("panic_SYNC_handler_str").queue(local).build(),
         Job::builder("panic_SYNC_handler_String")