summary refs log tree commit diff
path: root/synapse/storage/databases/main/pusher.py
diff options
context:
space:
mode:
authorreivilibre <38398653+reivilibre@users.noreply.github.com>2021-09-20 10:26:13 +0100
committerGitHub <noreply@github.com>2021-09-20 10:26:13 +0100
commit437961744c6c8761e6483bb215e5e779123ffd97 (patch)
tree73ca6a2ae76a0f52eabac3e8f923074716f76f80 /synapse/storage/databases/main/pusher.py
parentFix #10837 by adding JSON encoding/decoding to the Module API example… (#10... (diff)
downloadsynapse-437961744c6c8761e6483bb215e5e779123ffd97.tar.xz
Fix remove_stale_pushers job on SQLite. (#10843)
Diffstat (limited to 'synapse/storage/databases/main/pusher.py')
-rw-r--r--synapse/storage/databases/main/pusher.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/synapse/storage/databases/main/pusher.py b/synapse/storage/databases/main/pusher.py
index 63ac09c61d..a93caae8d0 100644
--- a/synapse/storage/databases/main/pusher.py
+++ b/synapse/storage/databases/main/pusher.py
@@ -324,7 +324,7 @@ class PusherWorkerStore(SQLBaseStore):
                 txn,
                 table="pushers",
                 column="user_name",
-                iterable=users,
+                values=users,
                 keyvalues={},
             )
 
@@ -373,7 +373,7 @@ class PusherWorkerStore(SQLBaseStore):
                 txn,
                 table="pushers",
                 column="id",
-                iterable=(pusher_id for pusher_id, token in pushers if token is None),
+                values=[pusher_id for pusher_id, token in pushers if token is None],
                 keyvalues={},
             )