diff --git a/beacon-chain/blockchain/log.go b/beacon-chain/blockchain/log.go index 2c9b60e3e7d2..3d0c469cf063 100644 --- a/beacon-chain/blockchain/log.go +++ b/beacon-chain/blockchain/log.go @@ -61,6 +61,14 @@ func logStateTransitionData(b interfaces.ReadOnlyBeaconBlock) error { txsPerSlotCount.Set(float64(len(txs))) } } + if b.Version() >= version.Deneb { + kzgs, err := b.Body().BlobKzgCommitments() + if err != nil { + log.WithError(err).Error("Failed to get blob KZG commitments") + } else if len(kzgs) > 0 { + log = log.WithField("blobCommitmentCount", len(kzgs)) + } + } log.Info("Finished applying state transition") return nil } @@ -88,10 +96,6 @@ func logBlockSyncStatus(block interfaces.ReadOnlyBeaconBlock, blockRoot [32]byte "chainServiceProcessedTime": prysmTime.Now().Sub(receivedTime), "deposits": len(block.Body().Deposits()), } - commits, err := block.Body().BlobKzgCommitments() - if err == nil { - lf["commitments"] = len(commits) - } log.WithFields(lf).Debug("Synced new block") } else { log.WithFields(logrus.Fields{ diff --git a/validator/client/propose.go b/validator/client/propose.go index 8165d4c2f382..2a3c075e75a6 100644 --- a/validator/client/propose.go +++ b/validator/client/propose.go @@ -175,6 +175,15 @@ func (v *validator) ProposeBlock(ctx context.Context, slot primitives.Slot, pubK } log = log.WithField("withdrawalCount", len(withdrawals)) } + if blk.Version() >= version.Deneb { + kzgs, err := blk.Block().Body().BlobKzgCommitments() + if err != nil { + log.WithError(err).Error("Failed to get blob KZG commitments") + return + } else if len(kzgs) != 0 { + log = log.WithField("blobCommitmentCount", len(kzgs)) + } + } } blkRoot := fmt.Sprintf("%#x", bytesutil.Trunc(blkResp.BlockRoot))