Skip to content

Commit 8fe9059

Browse files
authored
try fix
1 parent 1f4c9a3 commit 8fe9059

File tree

1 file changed

+8
-1
lines changed

1 file changed

+8
-1
lines changed

frameworks/Python/blacksheep/app-socketify.py

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -116,7 +116,14 @@ async def db_updates_test(request,queries):
116116
for row_id, number in updates:
117117
await cursor.execute(READ_ROW_SQL, (row_id,))
118118
await cursor.fetchone()
119-
await cursor.executemany(WRITE_ROW_SQL, [(number, row_id) for row_id, number in updates])
119+
for _ in range(5):
120+
try:
121+
await cursor.executemany(WRITE_ROW_SQL, [(number, row_id) for row_id, number in updates])
122+
break
123+
except psycopg.errors.DeadlockDetected:
124+
await db_conn.rollback()
125+
continue
126+
# await cursor.executemany(WRITE_ROW_SQL, [(number, row_id) for row_id, number in updates])
120127
return bs.json(worlds)
121128

122129
@bs.get('/plaintext')

0 commit comments

Comments
 (0)