op-node/rollup/derive: add info logging (#13753)

ethereum-optimism · Jan 15, 2025 · 0347c66 · 0347c66
1 parent d987ba1
commit 0347c66
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git 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
@@ -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: