From 47f777856bff21e0c281f71402f879ef5cad6ab9 Mon Sep 17 00:00:00 2001 From: Dima I <79413560+DIvkov575@users.noreply.github.com> Date: Mon, 12 Feb 2024 13:27:01 -0500 Subject: [PATCH] fixed documentation in sdks/python/apache_beam/io/gcp/pubsub.py WriteToPubSub (#30285) * fixed documentation in sdks/python/apache_beam/io/gcp/pubsub.py writetopubsub * Update build.gradle - I accidentally removed a character in a previous commit * Update pubsub.py * fixed linting error --- sdks/python/apache_beam/io/gcp/pubsub.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/sdks/python/apache_beam/io/gcp/pubsub.py b/sdks/python/apache_beam/io/gcp/pubsub.py index d0785fa1f214b..cec65bc530f3f 100644 --- a/sdks/python/apache_beam/io/gcp/pubsub.py +++ b/sdks/python/apache_beam/io/gcp/pubsub.py @@ -337,7 +337,9 @@ def __init__( """Initializes ``WriteToPubSub``. Args: - topic: Cloud Pub/Sub topic in the form "/topics//". + topic: + Cloud Pub/Sub topic in the form + "projects//topics/". with_attributes: True - input elements will be :class:`~PubsubMessage` objects. False - input elements will be of type ``bytes`` (message