Update _txn function to match outer method name

matrix-org · Jan 26, 2022 · d8b8f74 · d8b8f74
1 parent de48ab4
commit d8b8f74
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/synapse/storage/databases/main/deviceinbox.py b/synapse/storage/databases/main/deviceinbox.py
@@ -283,7 +283,7 @@ async def _get_device_messages(
                 # This user has new messages sent to them. Query messages for them
                 user_ids_to_query.add(user_id)
 
-        def get_new_device_messages_txn(txn: LoggingTransaction):
+        def get_device_messages_txn(txn: LoggingTransaction):
             # Build a query to select messages from any of the given devices that
             # are between the given stream id bounds.
 
@@ -371,7 +371,7 @@ def get_new_device_messages_txn(txn: LoggingTransaction):
             return recipient_device_to_messages, to_stream_id
 
         return await self.db_pool.runInteraction(
-            "get_new_device_messages", get_new_device_messages_txn
+            "get_device_messages", get_device_messages_txn
         )
 
     @trace