diff --git a/node/pkg/processor/cleanup.go b/node/pkg/processor/cleanup.go index 7d4d262f3..e9de1ae53 100644 --- a/node/pkg/processor/cleanup.go +++ b/node/pkg/processor/cleanup.go @@ -230,7 +230,6 @@ func (p *Processor) handleCleanup(ctx context.Context) { oldestTime := time.Now().Add(-time.Hour) for key, pe := range p.pythnetVaas { if pe.updateTime.Before(oldestTime) { - p.logger.Debug("PYTHNET: dropping old pythnet vaa", zap.String("message_id", key), zap.Stringer("updateTime", pe.updateTime)) delete(p.pythnetVaas, key) } } diff --git a/node/pkg/processor/processor.go b/node/pkg/processor/processor.go index aed19a7aa..f4d06abd8 100644 --- a/node/pkg/processor/processor.go +++ b/node/pkg/processor/processor.go @@ -235,7 +235,6 @@ func (p *Processor) Run(ctx context.Context) error { func (p *Processor) storeSignedVAA(v *vaa.VAA) error { if v.EmitterChain == vaa.ChainIDPythNet { key := fmt.Sprintf("%v/%v", v.EmitterAddress, v.Sequence) - p.logger.Debug("PYTHNET: storing pythnet vaa", zap.String("message_id", key)) p.pythnetVaas[key] = PythNetVaaEntry{v: v, updateTime: time.Now()} return nil } @@ -247,11 +246,9 @@ func (p *Processor) getSignedVAA(id db.VAAID) (*vaa.VAA, error) { key := fmt.Sprintf("%v/%v", id.EmitterAddress, id.Sequence) ret, exists := p.pythnetVaas[key] if exists { - p.logger.Debug("PYTHNET: found pythnet vaa", zap.String("message_id", key)) return ret.v, nil } - p.logger.Debug("PYTHNET: did not find pythnet vaa", zap.String("message_id", key)) return nil, db.ErrVAANotFound }