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 10:34:40 UTC
(beam) branch fix-python-validates-runner updated: Fix circular import
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
The following commit(s) were added to refs/heads/fix-python-validates-runner by this push:
new 4655193879e Fix circular import
4655193879e is described below
commit 4655193879e9dff2718c02c20b46f6c06c9bf54c
Author: Vitaly Terentyev <vi...@akvelon.com>
AuthorDate: Mon Jun 9 14:34:31 2025 +0400
Fix circular import
---
sdks/python/apache_beam/runners/portability/portable_runner_test.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
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 d95fa463a9a..8cca24e8fff 100644
--- a/sdks/python/apache_beam/runners/portability/portable_runner_test.py
+++ b/sdks/python/apache_beam/runners/portability/portable_runner_test.py
@@ -40,8 +40,6 @@ 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
@@ -225,6 +223,8 @@ class PortableRunnerTest(fn_runner_test.FnApiRunnerTest):
raise unittest.SkipTest("Portable runners don't support drain yet.")
def test_pardo_et_timer_with_no_firing(self):
+ from apache_beam.runners.portability.samza_runner_test import SamzaRunnerTest
+ from apache_beam.runners.portability.spark_runner_test import SparkRunnerTest
if type(self) in [PortableRunnerTest,
PortableRunnerTestWithSubprocesses,
PortableRunnerTestWithSubprocessesAndMultiWorkers,