close rows

casperholders · Jan 4, 2024 · 94fe617 · 94fe617
1 parent 421cb6f
commit 94fe617
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/db/db.go b/db/db.go
@@ -292,7 +292,8 @@ func (db *DB) InsertRewards(ctx context.Context, rowsToInsert [][]interface{}) e
 	)
 	if err != nil || count < int64(len(rowsToInsert)) {
 		const sql = `DELETE FROM rewards WHERE block = $1;`
-		_, errD := db.Postgres.Query(ctx, sql, rowsToInsert[0][0])
+		rows, errD := db.Postgres.Query(ctx, sql, rowsToInsert[0][0])
+		defer rows.Close()
 		if db.checkErr(errD) != nil {
 			return db.checkErr(errD)
 		}