From ae43ad618b7c0f2e2db8ca881edc9f56b03917d2 Mon Sep 17 00:00:00 2001 From: Ian Shim Date: Mon, 8 Apr 2024 22:45:53 -0700 Subject: [PATCH] minor logging update --- core/aggregation.go | 1 - disperser/common/blobstore/shared_storage.go | 4 ++-- node/node.go | 2 +- 3 files changed, 3 insertions(+), 4 deletions(-) diff --git a/core/aggregation.go b/core/aggregation.go index b59ff835e6..3e156d24ff 100644 --- a/core/aggregation.go +++ b/core/aggregation.go @@ -152,7 +152,6 @@ func (a *StdSignatureAggregator) AggregateSignatures(ctx context.Context, state opInfo, ok := ops[r.Operator] // If operator is not in quorum, skip if !ok { - a.Logger.Error("Operator not found in quorum", "operatorID", operatorIDHex, "operatorAddress", operatorAddr, "socket", socket, "quorumID", quorumID) continue } operatorQuorums = append(operatorQuorums, quorumID) diff --git a/disperser/common/blobstore/shared_storage.go b/disperser/common/blobstore/shared_storage.go index a6fc8c8f6b..e107df6c78 100644 --- a/disperser/common/blobstore/shared_storage.go +++ b/disperser/common/blobstore/shared_storage.go @@ -137,12 +137,12 @@ func (s *SharedBlobStore) MarkBlobConfirmed(ctx context.Context, existingMetadat // TODO (ian-shim): remove this check once we are sure that the metadata is never overwritten refreshedMetadata, err := s.GetBlobMetadata(ctx, existingMetadata.GetBlobKey()) if err != nil { - s.logger.Error("[MarkBlobConfirmed] error getting blob metadata", "err", err) + s.logger.Error("error getting blob metadata", "err", err) return nil, err } alreadyConfirmed, _ := refreshedMetadata.IsConfirmed() if alreadyConfirmed { - s.logger.Warn("[MarkBlobConfirmed] trying to confirm blob already marked as confirmed", "blobKey", existingMetadata.GetBlobKey().String()) + s.logger.Warn("trying to confirm blob already marked as confirmed", "blobKey", existingMetadata.GetBlobKey().String()) return refreshedMetadata, nil } newMetadata := *existingMetadata diff --git a/node/node.go b/node/node.go index b54f6d7bd8..a2c6e3b817 100644 --- a/node/node.go +++ b/node/node.go @@ -185,7 +185,7 @@ func (n *Node) Start(ctx context.Context) error { socket := string(core.MakeOperatorSocket(n.Config.Hostname, n.Config.DispersalPort, n.Config.RetrievalPort)) if n.Config.RegisterNodeAtStart { n.Logger.Info("Registering node on chain with the following parameters:", "operatorId", - n.Config.ID, "hostname", n.Config.Hostname, "dispersalPort", n.Config.DispersalPort, + n.Config.ID.Hex(), "hostname", n.Config.Hostname, "dispersalPort", n.Config.DispersalPort, "retrievalPort", n.Config.RetrievalPort, "churnerUrl", n.Config.ChurnerUrl, "quorumIds", n.Config.QuorumIDList) socket := string(core.MakeOperatorSocket(n.Config.Hostname, n.Config.DispersalPort, n.Config.RetrievalPort)) privateKey, err := crypto.HexToECDSA(n.Config.EthClientConfig.PrivateKeyString)