copyTrees: use for update skip locked to avoid deadlocks (#97)

ourzora · Jun 14, 2023 · 7a6f264 · 7a6f264 · vercel · Jun 14, 2023
1 parent fc31983
commit 7a6f264
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/cmd/api/main.go b/cmd/api/main.go
@@ -38,7 +38,9 @@ func copyTrees(ctx context.Context, db *pgxpool.Pool) {
 	t, err := db.Exec(ctx, `
 			insert into trees_proofs
 			(select root, proofs from trees
-			where root not in (select root from trees_proofs))
+			where root not in (select root from trees_proofs)
+			limit 5
+			for update skip locked)
 			`)
 
 	if err != nil {