From c10e8354328f195f9b2486004cec329468cdf3ba Mon Sep 17 00:00:00 2001 From: KCarretto Date: Tue, 7 Jan 2025 03:46:01 +0000 Subject: [PATCH] [Tavern] Fix pubsub connect string --- tavern/config.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/tavern/config.go b/tavern/config.go index 3c2d674cc..c494886c3 100644 --- a/tavern/config.go +++ b/tavern/config.go @@ -197,9 +197,9 @@ func (cfg *Config) NewShellMuxes(ctx context.Context) (wsMux *stream.Mux, grpcMu shellOutputTopic := client.Topic(strings.TrimPrefix(topicShellOutput, gcpPrefix)) // Overwrite env var specification with newly created GCP PubSub Subscriptions - subShellInput = fmt.Sprintf("gcpubsub://%s", createGCPSubscription(ctx, shellInputTopic)) + subShellInput = fmt.Sprintf("gcpubsub://projects/%s/subscriptions/%s", projectID, createGCPSubscription(ctx, shellInputTopic)) slog.DebugContext(ctx, "created GCP PubSub subscription for shell input", "subscription_name", subShellInput) - subShellOutput = fmt.Sprintf("gcpubsub://%s", createGCPSubscription(ctx, shellOutputTopic)) + subShellOutput = fmt.Sprintf("gcpubsub://projects/%s/subscriptions/%s", projectID, createGCPSubscription(ctx, shellOutputTopic)) slog.DebugContext(ctx, "created GCP PubSub subscription for shell output", "subscription_name", subShellOutput) }