summary refs log tree commit diff
path: root/synapse/storage
diff options
context:
space:
mode:
authorAndrew Morgan <andrew@amorgan.xyz>2021-09-01 10:56:17 +0100
committerAndrew Morgan <andrew@amorgan.xyz>2021-09-01 10:56:17 +0100
commitca2e5b2060df3b922c6764f66d0f4501d0fb1cb1 (patch)
tree88969bd5f6bb2bb83d71413dcaeb8769f0b0abea /synapse/storage
parentMerge remote-tracking branch 'origin/develop' into matrix-org-hotfixes (diff)
parentFix iteration in _remove_deleted_email_pushers background job. (#10734) (diff)
downloadsynapse-ca2e5b2060df3b922c6764f66d0f4501d0fb1cb1.tar.xz
Merge branch 'release-v1.42' of github.com:matrix-org/synapse into matrix-org-hotfixes
Diffstat (limited to 'synapse/storage')
-rw-r--r--synapse/storage/databases/main/pusher.py3
-rw-r--r--synapse/storage/schema/main/delta/63/03session_store.sql (renamed from synapse/storage/schema/main/delta/62/02session_store.sql)0
2 files changed, 2 insertions, 1 deletions
diff --git a/synapse/storage/databases/main/pusher.py b/synapse/storage/databases/main/pusher.py

index e47caa2125..63ac09c61d 100644 --- a/synapse/storage/databases/main/pusher.py +++ b/synapse/storage/databases/main/pusher.py
@@ -430,10 +430,11 @@ class PusherWorkerStore(SQLBaseStore): """ txn.execute(sql, (last_pusher, batch_size)) + rows = txn.fetchall() last = None num_deleted = 0 - for row in txn: + for row in rows: last = row[0] num_deleted += 1 self.db_pool.simple_delete_txn( diff --git a/synapse/storage/schema/main/delta/62/02session_store.sql b/synapse/storage/schema/main/delta/63/03session_store.sql
index 535fb34c10..535fb34c10 100644 --- a/synapse/storage/schema/main/delta/62/02session_store.sql +++ b/synapse/storage/schema/main/delta/63/03session_store.sql