diff --git a/src/market_markers.rs b/src/market_markers.rs
index 91e0788..a0732d3 100644
--- a/src/market_markers.rs
+++ b/src/market_markers.rs
@@ -21,13 +21,13 @@ use solana_sdk::{
     compute_budget, hash::Hash, instruction::Instruction, message::Message, signature::Keypair,
     signer::Signer, transaction::Transaction,
 };
-use tokio::{sync::RwLock, task::JoinHandle};
+use tokio::{sync::RwLock, task::{JoinHandle, self}};
 
 use crate::{
     helpers::{to_sdk_instruction, to_sp_pk},
     mango::AccountKeys,
     states::{PerpMarketCache, TransactionSendRecord},
-    tpu_manager::TpuManager,
+    tpu_manager::{TpuManager, self},
 };
 
 pub fn create_ask_bid_transaction(
@@ -195,10 +195,13 @@ pub async fn send_mm_transactions(
             batch_to_send.push((tx, record));
         }
 
+        let tpu_manager = tpu_manager.clone();
+        task::spawn(async move{
+            if !tpu_manager.send_transaction_batch(&batch_to_send).await {
+                println!("sending failed on tpu client");
+            }
+        });
 
-        if !tpu_manager.send_transaction_batch(&batch_to_send).await {
-            println!("sending failed on tpu client");
-        }
     }
 }
 
diff --git a/src/tpu_manager.rs b/src/tpu_manager.rs
index 8083a0c..8dcfa91 100644
--- a/src/tpu_manager.rs
+++ b/src/tpu_manager.rs
@@ -144,29 +144,33 @@ impl TpuManager {
         tpu_client.send_transaction(transaction).await
     }
 
-       pub async fn send_transaction_batch(
+    pub async fn send_transaction_batch(
         &self,
         batch: &Vec<(solana_sdk::transaction::Transaction, TransactionSendRecord)>,
     ) -> bool {
         let tpu_client = self.get_tpu_client().await;
 
-
         for (tx, record) in batch {
+            self.stats.inc_send(&record.keeper_instruction);
 
-        self.stats
-            .inc_send(&record.keeper_instruction);
-
-        let tx_sent_record = self.tx_send_record.clone();
-        let sent = tx_sent_record.send(record.clone());
-        if sent.is_err() {
-            warn!(
-                "sending error on channel : {}",
-                sent.err().unwrap().to_string()
-            );
-        }
+            let tx_sent_record = self.tx_send_record.clone();
+            let sent = tx_sent_record.send(record.clone());
+            if sent.is_err() {
+                warn!(
+                    "sending error on channel : {}",
+                    sent.err().unwrap().to_string()
+                );
+            }
         }
 
-        tpu_client.try_send_wire_transaction_batch(batch.iter().map(|(tx, _)| serialize(tx).expect("serialization should succeed")).collect()).await.is_ok()
+        tpu_client
+            .try_send_wire_transaction_batch(
+                batch
+                    .iter()
+                    .map(|(tx, _)| serialize(tx).expect("serialization should succeed"))
+                    .collect(),
+            )
+            .await
+            .is_ok()
     }
-
 }