This is an automated email from the ASF dual-hosted git repository. damccorm pushed a commit to branch users/damccorm/prism-minimal-repro in repository https://gitbox.apache.org/repos/asf/beam.git
commit 0e6cfdb2d1ed6bc127c137e150e6fe8783af99b2 Author: Danny Mccormick <[email protected]> AuthorDate: Mon Jun 16 15:19:05 2025 -0400 [WIP] Get minimal repro of flaky prism test --- sdks/python/apache_beam/yaml/yaml_mapping_test.py | 5 ++--- sdks/python/test-suites/tox/common.gradle | 4 ++-- sdks/python/tox.ini | 2 +- 3 files changed, 5 insertions(+), 6 deletions(-) diff --git a/sdks/python/apache_beam/yaml/yaml_mapping_test.py b/sdks/python/apache_beam/yaml/yaml_mapping_test.py index d5179d385ca..4d969e75045 100644 --- a/sdks/python/apache_beam/yaml/yaml_mapping_test.py +++ b/sdks/python/apache_beam/yaml/yaml_mapping_test.py @@ -416,9 +416,8 @@ class YamlMappingTest(unittest.TestCase): ''') def test_partition_bad_runtime_type(self): - with self.assertRaisesRegex(ValueError, - r'.*Returned output name.*must be a string.*'): - with beam.Pipeline(options=beam.options.pipeline_options.PipelineOptions( + with self.assertRaises(Exception): + with beam.Pipeline('PrismRunner', options=beam.options.pipeline_options.PipelineOptions( pickle_library='cloudpickle')) as p: elements = p | beam.Create([ beam.Row(element='apple', texture='smooth'), diff --git a/sdks/python/test-suites/tox/common.gradle b/sdks/python/test-suites/tox/common.gradle index 75a12cdcf4c..6b570b0ee0b 100644 --- a/sdks/python/test-suites/tox/common.gradle +++ b/sdks/python/test-suites/tox/common.gradle @@ -18,7 +18,7 @@ def pythonVersionSuffix = project.ext.pythonVersion.replace('.', '') -def posargs = project.findProperty("posargs") ?: "" +def posargs = "--ignore=apache_beam/dataframe/ --ignore=apache_beam/ml/ --ignore=apache_beam/examples/ --ignore=apache_beam/runners/ --ignore=apache_beam/transforms/" toxTask "testPython${pythonVersionSuffix}", "py${pythonVersionSuffix}", "${posargs}" test.dependsOn "testPython${pythonVersionSuffix}" @@ -35,6 +35,6 @@ project.tasks.register("preCommitPy${pythonVersionSuffix}") { // Since codecoverage reports will always be generated for py39, // all tests will be exercised. // dependsOn = ["testPy${pythonVersionSuffix}Cloud", "testPython${pythonVersionSuffix}"] - dependsOn = ["testPy${pythonVersionSuffix}Cloud", "testPython${pythonVersionSuffix}"] + dependsOn = ["testPy${pythonVersionSuffix}Cloud"] } diff --git a/sdks/python/tox.ini b/sdks/python/tox.ini index 5131769509d..2910d5e9ff4 100644 --- a/sdks/python/tox.ini +++ b/sdks/python/tox.ini @@ -100,7 +100,7 @@ list_dependencies_command = {envbindir}/python.exe {envbindir}/pip.exe freeze ; extras = test,gcp,interactive,dataframe,aws,azure extras = test,gcp,interactive,dataframe,aws,azure commands = - python apache_beam/examples/complete/autocomplete_test.py + ; python apache_beam/examples/complete/autocomplete_test.py bash {toxinidir}/scripts/run_pytest.sh {envname} "{posargs}" [testenv:py{39,310,311}-ml]
