diff options
| author | Erik Johnston <erik@matrix.org> | 2021-01-21 14:44:12 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-01-21 14:44:12 +0000 |
| commit | 7a43482f1916622967f5a4b389f93944dd5deb07 (patch) | |
| tree | 067807264e4296afce13edae43743bc0ee281928 /synapse/storage/databases/main/roommember.py | |
| parent | Add tests for List Users Admin API (#9045) (diff) | |
| download | synapse-7a43482f1916622967f5a4b389f93944dd5deb07.tar.xz | |
Use execute_batch in more places (#9188)
* Use execute_batch in more places * Newsfile
Diffstat (limited to 'synapse/storage/databases/main/roommember.py')
| -rw-r--r-- | synapse/storage/databases/main/roommember.py | 6 |
1 files changed, 1 insertions, 5 deletions
diff --git a/synapse/storage/databases/main/roommember.py b/synapse/storage/databases/main/roommember.py index dcdaf09682..92382bed28 100644 --- a/synapse/storage/databases/main/roommember.py +++ b/synapse/storage/databases/main/roommember.py @@ -873,8 +873,6 @@ class RoomMemberBackgroundUpdateStore(SQLBaseStore): "max_stream_id_exclusive", self._stream_order_on_start + 1 ) - INSERT_CLUMP_SIZE = 1000 - def add_membership_profile_txn(txn): sql = """ SELECT stream_ordering, event_id, events.room_id, event_json.json @@ -915,9 +913,7 @@ class RoomMemberBackgroundUpdateStore(SQLBaseStore): UPDATE room_memberships SET display_name = ?, avatar_url = ? WHERE event_id = ? AND room_id = ? """ - for index in range(0, len(to_update), INSERT_CLUMP_SIZE): - clump = to_update[index : index + INSERT_CLUMP_SIZE] - txn.executemany(to_update_sql, clump) + txn.execute_batch(to_update_sql, to_update) progress = { "target_min_stream_id_inclusive": target_min_stream_id, |