Skip to content

Commit f5c7c4a

Browse files
committed
Harden snippets-under-test against eventual consistency.
1 parent dd38d66 commit f5c7c4a

1 file changed

Lines changed: 4 additions & 2 deletions

File tree

docs/pubsub_snippets.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -314,16 +314,18 @@ def subscription_pull(client, to_delete):
314314
# [START subscription_pull_return_immediately]
315315
pulled = subscription.pull(return_immediately=True)
316316
# [END subscription_pull_return_immediately]
317-
assert len(pulled) == 0
317+
assert len(pulled) == 0, "unexpeccted message"
318318

319319
topic.publish(PAYLOAD1)
320320
topic.publish(PAYLOAD2, extra=EXTRA)
321321

322+
time.sleep(1) # eventually-consistent
323+
322324
# [START subscription_pull]
323325
pulled = subscription.pull(max_messages=2)
324326
# [END subscription_pull]
325327

326-
assert len(pulled) == 2
328+
assert len(pulled) == 2, "eventual consistency"
327329

328330
# [START subscription_modify_ack_deadline]
329331
for ack_id, _ in pulled:

0 commit comments

Comments
 (0)