diff --git a/frappe/database/database.py b/frappe/database/database.py
index 7e82340d23..7e702a8862 100644
--- a/frappe/database/database.py
+++ b/frappe/database/database.py
@@ -994,6 +994,9 @@ class Database:
 				if hasattr(obj, "on_rollback"):
 					obj.on_rollback()
 			frappe.local.rollback_observers = []
+		
+			frappe.local.realtime_log = []
+			frappe.flags.enqueue_after_commit = []
 
 	def field_exists(self, dt, fn):
 		"""Return true of field exists."""