From 9ee2fe76eac065ea442bb19e2c2785029c26eb95 Mon Sep 17 00:00:00 2001 From: Daniel Mancia <21249320+dmanc@users.noreply.github.com> Date: Mon, 16 Dec 2024 10:23:31 -0800 Subject: [PATCH] Use hex representation of operator ID in dispatcher logs (#1002) --- disperser/controller/dispatcher.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/disperser/controller/dispatcher.go b/disperser/controller/dispatcher.go index 8abbcf892f..231213fe48 100644 --- a/disperser/controller/dispatcher.go +++ b/disperser/controller/dispatcher.go @@ -17,6 +17,7 @@ import ( "github.com/Layr-Labs/eigenda/disperser/common/v2/blobstore" "github.com/Layr-Labs/eigensdk-go/logging" gethcommon "github.com/ethereum/go-ethereum/common" + "github.com/prometheus/client_golang/prometheus" ) var errNoBlobsToDispatch = errors.New("no blobs to dispatch") @@ -153,7 +154,7 @@ func (d *Dispatcher) HandleBatch(ctx context.Context) (chan core.SigningMessage, client, err := d.nodeClientManager.GetClient(host, dispersalPort) if err != nil { - d.logger.Error("failed to get node client", "operator", opID, "err", err) + d.logger.Error("failed to get node client", "operator", opID.Hex(), "err", err) continue } @@ -208,7 +209,7 @@ func (d *Dispatcher) HandleBatch(ctx context.Context) (chan core.SigningMessage, break } - d.logger.Warn("failed to send chunks", "operator", opID, "NumAttempts", i, "err", err) + d.logger.Warn("failed to send chunks", "operator", opID.Hex(), "NumAttempts", i, "err", err) time.Sleep(time.Duration(math.Pow(2, float64(i))) * time.Second) // Wait before retrying } d.metrics.reportSendChunksRetryCount(float64(i))