Skip to content

Commit f198c11

Browse files
committed
remove unnecessary protection for circular import
1 parent d37c808 commit f198c11

File tree

1 file changed

+1
-4
lines changed

1 file changed

+1
-4
lines changed

sdks/python/apache_beam/runners/interactive/recording_manager.py

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -41,6 +41,7 @@
4141
from apache_beam.runners.interactive import pipeline_fragment as pf
4242
from apache_beam.runners.interactive import utils
4343
from apache_beam.runners.interactive.caching.cacheable import CacheKey
44+
from apache_beam.runners.interactive.display.pipeline_graph import PipelineGraph
4445
from apache_beam.runners.interactive.options import capture_control
4546
from apache_beam.runners.runner import PipelineState
4647

@@ -712,10 +713,6 @@ def _get_pipeline_graph(self):
712713
"""Lazily initializes and returns the PipelineGraph."""
713714
if self._pipeline_graph is None:
714715
try:
715-
# Allow initial module loading to be complete and not have a circular
716-
# import.
717-
from apache_beam.runners.interactive.display.pipeline_graph import PipelineGraph
718-
719716
# Try to create the graph.
720717
self._pipeline_graph = PipelineGraph(self.user_pipeline)
721718
except (ImportError, NameError, AttributeError):

0 commit comments

Comments
 (0)