diff options
Diffstat (limited to 'weed/mq/topic/local_partition.go')
| -rw-r--r-- | weed/mq/topic/local_partition.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/mq/topic/local_partition.go b/weed/mq/topic/local_partition.go index d1433775a..00ea04eee 100644 --- a/weed/mq/topic/local_partition.go +++ b/weed/mq/topic/local_partition.go @@ -155,7 +155,7 @@ func (p *LocalPartition) MaybeConnectToFollowers(initMessage *mq_pb.PublishMessa followerClient := mq_pb.NewSeaweedMessagingClient(p.followerGrpcConnection) p.publishFolloweMeStream, err = followerClient.PublishFollowMe(ctx) if err != nil { - return fmt.Errorf("fail to create publish client: %v", err) + return fmt.Errorf("fail to create publish client: %w", err) } if err = p.publishFolloweMeStream.Send(&mq_pb.PublishFollowMeRequest{ Message: &mq_pb.PublishFollowMeRequest_Init{ |