diff --git a/applications/tari_validator_node/src/p2p/services/mempool/service.rs b/applications/tari_validator_node/src/p2p/services/mempool/service.rs
index 92314f24e..e7ddf7f76 100644
--- a/applications/tari_validator_node/src/p2p/services/mempool/service.rs
+++ b/applications/tari_validator_node/src/p2p/services/mempool/service.rs
@@ -586,18 +586,9 @@ where
         };
 
         let current_epoch = self.epoch_manager.current_epoch().await?;
-        let local_committee_shard = self.epoch_manager.get_local_committee_shard(current_epoch).await?;
-        let is_input_shard = local_committee_shard.includes_any_shard(executed.transaction().all_inputs_iter());
 
         // TODO: Should we always propagate? The TX is initially send only to single output shard (TxReceipt).
         if should_propagate {
-            // Forward the transaction to any output shards that are not part of the input shard set as these have
-            // already been forwarded
-            let num_committees = self.epoch_manager.get_num_committees(current_epoch).await?;
-            let input_buckets = executed
-                .involved_shards_iter()
-                .map(|s| s.to_committee_bucket(num_committees))
-                .collect::<HashSet<_>>();
             // Should we propagate to everyone?
             let output_shards = executed
                 .resulting_outputs()