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 <juta.st...@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."""