Skip to content
This repository was archived by the owner on Apr 26, 2024. It is now read-only.

Commit 2dd67e1

Browse files
committed
Moar fixups
1 parent 2110d23 commit 2dd67e1

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

synapse/storage/databases/main/events_bg_updates.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -722,7 +722,7 @@ async def _chain_cover_index(self, progress: dict, batch_size: int) -> int:
722722
def _get_next_room(txn: Cursor) -> Optional[str]:
723723
sql = """
724724
SELECT room_id FROM rooms
725-
WHERE room_id > ? AND NOT has_auth_chain_index
725+
WHERE room_id > ? AND (NOT has_auth_chain_index or has_auth_chain_index IS NULL)
726726
ORDER BY room_id
727727
LIMIT 1
728728
"""
@@ -777,11 +777,11 @@ def _get_event_ids(txn: Cursor) -> List[Tuple[str, int, int]]:
777777

778778
if len(event_ids) < batch_size:
779779
await self.db_pool.updates._background_update_progress(
780-
"_chain_cover_index", {"current_room_id": current_room_id}
780+
"chain_cover", {"current_room_id": current_room_id}
781781
)
782782
else:
783783
await self.db_pool.updates._background_update_progress(
784-
"_chain_cover_index",
784+
"chain_cover",
785785
{
786786
"current_room_id": current_room_id,
787787
"last_depth": rows[-1][1],

0 commit comments

Comments
 (0)