Fix linting error: unused imports

Author: ian-Liaozy

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

@@ -25,7 +25,7 @@
 import unittest
 from typing import NamedTuple
 from unittest.mock import patch
-from concurrent.futures import Future, TimeoutError
+from concurrent.futures import TimeoutError
 
 import apache_beam as beam
 from apache_beam import dataframe as frames

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

@@ -15,7 +15,6 @@
 # limitations under the License.
 #
 
-import asyncio
 import collections
 from concurrent.futures import Future, ThreadPoolExecutor
 import logging
@@ -37,7 +36,6 @@
 import apache_beam as beam
 from apache_beam.dataframe.frame_base import DeferredBase
 from apache_beam.options import pipeline_options
-from apache_beam.pipeline import PipelineVisitor
 from apache_beam.portability.api import beam_runner_api_pb2
 from apache_beam.runners import runner
 from apache_beam.runners.interactive import background_caching_job as bcj
@@ -47,7 +45,6 @@
 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.messaging.interactive_environment_inspector import meta
 from apache_beam.runners.interactive.options import capture_control
 from apache_beam.runners.runner import PipelineState
 
@@ -721,10 +718,6 @@ def _get_pcoll_id_map(self):
     else:
       # Fallback for proto-based PipelineGraph, though less likely in this context
       proto = self._pipeline_graph._pipeline_proto
-      for pid, pcoll_proto in proto.components.pcollections.items():
-        # This is tricky, we don't have the direct Python object map here.
-        # This path is less likely to be hit if PipelineGraph is init with a beam.Pipeline
-        pass
     return {v: k for k, v in pcoll_to_id.items()}
 
   def _get_all_dependencies(