diff --git a/core/chains/evm/txmgr/evm_tx_store.go b/core/chains/evm/txmgr/evm_tx_store.go index 51c9f98e884..e36ca611e16 100644 --- a/core/chains/evm/txmgr/evm_tx_store.go +++ b/core/chains/evm/txmgr/evm_tx_store.go @@ -567,7 +567,10 @@ func (o *evmTxStore) GetFatalTransactions(ctx context.Context) (txes []*Tx, err txes = make([]*Tx, len(dbEtxs)) dbEthTxsToEvmEthTxPtrs(dbEtxs, txes) err = o.LoadTxesAttempts(txes, pg.WithParentCtx(ctx), pg.WithQueryer(tx)) - return fmt.Errorf("failed to load evm.tx_attempts: %w", err) + if err != nil { + return fmt.Errorf("failed to load evm.tx_attempts: %w", err) + } + return nil }, pg.OptReadOnlyTx()) return txes, nil @@ -1277,7 +1280,10 @@ func (o *evmTxStore) GetNonFatalTransactions(ctx context.Context, chainID *big.I txes = make([]*Tx, len(dbEtxs)) dbEthTxsToEvmEthTxPtrs(dbEtxs, txes) err = o.LoadTxesAttempts(txes, pg.WithParentCtx(ctx), pg.WithQueryer(tx)) - return fmt.Errorf("failed to load evm.txes: %w", err) + if err != nil { + return fmt.Errorf("failed to load evm.txes: %w", err) + } + return nil }, pg.OptReadOnlyTx()) return txes, nil @@ -1302,7 +1308,10 @@ func (o *evmTxStore) GetTxByID(ctx context.Context, id int64) (txe *Tx, err erro } txe = txes[0] err = o.LoadTxesAttempts(txes, pg.WithParentCtx(ctx), pg.WithQueryer(tx)) - return fmt.Errorf("failed to load evm.tx_attempts: %w", err) + if err != nil { + return fmt.Errorf("failed to load evm.tx_attempts: %w", err) + } + return nil }, pg.OptReadOnlyTx()) return txe, nil