From 55f587c6be3ad4acdb96c1b5746522830fea27b2 Mon Sep 17 00:00:00 2001 From: Nick Barrett Date: Tue, 23 Aug 2022 17:41:15 +0100 Subject: [PATCH] Rename txn functions with `_txn` suffix --- synapse/storage/databases/main/event_push_actions.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/synapse/storage/databases/main/event_push_actions.py b/synapse/storage/databases/main/event_push_actions.py index 751270f3dafd..16fa53838535 100644 --- a/synapse/storage/databases/main/event_push_actions.py +++ b/synapse/storage/databases/main/event_push_actions.py @@ -516,7 +516,7 @@ async def get_unread_push_actions_for_user_in_range_for_http( ), ) - def get_push_actions( + def get_push_actions_txn( txn: LoggingTransaction, ) -> List[Tuple[str, str, int, str, bool]]: sql = """ @@ -533,7 +533,7 @@ def get_push_actions( return cast(List[Tuple[str, str, int, str, bool]], txn.fetchall()) push_actions = await self.db_pool.runInteraction( - "get_unread_push_actions_for_user_in_range_http", get_push_actions + "get_unread_push_actions_for_user_in_range_http", get_push_actions_txn ) notifs = [ @@ -590,7 +590,7 @@ async def get_unread_push_actions_for_user_in_range_for_email( ), ) - def get_push_actions( + def get_push_actions_txn( txn: LoggingTransaction, ) -> List[Tuple[str, str, int, str, bool, int]]: sql = """ @@ -609,7 +609,7 @@ def get_push_actions( return cast(List[Tuple[str, str, int, str, bool, int]], txn.fetchall()) push_actions = await self.db_pool.runInteraction( - "get_unread_push_actions_for_user_in_range_email", get_push_actions + "get_unread_push_actions_for_user_in_range_email", get_push_actions_txn ) # Make a list of dicts from the two sets of results.