Matrix-Mirrors/synapse-product
1
0
Fork 0
mirror of https://git.anonymousland.org/anonymousland/synapse-product.git synced 2024-10-01 08:25:44 -04:00
Code Issues Packages Projects Releases Wiki Activity

Print out the actual number of affected rows

Browse Source
This commit is contained in:
Brendan Abolivier 2019-11-01 12:07:05 +00:00
parent 824bba2f78
commit 3b29a73f9f
No known key found for this signature in database
GPG Key ID: 1E015C145F1916CD
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
synapse/storage/data_stores/main/events_bg_updates.py
View File

@ -527,7 +527,7 @@ class EventsBackgroundUpdatesStore(BackgroundUpdateStore):
rows = self.cursor_to_dict(txn) rows = self.cursor_to_dict(txn)
if not rows: if not rows:
return True return True, 0
for row in rows: for row in rows:
event_id = row["event_id"] event_id = row["event_id"]
@ -550,13 +550,13 @@ class EventsBackgroundUpdatesStore(BackgroundUpdateStore):
# We want to return true (to end the background update) only when # We want to return true (to end the background update) only when
# the query returned with less rows than we asked for. # the query returned with less rows than we asked for.
return len(rows) != batch_size return len(rows) != batch_size, len(rows)
end = yield self.runInteraction( end, num_rows = yield self.runInteraction(
desc="event_store_labels", func=_event_store_labels_txn desc="event_store_labels", func=_event_store_labels_txn
) )
if end: if end:
yield self._end_background_update("event_store_labels") yield self._end_background_update("event_store_labels")
return batch_size return num_rows