fix import formatting (linting)

Author: ian-Liaozy

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

@@ -43,9 +43,8 @@
 from typing import Optional
 from typing import Union
 
-import pandas as pd
-
 import apache_beam as beam
+import pandas as pd
 from apache_beam.dataframe.frame_base import DeferredBase
 from apache_beam.options.pipeline_options import FlinkRunnerOptions
 from apache_beam.pvalue import PCollection

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

@@ -23,9 +23,12 @@
 import sys
 import time
 import unittest
-from typing import NamedTuple
-from unittest.mock import patch, MagicMock, ANY, call
 from concurrent.futures import TimeoutError
+from typing import NamedTuple
+from unittest.mock import ANY
+from unittest.mock import MagicMock
+from unittest.mock import call
+from unittest.mock import patch
 
 import apache_beam as beam
 from apache_beam import dataframe as frames

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

@@ -16,24 +16,23 @@
 #
 
 import collections
-from concurrent.futures import Future, ThreadPoolExecutor
 import logging
 import os
 import threading
 import time
+import uuid
 import warnings
+from concurrent.futures import Future
+from concurrent.futures import ThreadPoolExecutor
 from typing import Any
 from typing import Dict
 from typing import List
 from typing import Optional
 from typing import Set
 from typing import Union
 
-import pandas as pd
-
-import uuid
-
 import apache_beam as beam
+import pandas as pd
 from apache_beam.dataframe.frame_base import DeferredBase
 from apache_beam.options import pipeline_options
 from apache_beam.portability.api import beam_runner_api_pb2
@@ -51,8 +50,10 @@
 _LOGGER = logging.getLogger(__name__)
 
 try:
-  from IPython.display import display, HTML, clear_output
   import ipywidgets as widgets
+  from IPython.display import HTML
+  from IPython.display import clear_output
+  from IPython.display import display
 
   IS_IPYTHON = True
 except ImportError:

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

@@ -18,7 +18,9 @@
 import time
 import unittest
 from concurrent.futures import Future
-from unittest.mock import patch, MagicMock, call
+from unittest.mock import MagicMock
+from unittest.mock import call
+from unittest.mock import patch
 
 import apache_beam as beam
 from apache_beam import coders
@@ -30,11 +32,11 @@
 from apache_beam.runners.interactive.caching.cacheable import CacheKey
 from apache_beam.runners.interactive.interactive_runner import InteractiveRunner
 from apache_beam.runners.interactive.options.capture_limiters import Limiter
+from apache_beam.runners.interactive.recording_manager import _LOGGER
 from apache_beam.runners.interactive.recording_manager import AsyncComputationResult
 from apache_beam.runners.interactive.recording_manager import ElementStream
 from apache_beam.runners.interactive.recording_manager import Recording
 from apache_beam.runners.interactive.recording_manager import RecordingManager
-from apache_beam.runners.interactive.recording_manager import _LOGGER
 from apache_beam.runners.interactive.testing.test_cache_manager import FileRecordsBuilder
 from apache_beam.runners.interactive.testing.test_cache_manager import InMemoryCache
 from apache_beam.runners.runner import PipelineState