diff --git a/lbry/wallet/server/mempool.py b/lbry/wallet/server/mempool.py
index 22ebe6e98..ce08f7446 100644
--- a/lbry/wallet/server/mempool.py
+++ b/lbry/wallet/server/mempool.py
@@ -210,6 +210,15 @@ class MemPool:
 
         return deferred, {prevout: utxo_map[prevout] for prevout in unspent}
 
+    async def _mempool_loop(self, synchronized_event):
+        try:
+            return await self._refresh_hashes(synchronized_event)
+        except asyncio.CancelledError:
+            raise
+        except Exception as e:
+            self.logger.exception("MEMPOOL DIED")
+            raise e
+
     async def _refresh_hashes(self, synchronized_event):
         """Refresh our view of the daemon's mempool."""
         while True:
@@ -326,7 +335,7 @@ class MemPool:
     async def keep_synchronized(self, synchronized_event):
         """Keep the mempool synchronized with the daemon."""
         await asyncio.wait([
-            self._refresh_hashes(synchronized_event),
+            self._mempool_loop(synchronized_event),
             # self._refresh_histogram(synchronized_event),
             self._logging(synchronized_event)
         ])