Fix: sol_unprocessed_txs was renamed to sol_retry_queue (#513)

rickyrombo · web-flow · commit c42c249a731e · 2025-10-29T14:35:51.000-07:00
diff --git a/api/solana_health.go b/api/solana_health.go
@@ -54,7 +54,7 @@ func (app *ApiServer) solanaHealth(c *fiber.Ctx) error {
 		LastIndexerUpdateAt: checkpoint.UpdatedAt,
 	}
 
-	err = app.pool.QueryRow(c.Context(), `SELECT COUNT(*) FROM sol_unprocessed_txs`).Scan(&health.UnprocessedCount)
+	err = app.pool.QueryRow(c.Context(), `SELECT COUNT(*) FROM sol_retry_queue`).Scan(&health.UnprocessedCount)
 	if err != nil {
 		if err == pgx.ErrNoRows {
 			health.UnprocessedCount = 0

Original file line number	Diff line number	Diff line change
`@@ -54,7 +54,7 @@ func (app ApiServer) solanaHealth(c fiber.Ctx) error {`
`54`	`54`	`LastIndexerUpdateAt: checkpoint.UpdatedAt,`
`55`	`55`	`}`
`56`	`56`
`57`		- err = app.pool.QueryRow(c.Context(), `SELECT COUNT(*) FROM sol_unprocessed_txs`).Scan(&health.UnprocessedCount)
	`57`	+ err = app.pool.QueryRow(c.Context(), `SELECT COUNT(*) FROM sol_retry_queue`).Scan(&health.UnprocessedCount)
`58`	`58`	`if err != nil {`
`59`	`59`	`if err == pgx.ErrNoRows {`
`60`	`60`	`health.UnprocessedCount = 0`