diff --git a/node/pkg/accountant/accountant.go b/node/pkg/accountant/accountant.go index 7f2d6d207..281de7a43 100644 --- a/node/pkg/accountant/accountant.go +++ b/node/pkg/accountant/accountant.go @@ -292,12 +292,10 @@ func (acct *Accountant) publishTransferAlreadyLocked(pe *pendingEntry) { // addPendingTransferAlreadyLocked adds a pending transfer to both the map and the database. It assumes the caller holds the lock. func (acct *Accountant) addPendingTransferAlreadyLocked(pe *pendingEntry) error { - acct.logger.Info("writing transfer to database", zap.String("msgId", pe.msgId)) pe.setUpdTime() if err := acct.db.AcctStorePendingTransfer(pe.msg); err != nil { return err } - acct.logger.Info("wrote message to database", zap.String("msgId", pe.msgId)) acct.pendingTransfers[pe.msgId] = pe transfersOutstanding.Set(float64(len(acct.pendingTransfers))) diff --git a/node/pkg/governor/governor.go b/node/pkg/governor/governor.go index c0f7ccf1b..300271eb9 100644 --- a/node/pkg/governor/governor.go +++ b/node/pkg/governor/governor.go @@ -393,7 +393,6 @@ func (gov *ChainGovernor) ProcessMsgForTime(msg *common.MessagePublication, now if enqueueIt { dbData := db.PendingTransfer{ReleaseTime: releaseTime, Msg: *msg} - gov.logger.Info("writing pending transfer to database", zap.String("msgId", msg.MessageIDString())) err = gov.db.StorePendingMsg(&dbData) if err != nil { gov.logger.Error("failed to store pending vaa", @@ -404,7 +403,6 @@ func (gov *ChainGovernor) ProcessMsgForTime(msg *common.MessagePublication, now ) return false, err } - gov.logger.Info("wrote pending transfer to database", zap.String("msgId", msg.MessageIDString())) ce.pending = append(ce.pending, &pendingEntry{token: token, amount: payload.Amount, hash: hash, dbData: dbData}) gov.msgsSeen[hash] = transferEnqueued