diff --git a/cmd/summarizer/main.go b/cmd/summarizer/main.go index 330e61dd4..c4de0a3ec 100644 --- 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 index 3dd1e44bc..65f393647 100644 --- 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 index 4463c2821..1b8d600fa 100644 --- 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") }