enhance worker connection failure logging (#403)

* log core number and multiaddr upon worker connection failure

* adjust tag name

---------

Co-authored-by: Cassandra Heart <7929478+CassOnMars@users.noreply.github.com>
This commit is contained in:
Black Swan 2024-12-08 05:20:18 +02:00 committed by GitHub
parent 99bc683145
commit 25fc33b7e5
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194

View File

@ -940,7 +940,8 @@ func (e *DataClockConsensusEngine) createParallelDataClientsFromList() (
clients := make([]protobufs.DataIPCServiceClient, parallelism)
for i := 0; i < parallelism; i++ {
ma, err := multiaddr.NewMultiaddr(e.config.Engine.DataWorkerMultiaddrs[i])
wma := e.config.Engine.DataWorkerMultiaddrs[i]
ma, err := multiaddr.NewMultiaddr(wma)
if err != nil {
panic(err)
}
@ -966,7 +967,7 @@ func (e *DataClockConsensusEngine) createParallelDataClientsFromList() (
grpc.WithBlock(),
)
if err != nil {
e.logger.Error("could not dial", zap.Error(err))
e.logger.Error("could not dial", zap.Int("core", i), zap.String("worker_multiaddr", wma), zap.Error(err))
continue
}