Increase pipeline duration

yeandy · yeandy · commit a85649989b8f · 2022-01-12T14:26:45.000-06:00
diff --git 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
