From ec23d4396e6eb34eddf1699a254ae6028c3b8dc8 Mon Sep 17 00:00:00 2001
From: Tianzi Cai <tianzi@google.com>
Date: Mon, 14 Feb 2022 16:04:07 -0800
Subject: [PATCH] samples: handle empty response in sync pull samples

---
 samples/snippets/subscriber.py | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/samples/snippets/subscriber.py b/samples/snippets/subscriber.py
index dad841600..7bc124ca8 100644
--- a/samples/snippets/subscriber.py
+++ b/samples/snippets/subscriber.py
@@ -605,6 +605,9 @@ def synchronous_pull(project_id: str, subscription_id: str) -> None:
             retry=retry.Retry(deadline=300),
         )
 
+        if len(response.received_messages) == 0:
+            return
+
         ack_ids = []
         for received_message in response.received_messages:
             print(f"Received: {received_message.message.data}.")
@@ -651,6 +654,9 @@ def synchronous_pull_with_lease_management(
         retry=retry.Retry(deadline=300),
     )
 
+    if len(response.received_messages) == 0:
+        return
+
     # Start a process for each message based on its size modulo 10.
     for message in response.received_messages:
         process = multiprocessing.Process(