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

Commit 71c2f05

Browse files
committed
Use simplified upsert
1 parent 5268749 commit 71c2f05

File tree

1 file changed

+9
-12
lines changed

1 file changed

+9
-12
lines changed

synapse/storage/databases/main/event_federation.py

Lines changed: 9 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -1198,18 +1198,15 @@ def _delete_old_forward_extrem_cache_txn(txn):
11981198
)
11991199

12001200
async def insert_insertion_extremity(self, event_id: str, room_id: str) -> None:
1201-
def _insert_insertion_extremity_txn(txn):
1202-
self.db_pool.simple_insert_txn(
1203-
txn,
1204-
table="insertion_event_extremities",
1205-
values={
1206-
"event_id": event_id,
1207-
"room_id": room_id,
1208-
},
1209-
)
1210-
1211-
await self.db_pool.runInteraction(
1212-
"_insert_insertion_extremity_txn", _insert_insertion_extremity_txn
1201+
await self.db_pool.simple_upsert(
1202+
table="insertion_event_extremities",
1203+
keyvalues={"event_id": event_id},
1204+
values={
1205+
"event_id": event_id,
1206+
"room_id": room_id,
1207+
},
1208+
insertion_values={},
1209+
desc="insert_insertion_extremity",
12131210
)
12141211

12151212
async def insert_received_event_to_staging(

0 commit comments

Comments
 (0)