From 41f99c69506589c35d90b3e13a0fcc5eb589c049 Mon Sep 17 00:00:00 2001 From: Rajan Joshi Date: Wed, 19 Feb 2020 15:42:59 +0530 Subject: [PATCH] error message refined --- beater/pubsubbeat.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/beater/pubsubbeat.go b/beater/pubsubbeat.go index dc6846f60..bd55d96da 100644 --- a/beater/pubsubbeat.go +++ b/beater/pubsubbeat.go @@ -192,12 +192,12 @@ func getOrCreateSubscription(client *pubsub.Client, config *config.Config) (*pub RetainAckedMessages: config.Subscription.RetainAckedMessages, RetentionDuration: config.Subscription.RetentionDuration, }) - - if st, ok := status.FromError(err); ok && st.Code() == codes.AlreadyExists { + st, ok := status.FromError(err) + if ok && st.Code() == codes.AlreadyExists { // The subscription already exists. subscription = client.Subscription(config.Subscription.Name) } else if err != nil { - return nil, fmt.Errorf("project %q does not exists", err) + return nil, fmt.Errorf(st.Message()) } else if ok && st.Code() == codes.NotFound { return nil, fmt.Errorf("topic %q does not exists", config.Topic) } else if !ok {