diff --git a/hub/elastic_sync/service.py b/hub/elastic_sync/service.py
index d182a1a..093dd80 100644
--- a/hub/elastic_sync/service.py
+++ b/hub/elastic_sync/service.py
@@ -435,6 +435,11 @@ class ElasticSyncService(BlockchainReaderService):
                 for k, v in self.db.prefix_db.trending_notification.iterate(start=(batch_height,), stop=(batch_height+10000,)):
                     notifications[k.claim_hash].append(TrendingNotification(k.height, v.previous_amount, v.new_amount))
 
+                async for (k,), v in self.db.prefix_db.claim_to_txo.multi_get_async_gen(
+                        self._executor, [(claim_hash,) for claim_hash in notifications]):
+                    if not v:
+                        notifications.pop(k)
+
                 for claim_hash, trending in notifications.items():
                     yield self._update_trending_query(self.index, claim_hash, trending)
             self._trending.clear()
@@ -452,7 +457,7 @@ class ElasticSyncService(BlockchainReaderService):
                 else:
                     success += 1
                 if cnt % batch_size == 0:
-                    self.log.info(f"indexed {success} claims")
+                    self.log.info(f"indexed {success}/{cnt} claims")
             finished = True
             await self.sync_client.indices.refresh(self.index)
             self.log.info("indexed %i/%i claims", success, cnt)