Skip to content
This repository was archived by the owner on Mar 9, 2026. It is now read-only.

Commit 263f4f9

Browse files
committed
fix: add smt suffixes to topics/subscriptions with smts to prevent cache lookups causing run conflicts
1 parent b283217 commit 263f4f9

File tree

2 files changed

+2
-5
lines changed

2 files changed

+2
-5
lines changed

samples/snippets/publisher.py

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1046,10 +1046,7 @@ def detach_subscription(project_id: str, subscription_id: str) -> None:
10461046
args.gcp_service_account,
10471047
)
10481048
elif args.command == "create_smt":
1049-
create_topic_with_smt(
1050-
args.project_id,
1051-
args.topic_id,
1052-
)
1049+
create_topic_with_smt(args.project_id, f"{args.topic_id}-smt")
10531050
elif args.command == "update_kinesis_ingestion":
10541051
update_topic_type(
10551052
args.project_id,

samples/snippets/subscriber.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1518,7 +1518,7 @@ def callback(message: pubsub_v1.subscriber.message.Message) -> None:
15181518
)
15191519
elif args.command == "create-with-smt":
15201520
create_subscription_with_smt(
1521-
args.project_id, args.topic_id, args.subscription_id
1521+
args.project_id, f"{args.topic_id}-smt", f"{args.subscription_id}-smt"
15221522
)
15231523

15241524
elif args.command == "delete":

0 commit comments

Comments
 (0)