File tree Expand file tree Collapse file tree 1 file changed +15
-0
lines changed Expand file tree Collapse file tree 1 file changed +15
-0
lines changed Original file line number Diff line number Diff line change @@ -1235,6 +1235,14 @@ def callback(message: pubsub_v1.subscriber.message.Message) -> None:
1235
1235
"list-in-project" , help = list_subscriptions_in_project .__doc__
1236
1236
)
1237
1237
1238
+ otel_subscribe_parse = subparsers .add_parser (
1239
+ "otel-subscribe" , help = pubsub_subscribe_otel_tracing .__doc__
1240
+ )
1241
+ otel_subscribe_parse .add_argument ("subscription_project_id" )
1242
+ otel_subscribe_parse .add_argument ("cloud_trace_project_id" )
1243
+ otel_subscribe_parse .add_argument ("subscription_id" )
1244
+ otel_subscribe_parse .add_argument ("timeout" , default = None , type = float , nargs = "?" )
1245
+
1238
1246
create_parser = subparsers .add_parser ("create" , help = create_subscription .__doc__ )
1239
1247
create_parser .add_argument ("topic_id" )
1240
1248
create_parser .add_argument ("subscription_id" )
@@ -1516,3 +1524,10 @@ def callback(message: pubsub_v1.subscriber.message.Message) -> None:
1516
1524
receive_messages_with_concurrency_control (
1517
1525
args .project_id , args .subscription_id , args .timeout
1518
1526
)
1527
+ elif args .command == "otel-subscribe" :
1528
+ pubsub_subscribe_otel_tracing (
1529
+ args .subscription_project_id ,
1530
+ args .cloud_trace_project_id ,
1531
+ args .subscription_id ,
1532
+ args .timeout ,
1533
+ )
You can’t perform that action at this time.
0 commit comments