diff --git a/dexbot/worker.py b/dexbot/worker.py
index 1f7571353..e5f68ed6c 100644
--- a/dexbot/worker.py
+++ b/dexbot/worker.py
@@ -131,6 +131,8 @@ def on_block(self, data):
                     self.workers[worker_name].error_ontick(e)
                 except Exception:
                     self.workers[worker_name].log.exception("in error_ontick()")
+            finally:
+                self.bitshares.txbuffer.clear()
         self.config_lock.release()
 
     def on_market(self, data):
@@ -154,6 +156,9 @@ def on_market(self, data):
                         self.workers[worker_name].error_onMarketUpdate(e)
                     except Exception:
                         self.workers[worker_name].log.exception("in error_onMarketUpdate()")
+                finally:
+                    self.bitshares.txbuffer.clear()
+
         self.config_lock.release()
 
     def on_account(self, account_update):
@@ -175,6 +180,8 @@ def on_account(self, account_update):
                         self.workers[worker_name].error_onAccount(e)
                     except Exception:
                         self.workers[worker_name].log.exception("in error_onAccountUpdate()")
+                finally:
+                    self.bitshares.txbuffer.clear()
         self.config_lock.release()
 
     def add_worker(self, worker_name, config):