isort

samples/snippets/publisher.py

@@ -223,11 +223,9 @@ def publish_messages_with_flow_control_settings(project_id: str, topic_id: str)
     from concurrent import futures
 
     from google.cloud import pubsub_v1
-    from google.cloud.pubsub_v1.types import (
-        LimitExceededBehavior,
-        PublisherOptions,
-        PublishFlowControl,
-    )
+    from google.cloud.pubsub_v1.types import (LimitExceededBehavior,
+                                              PublisherOptions,
+                                              PublishFlowControl)
 
     # TODO(developer)
     # project_id = "your-project-id"

samples/snippets/publisher_test.py

@@ -15,7 +15,7 @@
 import os
 import time
 import typing
-from typing import Any, Callable, cast, Iterator, TypeVar, Union
+from typing import Any, Callable, Iterator, TypeVar, Union, cast
 import uuid
 
 from _pytest.capture import CaptureFixture

samples/snippets/schema_test.py

@@ -15,14 +15,15 @@
 # limitations under the License.
 
 import os
-from typing import Any, Callable, cast, Generator, TypeVar
+from typing import Any, Callable, Generator, TypeVar, cast
 import uuid
 
 from _pytest.capture import CaptureFixture
 from flaky import flaky
 from google.api_core.exceptions import InternalServerError, NotFound
 from google.cloud import pubsub_v1
-from google.cloud.pubsub import PublisherClient, SchemaServiceClient, SubscriberClient
+from google.cloud.pubsub import (PublisherClient, SchemaServiceClient,
+                                 SubscriberClient)
 from google.pubsub_v1.types import Encoding
 import pytest
 

samples/snippets/subscriber_test.py

@@ -16,7 +16,7 @@
 import re
 import sys
 import time
-from typing import Any, Callable, cast, Generator, List, TypeVar
+from typing import Any, Callable, Generator, List, TypeVar, cast
 import uuid
 
 from _pytest.capture import CaptureFixture