1 files changed, 22 insertions, 20 deletions
diff --git a/src/python/grpcio/grpc/framework/interfaces/base/utilities.py b/src/python/grpcio/grpc/framework/interfaces/base/utilities.py
index 87a85018f5..461706ff9f 100644
--- a/src/python/grpcio/grpc/framework/interfaces/base/utilities.py
+++ b/src/python/grpcio/grpc/framework/interfaces/base/utilities.py
@@ -26,7 +26,6 @@
 # THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 # (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
 # OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
-
 """Utilities for use with the base interface of RPC Framework."""
 
 import collections
@@ -34,27 +33,30 @@ import collections
 from grpc.framework.interfaces.base import base
 
 
-class _Completion(
-    base.Completion,
-    collections.namedtuple(
-        '_Completion', ('terminal_metadata', 'code', 'message',))):
-  """A trivial implementation of base.Completion."""
+class _Completion(base.Completion,
+                  collections.namedtuple('_Completion', (
+                      'terminal_metadata',
+                      'code',
+                      'message',))):
+    """A trivial implementation of base.Completion."""
+
 
+class _Subscription(base.Subscription,
+                    collections.namedtuple('_Subscription', (
+                        'kind',
+                        'termination_callback',
+                        'allowance',
+                        'operator',
+                        'protocol_receiver',))):
+    """A trivial implementation of base.Subscription."""
 
-class _Subscription(
-    base.Subscription,
-    collections.namedtuple(
-        '_Subscription',
-        ('kind', 'termination_callback', 'allowance', 'operator',
-         'protocol_receiver',))):
-  """A trivial implementation of base.Subscription."""
 
-_NONE_SUBSCRIPTION = _Subscription(
-    base.Subscription.Kind.NONE, None, None, None, None)
+_NONE_SUBSCRIPTION = _Subscription(base.Subscription.Kind.NONE, None, None,
+                                   None, None)
 
 
 def completion(terminal_metadata, code, message):
-  """Creates a base.Completion aggregating the given operation values.
+    """Creates a base.Completion aggregating the given operation values.
 
   Args:
     terminal_metadata: A terminal metadata value for an operaton.
@@ -64,11 +66,11 @@ def completion(terminal_metadata, code, message):
   Returns:
     A base.Completion aggregating the given operation values.
   """
-  return _Completion(terminal_metadata, code, message)
+    return _Completion(terminal_metadata, code, message)
 
 
 def full_subscription(operator, protocol_receiver):
-  """Creates a "full" base.Subscription for the given base.Operator.
+    """Creates a "full" base.Subscription for the given base.Operator.
 
   Args:
     operator: A base.Operator to be used in an operation.
@@ -78,5 +80,5 @@ def full_subscription(operator, protocol_receiver):
     A base.Subscription of kind base.Subscription.Kind.FULL wrapping the given
       base.Operator and base.ProtocolReceiver.
   """
-  return _Subscription(
-      base.Subscription.Kind.FULL, None, None, operator, protocol_receiver)
+    return _Subscription(base.Subscription.Kind.FULL, None, None, operator,
+                         protocol_receiver)