From 9907c25ecbc5925cbde75bc4440cf258315a5217 Mon Sep 17 00:00:00 2001 From: Derrick Williams Date: Wed, 17 Dec 2025 18:26:40 +0000 Subject: [PATCH 1/2] move import --- .../apache_beam/runners/interactive/recording_manager.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/sdks/python/apache_beam/runners/interactive/recording_manager.py b/sdks/python/apache_beam/runners/interactive/recording_manager.py index c19b60b64fd2..9b6191bcb3fd 100644 --- a/sdks/python/apache_beam/runners/interactive/recording_manager.py +++ b/sdks/python/apache_beam/runners/interactive/recording_manager.py @@ -41,7 +41,6 @@ from apache_beam.runners.interactive import pipeline_fragment as pf from apache_beam.runners.interactive import utils from apache_beam.runners.interactive.caching.cacheable import CacheKey -from apache_beam.runners.interactive.display.pipeline_graph import PipelineGraph from apache_beam.runners.interactive.options import capture_control from apache_beam.runners.runner import PipelineState @@ -713,6 +712,9 @@ def _get_pipeline_graph(self): """Lazily initializes and returns the PipelineGraph.""" if self._pipeline_graph is None: try: + # Allow initial module loading to be complete and not have a circular + # import. + from apache_beam.runners.interactive.display.pipeline_graph import PipelineGraph # Try to create the graph. self._pipeline_graph = PipelineGraph(self.user_pipeline) except (ImportError, NameError, AttributeError): From f48b3e35d2d82e4c04693573f40b4d4899a7400d Mon Sep 17 00:00:00 2001 From: Derrick Williams Date: Wed, 17 Dec 2025 19:13:57 +0000 Subject: [PATCH 2/2] fix pylint --- sdks/python/apache_beam/runners/interactive/recording_manager.py | 1 + 1 file changed, 1 insertion(+) diff --git a/sdks/python/apache_beam/runners/interactive/recording_manager.py b/sdks/python/apache_beam/runners/interactive/recording_manager.py index 9b6191bcb3fd..688d71bada2e 100644 --- a/sdks/python/apache_beam/runners/interactive/recording_manager.py +++ b/sdks/python/apache_beam/runners/interactive/recording_manager.py @@ -715,6 +715,7 @@ def _get_pipeline_graph(self): # Allow initial module loading to be complete and not have a circular # import. from apache_beam.runners.interactive.display.pipeline_graph import PipelineGraph + # Try to create the graph. self._pipeline_graph = PipelineGraph(self.user_pipeline) except (ImportError, NameError, AttributeError):