From 0347c66c33c6c8653f95354c247c4f2cb2a3ffba Mon Sep 17 00:00:00 2001 From: Sebastian Stammler Date: Tue, 14 Jan 2025 20:29:54 +0100 Subject: [PATCH] op-node/rollup/derive: add info logging (#13753) --- op-node/rollup/derive/channel_assembler.go | 1 + op-node/rollup/derive/channel_in_reader.go | 4 ++-- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/op-node/rollup/derive/channel_assembler.go b/op-node/rollup/derive/channel_assembler.go index be821ca955f4..c6e92f5ec5da 100644 --- a/op-node/rollup/derive/channel_assembler.go +++ b/op-node/rollup/derive/channel_assembler.go @@ -96,6 +96,7 @@ func (ca *ChannelAssembler) NextRawChannel(ctx context.Context) ([]byte, error) if frame.FrameNumber == 0 { ca.metrics.RecordHeadChannelOpened() ca.channel = NewChannel(frame.ID, origin, true) + lgr.Info("created new channel") } if frame.FrameNumber > 0 && ca.channel == nil { lgr.Warn("dropping non-first frame without channel", diff --git a/op-node/rollup/derive/channel_in_reader.go b/op-node/rollup/derive/channel_in_reader.go index cdb648c3b870..ed4c12361a33 100644 --- a/op-node/rollup/derive/channel_in_reader.go +++ b/op-node/rollup/derive/channel_in_reader.go @@ -105,7 +105,7 @@ func (cr *ChannelInReader) NextBatch(ctx context.Context) (Batch, error) { if err != nil { return nil, err } - batch.LogContext(cr.log).Debug("decoded singular batch from channel", "stage_origin", cr.Origin()) + batch.LogContext(cr.log).Info("decoded singular batch from channel", "stage_origin", cr.Origin()) cr.metrics.RecordDerivedBatches("singular") return batch, nil case SpanBatchType: @@ -119,7 +119,7 @@ func (cr *ChannelInReader) NextBatch(ctx context.Context) (Batch, error) { if err != nil { return nil, err } - batch.LogContext(cr.log).Debug("decoded span batch from channel", "stage_origin", cr.Origin()) + batch.LogContext(cr.log).Info("decoded span batch from channel", "stage_origin", cr.Origin()) cr.metrics.RecordDerivedBatches("span") return batch, nil default: