[beam] branch master updated: [BEAM-7351] increment ack deadline for flaky pubsub test

[pa...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

pabloem pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 5b7f365  [BEAM-7351] increment ack deadline for flaky pubsub test
     new 4973c57  Merge pull request #8752 from Juta/flaky-it2
5b7f365 is described below

commit 5b7f365e9b8512a3d3a5e845bc4b09b2ecadfac0
Author: Juta <ju...@gmail.com>
AuthorDate: Tue Jun 4 12:17:33 2019 +0200

    [BEAM-7351] increment ack deadline for flaky pubsub test
---
 sdks/python/apache_beam/examples/streaming_wordcount_it_test.py | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/sdks/python/apache_beam/examples/streaming_wordcount_it_test.py b/sdks/python/apache_beam/examples/streaming_wordcount_it_test.py
index 281dc69..c587961 100644
--- a/sdks/python/apache_beam/examples/streaming_wordcount_it_test.py
+++ b/sdks/python/apache_beam/examples/streaming_wordcount_it_test.py
@@ -64,7 +64,8 @@ class StreamingWordCountIT(unittest.TestCase):
         self.input_topic.name)
     self.output_sub = self.sub_client.create_subscription(
         self.sub_client.subscription_path(self.project, OUTPUT_SUB + self.uuid),
-        self.output_topic.name)
+        self.output_topic.name,
+        ack_deadline_seconds=60)
 
   def _inject_numbers(self, topic, num_messages):
     """Inject numbers as test data to PubSub."""