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