diff --git a/src/processor.rs b/src/processor.rs
index e6e0c24..e6a15b7 100644
--- a/src/processor.rs
+++ b/src/processor.rs
@@ -44,7 +44,13 @@ impl<'a> Processor<'a> {
 
         log::info!("{messages_to_trash:?}");
         log::info!("Ready to run");
-        messages_to_trash.run(0).await
+        messages_to_trash.prepare(0).await?;
+        if self.execute {
+            log::warn!("***executing final delete messages***");
+            messages_to_trash.batch_trash().await
+        } else {
+            Ok(())
+        }
     }
 
     /// Delete the messages