summary refs log tree commit diff
path: root/synapse/storage/databases/main/deviceinbox.py
diff options
context:
space:
mode:
authorDavid Robertson <davidr@element.io>2023-03-07 12:17:08 +0000
committerDavid Robertson <davidr@element.io>2023-03-07 12:17:08 +0000
commita95e906227aeb62224790bb7796313ebcd6db446 (patch)
tree916661272a63b1e86d05ab1a24a2b0a5ce223e25 /synapse/storage/databases/main/deviceinbox.py
parentMerge remote-tracking branch 'origin/release-v1.78' into matrix-org-hotfixes (diff)
parent1.79.0rc1 (diff)
downloadsynapse-a95e906227aeb62224790bb7796313ebcd6db446.tar.xz
Merge remote-tracking branch 'origin/release-v1.79' into matrix-org-hotfixes
Diffstat (limited to 'synapse/storage/databases/main/deviceinbox.py')
-rw-r--r--synapse/storage/databases/main/deviceinbox.py5
1 files changed, 2 insertions, 3 deletions
diff --git a/synapse/storage/databases/main/deviceinbox.py b/synapse/storage/databases/main/deviceinbox.py

index 24596425ab..994c50116f 100644 --- a/synapse/storage/databases/main/deviceinbox.py +++ b/synapse/storage/databases/main/deviceinbox.py
@@ -721,8 +721,8 @@ class DeviceInboxWorkerStore(SQLBaseStore): ], ) - for (user_id, messages_by_device) in edu["messages"].items(): - for (device_id, msg) in messages_by_device.items(): + for user_id, messages_by_device in edu["messages"].items(): + for device_id, msg in messages_by_device.items(): with start_active_span("store_outgoing_to_device_message"): set_tag(SynapseTags.TO_DEVICE_EDU_ID, edu["sender"]) set_tag(SynapseTags.TO_DEVICE_EDU_ID, edu["message_id"]) @@ -963,7 +963,6 @@ class DeviceInboxBackgroundUpdateStore(SQLBaseStore): def _remove_dead_devices_from_device_inbox_txn( txn: LoggingTransaction, ) -> Tuple[int, bool]: - if "max_stream_id" in progress: max_stream_id = progress["max_stream_id"] else: