From 3a6ff92ef1325381eadfd220b280b492c84cff1c Mon Sep 17 00:00:00 2001 From: jonny rhea Date: Mon, 19 Jan 2026 15:46:28 -0600 Subject: [PATCH] normalize span names --- core/blockchain.go | 4 ++-- eth/catalyst/api.go | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/core/blockchain.go b/core/blockchain.go index 186c144976..a2bf7f41cb 100644 --- a/core/blockchain.go +++ b/core/blockchain.go @@ -2161,7 +2161,7 @@ func (bc *BlockChain) ProcessBlock(ctx context.Context, parentRoot common.Hash, // Process block using the parent state as reference point pstart := time.Now() - pctx, _, spanEnd := telemetry.StartSpan(ctx, "core.Process") + pctx, _, spanEnd := telemetry.StartSpan(ctx, "bc.processor.Process") res, err := bc.processor.Process(pctx, block, statedb, bc.cfg.VmConfig) spanEnd(err) if err != nil { @@ -2171,7 +2171,7 @@ func (bc *BlockChain) ProcessBlock(ctx context.Context, parentRoot common.Hash, ptime := time.Since(pstart) vstart := time.Now() - _, _, spanEnd = telemetry.StartSpan(ctx, "core.ValidateState") + _, _, spanEnd = telemetry.StartSpan(ctx, "bc.validator.ValidateState") err = bc.validator.ValidateState(block, statedb, res, false) spanEnd(err) if err != nil { diff --git a/eth/catalyst/api.go b/eth/catalyst/api.go index c0c633d9ca..5fa0cf8b80 100644 --- a/eth/catalyst/api.go +++ b/eth/catalyst/api.go @@ -735,7 +735,7 @@ func (api *ConsensusAPI) newPayload(ctx context.Context, params engine.Executabl log.Trace("Engine API request received", "method", "NewPayload", "number", params.Number, "hash", params.BlockHash) attrs := executableDataAttrs(params) - _, _, spanEnd := telemetry.StartSpan(ctx, "engine.newPayload.ExecutableDataToBlock", attrs...) + _, _, spanEnd := telemetry.StartSpan(ctx, "engine.ExecutableDataToBlock", attrs...) block, err := engine.ExecutableDataToBlock(params, versionedHashes, beaconRoot, requests) spanEnd(err) if err != nil { @@ -810,7 +810,7 @@ func (api *ConsensusAPI) newPayload(ctx context.Context, params engine.Executabl return engine.PayloadStatusV1{Status: engine.ACCEPTED}, nil } log.Trace("Inserting block without sethead", "hash", block.Hash(), "number", block.Number()) - sctx, _, spanEnd := telemetry.StartSpan(ctx, "engine.newPayload.InsertBlockWithoutSetHead", attrs...) + sctx, _, spanEnd := telemetry.StartSpan(ctx, "api.eth.Blockchain().InsertBlockWithoutSetHead", attrs...) start := time.Now() proofs, err := api.eth.BlockChain().InsertBlockWithoutSetHead(sctx, block, witness) processingTime := time.Since(start)