Preserve existing linter comments.

sdks/python/apache_beam/internal/module_test.py

@@ -21,7 +21,6 @@
 
 import re
 import sys
-
 from typing import Any
 
 

sdks/python/apache_beam/runners/direct/test_stream_impl.py

@@ -30,6 +30,7 @@
 from queue import Empty as EmptyException
 from queue import Queue
 from threading import Thread
+from typing import Union
 
 import grpc
 
@@ -309,8 +310,8 @@ def is_alive():
       return not (shutdown_requested or evaluation_context.shutdown_requested)
 
     # The shared queue that allows the producer and consumer to communicate.
-    channel: 'Queue[Union[test_stream.Event, _EndOfStream]]' = (
-        Queue())  # noqa: F821
+    channel: 'Queue[Union[test_stream.Event, _EndOfStream]]' = (  # noqa: F821
+        Queue())
     event_stream = Thread(
         target=_TestStream._stream_events_from_rpc,
         args=(endpoint, output_tags, coder, channel, is_alive))

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

@@ -255,8 +255,7 @@ def __init__(
       self,
       user_pipeline: beam.Pipeline,
       pipeline_var: str = None,
-      test_limiters: List['Limiter'] = None) -> None:
-    # noqa: F821
+      test_limiters: List['Limiter'] = None) -> None:  # noqa: F821
 
     self.user_pipeline: beam.Pipeline = user_pipeline
     self.pipeline_var: str = pipeline_var if pipeline_var else ''
@@ -265,8 +264,6 @@ def __init__(
     self._test_limiters = test_limiters if test_limiters else []
 
   def _watch(self, pcolls: List[beam.pvalue.PCollection]) -> None:
-    # noqa: F821
-
     """Watch any pcollections not being watched.
 
     This allows for the underlying caching layer to identify the PCollection as