Print actual number of messages pulled [(#2078)](GoogleCloudPlatform/…

…python-docs-samples#2078) * Print actual number of messages pulled
googleapis · Jul 10, 2020 · 8dca3e8 · 8dca3e8
1 parent f418bca
commit 8dca3e8
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/samples/snippets/subscriber.py b/samples/snippets/subscriber.py
@@ -284,7 +284,8 @@ def synchronous_pull(project_id, subscription_name):
     # Acknowledges the received messages so they will not be sent again.
     subscriber.acknowledge(subscription_path, ack_ids)
 
-    print("Received and acknowledged {} messages. Done.".format(NUM_MESSAGES))
+    print('Received and acknowledged {} messages. Done.'.format(
+        len(response.received_messages)))
     # [END pubsub_subscriber_sync_pull]
 
 
@@ -357,7 +358,8 @@ def worker(msg):
         if processes:
             time.sleep(SLEEP_TIME)
 
-    print("Received and acknowledged {} messages. Done.".format(NUM_MESSAGES))
+    print('Received and acknowledged {} messages. Done.'.format(
+        len(response.received_messages)))
     # [END pubsub_subscriber_sync_pull_with_lease]