fix formatting

Author: tarun-google

sdks/python/apache_beam/examples/rate_limiter_simple.py

@@ -24,9 +24,9 @@
 import time
 
 import apache_beam as beam
-from apache_beam.utils import shared
 from apache_beam.io.components.rate_limiter import EnvoyRateLimiter
 from apache_beam.options.pipeline_options import PipelineOptions
+from apache_beam.utils import shared
 
 
 class SampleApiDoFn(beam.DoFn):

sdks/python/apache_beam/io/components/rate_limiter.py

@@ -28,10 +28,8 @@
 from typing import List
 
 import grpc
-from envoy_data_plane.envoy.extensions.common.ratelimit.v3 import (
-    RateLimitDescriptor)
-from envoy_data_plane.envoy.extensions.common.ratelimit.v3 import (
-    RateLimitDescriptorEntry)
+from envoy_data_plane.envoy.extensions.common.ratelimit.v3 import RateLimitDescriptor
+from envoy_data_plane.envoy.extensions.common.ratelimit.v3 import RateLimitDescriptorEntry
 from envoy_data_plane.envoy.service.ratelimit.v3 import RateLimitRequest
 from envoy_data_plane.envoy.service.ratelimit.v3 import RateLimitResponse
 from envoy_data_plane.envoy.service.ratelimit.v3 import RateLimitResponseCode
@@ -52,16 +50,14 @@ def __init__(self, namespace: str = ""):
     # Metric updates are thread safe
     self.throttling_signaler = adaptive_throttler.ThrottlingSignaler(
         namespace=namespace)
-    self.requests_counter = Metrics.counter(
-        namespace, 'RatelimitRequestsTotal')
+    self.requests_counter = Metrics.counter(namespace, 'RatelimitRequestsTotal')
     self.requests_allowed = Metrics.counter(
         namespace, 'RatelimitRequestsAllowed')
     self.requests_throttled = Metrics.counter(
         namespace, 'RatelimitRequestsThrottled')
     self.rpc_errors = Metrics.counter(namespace, 'RatelimitRpcErrors')
     self.rpc_retries = Metrics.counter(namespace, 'RatelimitRpcRetries')
-    self.rpc_latency = Metrics.distribution(
-        namespace, 'RatelimitRpcLatencyMs')
+    self.rpc_latency = Metrics.distribution(namespace, 'RatelimitRpcLatencyMs')
 
   @abc.abstractmethod
   def throttle(self, **kwargs) -> bool:

sdks/python/apache_beam/io/components/rate_limiter_test.py

@@ -16,15 +16,15 @@
 #
 
 import unittest
-from unittest import mock
-import grpc
 from datetime import timedelta
+from unittest import mock
 
-from apache_beam.io.components import rate_limiter
+import grpc
 from envoy_data_plane.envoy.service.ratelimit.v3 import RateLimitResponse
 from envoy_data_plane.envoy.service.ratelimit.v3 import RateLimitResponseCode
-from envoy_data_plane.envoy.service.ratelimit.v3 import (
-    RateLimitResponseDescriptorStatus)
+from envoy_data_plane.envoy.service.ratelimit.v3 import RateLimitResponseDescriptorStatus
+
+from apache_beam.io.components import rate_limiter
 
 
 class EnvoyRateLimiterTest(unittest.TestCase):