From a85649989b8f098715d72b333df376ce11ede203 Mon Sep 17 00:00:00 2001 From: Andy Ye Date: Wed, 12 Jan 2022 14:26:45 -0600 Subject: [PATCH] Increase pipeline duration --- sdks/python/apache_beam/io/gcp/pubsub_integration_test.py | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/sdks/python/apache_beam/io/gcp/pubsub_integration_test.py b/sdks/python/apache_beam/io/gcp/pubsub_integration_test.py index 36bb0de23114..e52d22032ed7 100644 --- a/sdks/python/apache_beam/io/gcp/pubsub_integration_test.py +++ b/sdks/python/apache_beam/io/gcp/pubsub_integration_test.py @@ -43,7 +43,7 @@ # How long TestXXXRunner will wait for pubsub_it_pipeline to run before # cancelling it. -TEST_PIPELINE_DURATION_MS = 3 * 60 * 1000 +TEST_PIPELINE_DURATION_MS = 8 * 60 * 1000 # How long PubSubMessageMatcher will wait for the correct set of messages to # appear. MESSAGE_MATCHER_TIMEOUT_S = 5 * 60 @@ -213,8 +213,6 @@ def _test_streaming(self, with_attributes): @pytest.mark.it_postcommit def test_streaming_data_only(self): - if self.runner_name == 'TestDataflowRunner': - pytest.skip("BEAM-13218") self._test_streaming(with_attributes=False) @pytest.mark.it_postcommit