Matrix-Mirrors/synapse-product
1
0
Fork 0
mirror of https://git.anonymousland.org/anonymousland/synapse-product.git synced 2024-12-24 22:49:29 -05:00
Code Issues Packages Projects Releases Wiki Activity

Initialise value before looping

Browse Source
This commit is contained in:
Brendan Abolivier 2019-11-07 16:18:40 +00:00
parent bb78276bdc
commit ec2cb9f298
No known key found for this signature in database
GPG Key ID: 1E015C145F1916CD
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -526,28 +526,32 @@ class EventsBackgroundUpdatesStore(BackgroundUpdateStore):
) )
nbrows = 0 nbrows = 0
for (event_id, event_json) in txn: last_row_event_id = ""
for (event_id, event_json_raw) in txn:
event_json = json.loads(event_json_raw)
self._simple_insert_many_txn( self._simple_insert_many_txn(
txn=txn, txn=txn,
table="event_labels", table="event_labels",
values=[ values=[
{ {
"event_id": event_id, "event_id": event_id,
"label": str(label), "label": label,
"room_id": event_json["room_id"], "room_id": event_json["room_id"],
"topological_ordering": event_json["depth"], "topological_ordering": event_json["depth"],
} }
for label in event_json["content"].get( for label in event_json["content"].get(
EventContentFields.LABELS, [] EventContentFields.LABELS, []
) )
if label is not None if label is not None and isinstance(label, str)
], ],
) )
nbrows += 1 nbrows += 1
last_row_event_id = event_id
self._background_update_progress_txn( self._background_update_progress_txn(
txn, "event_store_labels", {"last_event_id": event_id} txn, "event_store_labels", {"last_event_id": last_row_event_id}
) )
return nbrows return nbrows