Skip to content
This repository was archived by the owner on Apr 26, 2024. It is now read-only.

Commit 55f587c

Browse files
committed
Rename txn functions with _txn suffix
1 parent 2531eee commit 55f587c

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

synapse/storage/databases/main/event_push_actions.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -516,7 +516,7 @@ async def get_unread_push_actions_for_user_in_range_for_http(
516516
),
517517
)
518518

519-
def get_push_actions(
519+
def get_push_actions_txn(
520520
txn: LoggingTransaction,
521521
) -> List[Tuple[str, str, int, str, bool]]:
522522
sql = """
@@ -533,7 +533,7 @@ def get_push_actions(
533533
return cast(List[Tuple[str, str, int, str, bool]], txn.fetchall())
534534

535535
push_actions = await self.db_pool.runInteraction(
536-
"get_unread_push_actions_for_user_in_range_http", get_push_actions
536+
"get_unread_push_actions_for_user_in_range_http", get_push_actions_txn
537537
)
538538

539539
notifs = [
@@ -590,7 +590,7 @@ async def get_unread_push_actions_for_user_in_range_for_email(
590590
),
591591
)
592592

593-
def get_push_actions(
593+
def get_push_actions_txn(
594594
txn: LoggingTransaction,
595595
) -> List[Tuple[str, str, int, str, bool, int]]:
596596
sql = """
@@ -609,7 +609,7 @@ def get_push_actions(
609609
return cast(List[Tuple[str, str, int, str, bool, int]], txn.fetchall())
610610

611611
push_actions = await self.db_pool.runInteraction(
612-
"get_unread_push_actions_for_user_in_range_email", get_push_actions
612+
"get_unread_push_actions_for_user_in_range_email", get_push_actions_txn
613613
)
614614

615615
# Make a list of dicts from the two sets of results.

0 commit comments

Comments
 (0)