diff --git a/confluent_server/confluent/plugins/console/megasol.py b/confluent_server/confluent/plugins/console/megasol.py
index c6467f98..f007477e 100644
--- a/confluent_server/confluent/plugins/console/megasol.py
+++ b/confluent_server/confluent/plugins/console/megasol.py
@@ -152,6 +152,7 @@ class TsmConsole(conapi.Console):
         if self.ws:
             self.ws.close()
         self.connected = False
+        self.datacallback = None
 
 def create(nodes, element, configmanager, inputdata):
     if len(nodes) == 1: