diff --git a/internal/blocktx/store/postgresql/upsert_and_get_mined_transactions.go b/internal/blocktx/store/postgresql/upsert_and_get_mined_transactions.go index 58ce0ac61..00716e38b 100644 --- a/internal/blocktx/store/postgresql/upsert_and_get_mined_transactions.go +++ b/internal/blocktx/store/postgresql/upsert_and_get_mined_transactions.go @@ -39,7 +39,7 @@ func (p *PostgreSQL) UpsertAndGetMinedTransactions(ctx context.Context, txHashes rows, err := p.db.QueryContext(ctx, q, pq.Array(txHashes)) if err != nil { - return nil, errors.Join(store.ErrFailedToInsertTransactions, err) + return nil, errors.Join(store.ErrFailedToUpsertTransactions, err) } defer rows.Close() diff --git a/internal/blocktx/store/store.go b/internal/blocktx/store/store.go index 0ca0dea86..e0666a72e 100644 --- a/internal/blocktx/store/store.go +++ b/internal/blocktx/store/store.go @@ -16,7 +16,7 @@ var ( ErrUnableToDeleteRows = errors.New("unable to delete rows") ErrFailedToInsertBlock = errors.New("failed to insert block") ErrFailedToOpenDB = errors.New("failed to open postgres database") - ErrFailedToInsertTransactions = errors.New("failed to bulk insert transactions") + ErrFailedToUpsertTransactions = errors.New("failed to register and get mined transactions") ErrFailedToGetRows = errors.New("failed to get rows") ErrFailedToSetBlockProcessing = errors.New("failed to set block processing") ErrFailedToExecuteTxUpdateQuery = errors.New("failed to execute transaction update query")