You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by pa...@apache.org on 2019/05/14 01:25:01 UTC
[beam] branch master updated: [BEAM-7181][BEAM-7243] add streaming
it tests python 3.6
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 9cb1c3c [BEAM-7181][BEAM-7243] add streaming it tests python 3.6
new 8d9abd0 Merge pull request #8550 from Juta/it-tests
9cb1c3c is described below
commit 9cb1c3c5a1f3d8070330d71b5af7a142831784f2
Author: Juta <ju...@gmail.com>
AuthorDate: Fri May 10 16:29:11 2019 +0200
[BEAM-7181][BEAM-7243] add streaming it tests python 3.6
---
.../apache_beam/examples/complete/game/game_stats_it_test.py | 6 ------
.../apache_beam/examples/complete/game/leader_board_it_test.py | 6 ------
sdks/python/apache_beam/examples/wordcount_it_test.py | 6 ------
sdks/python/apache_beam/io/gcp/pubsub_integration_test.py | 10 ----------
.../dataflow/dataflow_exercise_metrics_pipeline_test.py | 6 ------
5 files changed, 34 deletions(-)
diff --git a/sdks/python/apache_beam/examples/complete/game/game_stats_it_test.py b/sdks/python/apache_beam/examples/complete/game/game_stats_it_test.py
index a2d1abf..cba4b00 100644
--- a/sdks/python/apache_beam/examples/complete/game/game_stats_it_test.py
+++ b/sdks/python/apache_beam/examples/complete/game/game_stats_it_test.py
@@ -33,8 +33,6 @@ Usage:
from __future__ import absolute_import
import logging
-import os
-import sys
import time
import unittest
import uuid
@@ -105,10 +103,6 @@ class GameStatsIT(unittest.TestCase):
test_utils.cleanup_subscriptions(self.sub_client, [self.input_sub])
test_utils.cleanup_topics(self.pub_client, [self.input_topic])
- @unittest.skipIf(sys.version[0:3] == '3.6' and
- os.environ.get('RUN_SKIPPED_PY3_TESTS') != '1',
- 'This test still needs to be fixed on Python 3.6 '
- 'TODO: BEAM-7182')
@attr('IT')
def test_game_stats_it(self):
state_verifier = PipelineStateMatcher(PipelineState.RUNNING)
diff --git a/sdks/python/apache_beam/examples/complete/game/leader_board_it_test.py b/sdks/python/apache_beam/examples/complete/game/leader_board_it_test.py
index c712352..9f057fd 100644
--- a/sdks/python/apache_beam/examples/complete/game/leader_board_it_test.py
+++ b/sdks/python/apache_beam/examples/complete/game/leader_board_it_test.py
@@ -33,8 +33,6 @@ Usage:
from __future__ import absolute_import
import logging
-import os
-import sys
import time
import unittest
import uuid
@@ -107,10 +105,6 @@ class LeaderBoardIT(unittest.TestCase):
test_utils.cleanup_subscriptions(self.sub_client, [self.input_sub])
test_utils.cleanup_topics(self.pub_client, [self.input_topic])
- @unittest.skipIf(sys.version[0:3] == '3.6' and
- os.environ.get('RUN_SKIPPED_PY3_TESTS') != '1',
- 'This test still needs to be fixed on Python 3.6 '
- 'TODO: BEAM-7182')
@attr('IT')
def test_leader_board_it(self):
state_verifier = PipelineStateMatcher(PipelineState.RUNNING)
diff --git a/sdks/python/apache_beam/examples/wordcount_it_test.py b/sdks/python/apache_beam/examples/wordcount_it_test.py
index 868f837..eabe88b 100644
--- a/sdks/python/apache_beam/examples/wordcount_it_test.py
+++ b/sdks/python/apache_beam/examples/wordcount_it_test.py
@@ -20,8 +20,6 @@
from __future__ import absolute_import
import logging
-import os
-import sys
import time
import unittest
@@ -48,10 +46,6 @@ class WordCountIT(unittest.TestCase):
def test_wordcount_it(self):
self._run_wordcount_it(wordcount.run)
- @unittest.skipIf(sys.version[0:3] == '3.6' and
- os.environ.get('RUN_SKIPPED_PY3_TESTS') != '1',
- 'This test still needs to be fixed on Python 3.6 '
- 'TODO: BEAM-7183')
@attr('IT', 'ValidatesContainer')
def test_wordcount_fnapi_it(self):
self._run_wordcount_it(wordcount.run, experiment='beam_fn_api')
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 6d3549c..c8a743e 100644
--- a/sdks/python/apache_beam/io/gcp/pubsub_integration_test.py
+++ b/sdks/python/apache_beam/io/gcp/pubsub_integration_test.py
@@ -20,8 +20,6 @@ Integration test for Google Cloud Pub/Sub.
from __future__ import absolute_import
import logging
-import os
-import sys
import unittest
import uuid
@@ -172,18 +170,10 @@ class PubSubIntegrationTest(unittest.TestCase):
id_label=self.ID_LABEL,
timestamp_attribute=self.TIMESTAMP_ATTRIBUTE)
- @unittest.skipIf(sys.version[0:3] == '3.6' and
- os.environ.get('RUN_SKIPPED_PY3_TESTS') != '1',
- 'This test still needs to be fixed on Python 3.6 '
- 'TODO: BEAM-7181')
@attr('IT')
def test_streaming_data_only(self):
self._test_streaming(with_attributes=False)
- @unittest.skipIf(sys.version[0:3] == '3.6' and
- os.environ.get('RUN_SKIPPED_PY3_TESTS') != '1',
- 'This test still needs to be fixed on Python 3.6 '
- 'TODO: BEAM-7181')
@attr('IT')
def test_streaming_with_attributes(self):
self._test_streaming(with_attributes=True)
diff --git a/sdks/python/apache_beam/runners/dataflow/dataflow_exercise_metrics_pipeline_test.py b/sdks/python/apache_beam/runners/dataflow/dataflow_exercise_metrics_pipeline_test.py
index 620f83c..c62824d 100644
--- a/sdks/python/apache_beam/runners/dataflow/dataflow_exercise_metrics_pipeline_test.py
+++ b/sdks/python/apache_beam/runners/dataflow/dataflow_exercise_metrics_pipeline_test.py
@@ -20,8 +20,6 @@
from __future__ import absolute_import
import argparse
-import os
-import sys
import unittest
from nose.plugins.attrib import attr
@@ -57,10 +55,6 @@ class ExerciseMetricsPipelineTest(unittest.TestCase):
dataflow_exercise_metrics_pipeline.legacy_metric_matchers())
self.assertFalse(errors, str(errors))
- @unittest.skipIf(sys.version[0:3] == '3.6' and
- os.environ.get('RUN_SKIPPED_PY3_TESTS') != '1',
- 'This test still needs to be fixed on Python 3.6 '
- 'TODO: BEAM-7183')
@attr('IT', 'ValidatesContainer')
def test_metrics_fnapi_it(self):
result = self.run_pipeline(experiment='beam_fn_api')