Moar fixups

matrix-org · Jan 11, 2021 · 2dd67e1 · 2dd67e1
1 parent 2110d23
commit 2dd67e1
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/synapse/storage/databases/main/events_bg_updates.py b/synapse/storage/databases/main/events_bg_updates.py
@@ -722,7 +722,7 @@ async def _chain_cover_index(self, progress: dict, batch_size: int) -> int:
             def _get_next_room(txn: Cursor) -> Optional[str]:
                 sql = """
                     SELECT room_id FROM rooms
-                    WHERE room_id > ? AND NOT has_auth_chain_index
+                    WHERE room_id > ? AND (NOT has_auth_chain_index or has_auth_chain_index IS NULL)
                     ORDER BY room_id
                     LIMIT 1
                 """
@@ -777,11 +777,11 @@ def _get_event_ids(txn: Cursor) -> List[Tuple[str, int, int]]:
 
         if len(event_ids) < batch_size:
             await self.db_pool.updates._background_update_progress(
-                "_chain_cover_index", {"current_room_id": current_room_id}
+                "chain_cover", {"current_room_id": current_room_id}
             )
         else:
             await self.db_pool.updates._background_update_progress(
-                "_chain_cover_index",
+                "chain_cover",
                 {
                     "current_room_id": current_room_id,
                     "last_depth": rows[-1][1],