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:
12351235 "list-in-project" , help = list_subscriptions_in_project .__doc__
12361236 )
12371237
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+
12381246 create_parser = subparsers .add_parser ("create" , help = create_subscription .__doc__ )
12391247 create_parser .add_argument ("topic_id" )
12401248 create_parser .add_argument ("subscription_id" )
@@ -1516,3 +1524,10 @@ def callback(message: pubsub_v1.subscriber.message.Message) -> None:
15161524 receive_messages_with_concurrency_control (
15171525 args .project_id , args .subscription_id , args .timeout
15181526 )
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