We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e23663a commit 15d3027Copy full SHA for 15d3027
synapse/storage/databases/main/deviceinbox.py
@@ -1000,11 +1000,11 @@ def _delete_old_federation_inbox_rows_txn(txn: LoggingTransaction) -> bool:
1000
ORDER BY received_ts ASC
1001
LIMIT ?
1002
)
1003
- DELETE FROM device_federation_inbox AS d
1004
- USING to_delete
+ DELETE FROM device_federation_inbox
1005
WHERE
1006
- d.origin = to_delete.origin
1007
- AND d.message_id = to_delete.message_id
+ (origin, message_id) IN (
+ SELECT origin, message_id FROM to_delete
+ )
1008
"""
1009
txn.execute(sql, (delete_before_ts, delete_limit))
1010
return txn.rowcount < delete_limit
0 commit comments