Merge pull request #1289 from michelle192837/pubsub

Specify auto-project detection for PubSub.
GoogleCloudPlatform · Sep 17, 2024 · 70f4277 · 70f4277
2 parents 1192f6a + 2aff760
commit 70f4277
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/cmd/summarizer/main.go b/cmd/summarizer/main.go
@@ -96,7 +96,7 @@ func gcsFixer(ctx context.Context, projectSub string, configPath gcs.Path, tabPr
 		return nil, errors.New("malformed project/subscription")
 	}
 	projID, subID := parts[0], parts[1]
-	pubsubClient, err := gpubsub.NewClient(ctx, "", option.WithCredentialsFile(credPath))
+	pubsubClient, err := gpubsub.NewClient(ctx, gpubsub.DetectProjectID, option.WithCredentialsFile(credPath))
 	if err != nil {
 		logrus.WithError(err).Fatal("Failed to create pubsub client")
 	}

diff --git a/cmd/tabulator/main.go b/cmd/tabulator/main.go
@@ -183,7 +183,7 @@ func gcsFixer(ctx context.Context, projectSub string, configPath gcs.Path, gridP
 		return nil, errors.New("malformed project/subscription")
 	}
 	projID, subID := parts[0], parts[1]
-	pubsubClient, err := gpubsub.NewClient(ctx, "", option.WithCredentialsFile(credPath))
+	pubsubClient, err := gpubsub.NewClient(ctx, gpubsub.DetectProjectID, option.WithCredentialsFile(credPath))
 	if err != nil {
 		logrus.WithError(err).Fatal("Failed to create pubsub client")
 	}

diff --git a/cmd/updater/main.go b/cmd/updater/main.go
@@ -215,7 +215,7 @@ func main() {
 
 	mets := updater.CreateMetrics(prometheus.NewFactory())
 
-	pubsubClient, err := gpubsub.NewClient(ctx, "", option.WithCredentialsFile(opt.creds))
+	pubsubClient, err := gpubsub.NewClient(ctx, gpubsub.DetectProjectID, option.WithCredentialsFile(opt.creds))
 	if err != nil {
 		logrus.WithError(err).Fatal("Failed to create pubsub client")
 	}