diff --git a/lbry/wallet/server/session.py b/lbry/wallet/server/session.py
index 6009009b2..4a415ba38 100644
--- a/lbry/wallet/server/session.py
+++ b/lbry/wallet/server/session.py
@@ -660,7 +660,7 @@ class SessionManager:
         if touched or (height_changed and self.mempool_statuses):
             notified_hashxs = 0
             notified_sessions = 0
-            to_notify = touched.union(self.mempool_statuses.keys() if height_changed else new_touched.intersection(self.mempool_statuses.keys()))
+            to_notify = touched if height_changed else new_touched
             for hashX in to_notify:
                 for session_id in self.hashx_subscriptions_by_session[hashX]:
                     asyncio.create_task(self.sessions[session_id].send_history_notification(hashX))