diff --git a/samples/snippets/subscriber.py b/samples/snippets/subscriber.py index 79cd0ebf1..ef74b32cb 100644 --- a/samples/snippets/subscriber.py +++ b/samples/snippets/subscriber.py @@ -232,7 +232,7 @@ def create_subscription_with_dead_letter_topic( def create_push_subscription( - project_id: str, topic_id: str, subscription_id: str, endpoint: str + project_id: str, topic_id: str, subscription_id: str, endpoint: str, ack_deadline_seconds: int = 60 ) -> None: """Create a new push subscription on the given topic.""" # [START pubsub_create_push_subscription] @@ -259,6 +259,7 @@ def create_push_subscription( "name": subscription_path, "topic": topic_path, "push_config": push_config, + "ack_deadline_seconds": ack_deadline_seconds } ) @@ -1168,6 +1169,8 @@ def callback(message: pubsub_v1.subscriber.message.Message) -> None: create_push_parser.add_argument("topic_id") create_push_parser.add_argument("subscription_id") create_push_parser.add_argument("endpoint") + create_push_parser.add_argument("ack_deadline_seconds", type=int) + create_push_no_wrapper_parser = subparsers.add_parser( "create-push-no-wrapper", help=create_push_no_wrapper_subscription.__doc__ @@ -1346,7 +1349,7 @@ def callback(message: pubsub_v1.subscriber.message.Message) -> None: ) elif args.command == "create-push": create_push_subscription( - args.project_id, args.topic_id, args.subscription_id, args.endpoint + args.project_id, args.topic_id, args.subscription_id, args.endpoint, args.ack_deadline_seconds ) elif args.command == "create-push-no-wrapper": create_push_no_wrapper_subscription(