Skip to content

Commit

Permalink
Fix the docstrings (#22497)
Browse files Browse the repository at this point in the history
I think PubSubHook is using gRPC but not REST.
  • Loading branch information
mai-nakagawa committed Mar 24, 2022
1 parent c615526 commit 82a26c0
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions airflow/providers/google/cloud/hooks/pubsub.py
Original file line number Diff line number Diff line change
Expand Up @@ -115,7 +115,7 @@ def publish(
include the ``projects/{project}/topics/`` prefix.
:param messages: messages to publish; if the data field in a
message is set, it should be a bytestring (utf-8 encoded)
http://cloud.google.com/pubsub/docs/reference/rest/v1/PubsubMessage
https://cloud.google.com/pubsub/docs/reference/rpc/google.pubsub.v1#pubsubmessage
:param project_id: Optional, the Google Cloud project ID in which to publish.
If set to None or missing, the default project_id from the Google Cloud connection is used.
"""
Expand Down Expand Up @@ -489,7 +489,7 @@ def pull(
:return: A list of Pub/Sub ReceivedMessage objects each containing
an ``ackId`` property and a ``message`` property, which includes
the base64-encoded message content. See
https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.subscriptions/pull#ReceivedMessage
https://cloud.google.com/pubsub/docs/reference/rpc/google.pubsub.v1#google.pubsub.v1.ReceivedMessage
"""
subscriber = self.subscriber_client
# E501
Expand Down

0 comments on commit 82a26c0

Please sign in to comment.