File tree Expand file tree Collapse file tree 1 file changed +0
-2
lines changed Expand file tree Collapse file tree 1 file changed +0
-2
lines changed Original file line number Diff line number Diff line change @@ -348,7 +348,6 @@ def callback(message):
348
348
349
349
def receive_messages_with_custom_attributes (project_id , subscription_id , timeout = None ):
350
350
"""Receives messages from a pull subscription."""
351
- # [START pubsub_subscriber_sync_pull_custom_attributes]
352
351
# [START pubsub_subscriber_async_pull_custom_attributes]
353
352
from concurrent .futures import TimeoutError
354
353
from google .cloud import pubsub_v1
@@ -383,7 +382,6 @@ def callback(message):
383
382
except TimeoutError :
384
383
streaming_pull_future .cancel ()
385
384
# [END pubsub_subscriber_async_pull_custom_attributes]
386
- # [END pubsub_subscriber_sync_pull_custom_attributes]
387
385
388
386
389
387
def receive_messages_with_flow_control (project_id , subscription_id , timeout = None ):
You can’t perform that action at this time.
0 commit comments