You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by vt...@apache.org on 2025/06/09 08:44:23 UTC
(beam) 01/01: Skip Samza/Spark runner tests
This is an automated email from the ASF dual-hosted git repository.
vterentev pushed a commit to branch fix-python-validates-runner
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 047bcb74b1ff7313fe56e31a247dac75bfa77d01
Author: Vitaly Terentyev <vi...@akvelon.com>
AuthorDate: Mon Jun 9 12:44:10 2025 +0400
Skip Samza/Spark runner tests
---
.../apache_beam/runners/portability/fn_api_runner/fn_runner_test.py | 6 +++++-
sdks/python/apache_beam/runners/portability/portable_runner_test.py | 6 +++++-
2 files changed, 10 insertions(+), 2 deletions(-)
diff --git a/sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py b/sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py
index aafa088ceb1..1a52681fac2 100644
--- a/sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py
+++ b/sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py
@@ -61,6 +61,8 @@ from apache_beam.options.value_provider import RuntimeValueProvider
from apache_beam.portability import python_urns
from apache_beam.runners.portability import fn_api_runner
from apache_beam.runners.portability.fn_api_runner import fn_runner
+from apache_beam.runners.portability.samza_runner_test import SamzaRunnerTest
+from apache_beam.runners.portability.spark_runner_test import SparkRunnerTest
from apache_beam.runners.sdf_utils import RestrictionTrackerView
from apache_beam.runners.worker import data_plane
from apache_beam.runners.worker import statesampler
@@ -833,7 +835,9 @@ class FnApiRunnerTest(unittest.TestCase):
FnApiRunnerTestWithDisabledCaching,
FnApiRunnerTestWithMultiWorkers,
FnApiRunnerTestWithBundleRepeat,
- FnApiRunnerTestWithBundleRepeatAndMultiWorkers]:
+ FnApiRunnerTestWithBundleRepeatAndMultiWorkers,
+ SamzaRunnerTest,
+ SparkRunnerTest]:
raise unittest.SkipTest("https://github.com/apache/beam/issues/35168")
# The timer will not fire. It is initially set to T + 10, but then it is
diff --git a/sdks/python/apache_beam/runners/portability/portable_runner_test.py b/sdks/python/apache_beam/runners/portability/portable_runner_test.py
index e128b6a73e4..d95fa463a9a 100644
--- a/sdks/python/apache_beam/runners/portability/portable_runner_test.py
+++ b/sdks/python/apache_beam/runners/portability/portable_runner_test.py
@@ -40,6 +40,8 @@ from apache_beam.runners.portability import portable_runner
from apache_beam.runners.portability.fn_api_runner import fn_runner_test
from apache_beam.runners.portability.local_job_service import LocalJobServicer
from apache_beam.runners.portability.portable_runner import PortableRunner
+from apache_beam.runners.portability.samza_runner_test import SamzaRunnerTest
+from apache_beam.runners.portability.spark_runner_test import SparkRunnerTest
from apache_beam.runners.worker import worker_pool_main
from apache_beam.runners.worker.channel_factory import GRPCChannelFactory
from apache_beam.testing.util import assert_that
@@ -228,7 +230,9 @@ class PortableRunnerTest(fn_runner_test.FnApiRunnerTest):
PortableRunnerTestWithSubprocessesAndMultiWorkers,
PortableRunnerTestWithExternalEnv,
PortableRunnerTestWithLocalDocker,
- PortableRunnerOptimizedWithoutFusion]:
+ PortableRunnerOptimizedWithoutFusion,
+ SamzaRunnerTest,
+ SparkRunnerTest]:
raise unittest.SkipTest("https://github.com/apache/beam/issues/35168")
super().test_pardo_et_timer_with_no_firing()