Skip to content

Commit 501b4d8

Browse files
geigerjlukesneeringer
authored andcommitted
Fix a system test TODO (#3314)
This should prevent the (as of yet, unexperienced) error case where the API deletes the acked messages before we have a chance to seek to them.
1 parent 7c94167 commit 501b4d8

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

packages/google-cloud-pubsub/tests/system.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -360,7 +360,8 @@ def test_seek(self):
360360
self.to_delete.append(topic)
361361

362362
SUBSCRIPTION_NAME = 'subscribing-to-seek' + unique_resource_id('-')
363-
subscription = topic.subscription(SUBSCRIPTION_NAME)
363+
subscription = topic.subscription(
364+
SUBSCRIPTION_NAME, retain_acked_messages=True)
364365
self.assertFalse(subscription.exists())
365366
subscription.create()
366367
self.to_delete.append(subscription)

0 commit comments

Comments
 (0)