Cleanup txbuffer if worker got disabled

Closes: #505
Codaone · Mar 18, 2020 · 86ed9d4 · 86ed9d4
1 parent a2a7e18
commit 86ed9d4
Showing 1 changed file with 7 additions and 0 deletions.
diff --git 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):