diff --git a/src/mempool.rs b/src/mempool.rs
index a4ff0f39..05f96a50 100644
--- a/src/mempool.rs
+++ b/src/mempool.rs
@@ -34,6 +34,7 @@ use std::{
     sync::Arc,
 };
 use storage::{DataProposalVerdict, LaneEntry, Storage};
+use tokio::task::{futures, JoinHandle, JoinSet};
 // Pick one of the two implementations
 // use storage_memory::LanesStorage;
 use storage_fjall::LanesStorage;
@@ -112,6 +113,7 @@ pub struct MempoolStore {
 pub struct Mempool {
     bus: MempoolBusClient,
     file: Option<PathBuf>,
+    blocker: JoinSet<()>,
     conf: SharedConf,
     crypto: SharedBlstCrypto,
     metrics: MempoolMetrics,
@@ -235,6 +237,7 @@ impl Module for Mempool {
             bus,
             file: Some(ctx.common.config.data_directory.clone()),
             conf: ctx.common.config.clone(),
+            blocker: JoinSet::new()
             metrics,
             crypto: Arc::clone(&ctx.node.crypto),
             lanes: LanesStorage::new(