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 bbb914e85f44..52c65dd2283b 100644 --- a/sdks/python/apache_beam/io/gcp/pubsub_integration_test.py +++ b/sdks/python/apache_beam/io/gcp/pubsub_integration_test.py @@ -206,6 +206,8 @@ 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