changes added for bugs

logrhythm · Feb 18, 2020 · 5b365af · 5b365af
1 parent 82ae91f
commit 5b365af
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/beater/pubsubbeat.go b/beater/pubsubbeat.go
@@ -196,8 +196,8 @@ func getOrCreateSubscription(client *pubsub.Client, config *config.Config) (*pub
 	if st, ok := status.FromError(err); 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)
+	} else if err != nil {
+		return nil, fmt.Errorf("project %q does not exists", err)
 	} else if ok && st.Code() == codes.NotFound {
 		return nil, fmt.Errorf("topic %q does not exists", config.Topic)
 	} else if !ok {