diff --git a/google/cloud/pubsub_v1/publisher/client.py b/google/cloud/pubsub_v1/publisher/client.py
index 6ecb625c3..3bd21ae23 100644
--- a/google/cloud/pubsub_v1/publisher/client.py
+++ b/google/cloud/pubsub_v1/publisher/client.py
@@ -133,14 +133,13 @@ def __init__(self, batch_settings=(), publisher_options=(), **kwargs):
         # The auto-generated layer's client has mTLS logic to determine the api
         # endpoint and the ssl credentials to use. Here we create a client
         # and extract the api endpoint and ssl credentials. The api endpoint
-        # will be used to set `self._target`, and ssl credentials will be 
+        # will be used to set `self._target`, and ssl credentials will be
         # passed to `grpc_helpers.create_channel` to establish a mTLS channel
         # (if ssl credentials is not None).
         client_options = kwargs.get("client_options", None)
-        credentials=kwargs.get("credentials", None)
+        credentials = kwargs.get("credentials", None)
         publisher_client_instance = publisher_client.PublisherClient(
-            credentials=credentials,
-            client_options=client_options
+            credentials=credentials, client_options=client_options
         )
 
         self._target = publisher_client_instance._transport._host
diff --git a/google/cloud/pubsub_v1/subscriber/client.py b/google/cloud/pubsub_v1/subscriber/client.py
index a40f4051f..f0bf43d9b 100644
--- a/google/cloud/pubsub_v1/subscriber/client.py
+++ b/google/cloud/pubsub_v1/subscriber/client.py
@@ -16,7 +16,6 @@
 
 import os
 import pkg_resources
-import six
 
 import grpc
 
@@ -85,14 +84,13 @@ def __init__(self, **kwargs):
         # The auto-generated layer's client has mTLS logic to determine the api
         # endpoint and the ssl credentials to use. Here we create a client
         # and extract the api endpoint and ssl credentials. The api endpoint
-        # will be used to set `self._target`, and ssl credentials will be 
+        # will be used to set `self._target`, and ssl credentials will be
         # passed to `grpc_helpers.create_channel` to establish a mTLS channel
         # (if ssl credentials is not None).
         client_options = kwargs.get("client_options", None)
-        credentials=kwargs.get("credentials", None)
+        credentials = kwargs.get("credentials", None)
         subscriber_client_instance = subscriber_client.SubscriberClient(
-            credentials=credentials,
-            client_options=client_options
+            credentials=credentials, client_options=client_options
         )
 
         self._target = subscriber_client_instance._transport._host