We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent dd38d66 commit f5c7c4aCopy full SHA for f5c7c4a
1 file changed
docs/pubsub_snippets.py
@@ -314,16 +314,18 @@ def subscription_pull(client, to_delete):
314
# [START subscription_pull_return_immediately]
315
pulled = subscription.pull(return_immediately=True)
316
# [END subscription_pull_return_immediately]
317
- assert len(pulled) == 0
+ assert len(pulled) == 0, "unexpeccted message"
318
319
topic.publish(PAYLOAD1)
320
topic.publish(PAYLOAD2, extra=EXTRA)
321
322
+ time.sleep(1) # eventually-consistent
323
+
324
# [START subscription_pull]
325
pulled = subscription.pull(max_messages=2)
326
# [END subscription_pull]
327
- assert len(pulled) == 2
328
+ assert len(pulled) == 2, "eventual consistency"
329
330
# [START subscription_modify_ack_deadline]
331
for ack_id, _ in pulled:
0 commit comments