Hard delete block_failures after successful attempt

jakeloo · jakeloo · commit f32b60c1ffb3 · 2025-08-06T06:36:35.000Z
diff --git a/internal/storage/postgres.go b/internal/storage/postgres.go
@@ -185,8 +185,8 @@ func (p *PostgresConnector) DeleteBlockFailures(failures []common.BlockFailure)
 	}
 	defer tx.Rollback()
 
-	query := `UPDATE block_failures 
-	          SET is_deleted = TRUE, deleted_at = NOW(), updated_at = NOW()
+	// Hard delete for block failures
+	query := `DELETE FROM block_failures 
 	          WHERE chain_id = $1 AND block_number = $2`
 
 	stmt, err := tx.Prepare(query)

Original file line number	Diff line number	Diff line change
`@@ -185,8 +185,8 @@ func (p *PostgresConnector) DeleteBlockFailures(failures []common.BlockFailure)`
`185`	`185`	`}`
`186`	`186`	`defer tx.Rollback()`
`187`	`187`
`188`		- query := `UPDATE block_failures
`189`		`- SET is_deleted = TRUE, deleted_at = NOW(), updated_at = NOW()`
	`188`	`+ // Hard delete for block failures`
	`189`	+ query := `DELETE FROM block_failures
`190`	`190`	WHERE chain_id = $1 AND block_number = $2`
`191`	`191`
`192`	`192`	`stmt, err := tx.Prepare(query)`