chore: sort imports (#761)

* chore: sort imports

* 🦉 Updates from OwlBot post-processor

See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md

---------

Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>

docs/conf.py

@@ -24,9 +24,9 @@
 # All configuration values have a default; values that are commented out
 # serve to show the default.
 
-import sys
 import os
 import shlex
+import sys
 
 # If extensions (or modules to document with autodoc) are in another directory,
 # add these directories to sys.path here. If the directory is relative to the

google/cloud/bigquery_storage/__init__.py

@@ -19,52 +19,53 @@
 
 
 from google.cloud.bigquery_storage_v1 import BigQueryReadClient
+from google.cloud.bigquery_storage_v1 import gapic_types as types
+from google.cloud.bigquery_storage_v1.services.big_query_write.async_client import (
+    BigQueryWriteAsyncClient,
+)
 from google.cloud.bigquery_storage_v1.services.big_query_write.client import (
     BigQueryWriteClient,
 )
-from google.cloud.bigquery_storage_v1.services.big_query_write.async_client import (
-    BigQueryWriteAsyncClient,
+from google.cloud.bigquery_storage_v1.types.arrow import (
+    ArrowRecordBatch,
+    ArrowSchema,
+    ArrowSerializationOptions,
 )
-
-from google.cloud.bigquery_storage_v1 import gapic_types as types
-from google.cloud.bigquery_storage_v1.types.arrow import ArrowRecordBatch
-from google.cloud.bigquery_storage_v1.types.arrow import ArrowSchema
-from google.cloud.bigquery_storage_v1.types.arrow import ArrowSerializationOptions
-from google.cloud.bigquery_storage_v1.types.avro import AvroRows
-from google.cloud.bigquery_storage_v1.types.avro import AvroSchema
-from google.cloud.bigquery_storage_v1.types.avro import AvroSerializationOptions
-from google.cloud.bigquery_storage_v1.types.protobuf import ProtoRows
-from google.cloud.bigquery_storage_v1.types.protobuf import ProtoSchema
-from google.cloud.bigquery_storage_v1.types.storage import AppendRowsRequest
-from google.cloud.bigquery_storage_v1.types.storage import AppendRowsResponse
-from google.cloud.bigquery_storage_v1.types.storage import (
-    BatchCommitWriteStreamsRequest,
+from google.cloud.bigquery_storage_v1.types.avro import (
+    AvroRows,
+    AvroSchema,
+    AvroSerializationOptions,
 )
+from google.cloud.bigquery_storage_v1.types.protobuf import ProtoRows, ProtoSchema
 from google.cloud.bigquery_storage_v1.types.storage import (
+    AppendRowsRequest,
+    AppendRowsResponse,
+    BatchCommitWriteStreamsRequest,
     BatchCommitWriteStreamsResponse,
+    CreateReadSessionRequest,
+    CreateWriteStreamRequest,
+    FinalizeWriteStreamRequest,
+    FinalizeWriteStreamResponse,
+    FlushRowsRequest,
+    FlushRowsResponse,
+    GetWriteStreamRequest,
+    ReadRowsRequest,
+    ReadRowsResponse,
+    RowError,
+    SplitReadStreamRequest,
+    SplitReadStreamResponse,
+    StorageError,
+    StreamStats,
+    ThrottleState,
+)
+from google.cloud.bigquery_storage_v1.types.stream import (
+    DataFormat,
+    ReadSession,
+    ReadStream,
+    WriteStream,
+    WriteStreamView,
 )
-from google.cloud.bigquery_storage_v1.types.storage import CreateReadSessionRequest
-from google.cloud.bigquery_storage_v1.types.storage import CreateWriteStreamRequest
-from google.cloud.bigquery_storage_v1.types.storage import FinalizeWriteStreamRequest
-from google.cloud.bigquery_storage_v1.types.storage import FinalizeWriteStreamResponse
-from google.cloud.bigquery_storage_v1.types.storage import FlushRowsRequest
-from google.cloud.bigquery_storage_v1.types.storage import FlushRowsResponse
-from google.cloud.bigquery_storage_v1.types.storage import GetWriteStreamRequest
-from google.cloud.bigquery_storage_v1.types.storage import ReadRowsRequest
-from google.cloud.bigquery_storage_v1.types.storage import ReadRowsResponse
-from google.cloud.bigquery_storage_v1.types.storage import RowError
-from google.cloud.bigquery_storage_v1.types.storage import SplitReadStreamRequest
-from google.cloud.bigquery_storage_v1.types.storage import SplitReadStreamResponse
-from google.cloud.bigquery_storage_v1.types.storage import StorageError
-from google.cloud.bigquery_storage_v1.types.storage import StreamStats
-from google.cloud.bigquery_storage_v1.types.storage import ThrottleState
-from google.cloud.bigquery_storage_v1.types.stream import ReadSession
-from google.cloud.bigquery_storage_v1.types.stream import ReadStream
-from google.cloud.bigquery_storage_v1.types.stream import WriteStream
-from google.cloud.bigquery_storage_v1.types.stream import DataFormat
-from google.cloud.bigquery_storage_v1.types.stream import WriteStreamView
-from google.cloud.bigquery_storage_v1.types.table import TableFieldSchema
-from google.cloud.bigquery_storage_v1.types.table import TableSchema
+from google.cloud.bigquery_storage_v1.types.table import TableFieldSchema, TableSchema
 
 __all__ = (
     "BigQueryReadClient",

google/cloud/bigquery_storage_v1/__init__.py

@@ -20,8 +20,7 @@
 
 __version__ = package_version.__version__
 
-from google.cloud.bigquery_storage_v1 import client
-from google.cloud.bigquery_storage_v1 import types
+from google.cloud.bigquery_storage_v1 import client, types
 
 
 class BigQueryReadClient(client.BigQueryReadClient):

google/cloud/bigquery_storage_v1/client.py

@@ -24,9 +24,7 @@
 import google.api_core.gapic_v1.method
 
 from google.cloud.bigquery_storage_v1 import reader
-from google.cloud.bigquery_storage_v1.services import big_query_read
-from google.cloud.bigquery_storage_v1.services import big_query_write
-
+from google.cloud.bigquery_storage_v1.services import big_query_read, big_query_write
 
 _SCOPES = (
     "https://www.googleapis.com/auth/bigquery",

google/cloud/bigquery_storage_v1/gapic_types.py

@@ -20,15 +20,11 @@
 import inspect
 import sys
 
-import proto
-
-from google.cloud.bigquery_storage_v1.types import arrow
-from google.cloud.bigquery_storage_v1.types import avro
-from google.cloud.bigquery_storage_v1.types import storage
-from google.cloud.bigquery_storage_v1.types import stream
-
 from google.protobuf import message as protobuf_message
 from google.protobuf import timestamp_pb2
+import proto
+
+from google.cloud.bigquery_storage_v1.types import arrow, avro, storage, stream
 
 
 # The current api core helper does not find new proto messages of type proto.Message,

google/cloud/bigquery_storage_v1/services/big_query_read/__init__.py

@@ -13,8 +13,8 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 #
-from .client import BigQueryReadClient
 from .async_client import BigQueryReadAsyncClient
+from .client import BigQueryReadClient
 
 __all__ = (
     "BigQueryReadClient",

google/cloud/bigquery_storage_v1/services/big_query_read/async_client.py

@@ -17,41 +17,40 @@
 import functools
 import re
 from typing import (
+    AsyncIterable,
+    Awaitable,
     Dict,
     Mapping,
     MutableMapping,
     MutableSequence,
     Optional,
-    AsyncIterable,
-    Awaitable,
     Sequence,
     Tuple,
     Type,
     Union,
 )
 
-from google.cloud.bigquery_storage_v1 import gapic_version as package_version
-
-from google.api_core.client_options import ClientOptions
 from google.api_core import exceptions as core_exceptions
 from google.api_core import gapic_v1
 from google.api_core import retry_async as retries
+from google.api_core.client_options import ClientOptions
 from google.auth import credentials as ga_credentials  # type: ignore
 from google.oauth2 import service_account  # type: ignore
 
+from google.cloud.bigquery_storage_v1 import gapic_version as package_version
+
 try:
     OptionalRetry = Union[retries.AsyncRetry, gapic_v1.method._MethodDefault, None]
 except AttributeError:  # pragma: NO COVER
     OptionalRetry = Union[retries.AsyncRetry, object, None]  # type: ignore
 
-from google.cloud.bigquery_storage_v1.types import arrow
-from google.cloud.bigquery_storage_v1.types import avro
-from google.cloud.bigquery_storage_v1.types import storage
-from google.cloud.bigquery_storage_v1.types import stream
 from google.protobuf import timestamp_pb2  # type: ignore
-from .transports.base import BigQueryReadTransport, DEFAULT_CLIENT_INFO
-from .transports.grpc_asyncio import BigQueryReadGrpcAsyncIOTransport
+
+from google.cloud.bigquery_storage_v1.types import arrow, avro, storage, stream
+
 from .client import BigQueryReadClient
+from .transports.base import DEFAULT_CLIENT_INFO, BigQueryReadTransport
+from .transports.grpc_asyncio import BigQueryReadGrpcAsyncIOTransport
 
 
 class BigQueryReadAsyncClient:

google/cloud/bigquery_storage_v1/services/big_query_read/client.py

@@ -18,11 +18,11 @@
 import re
 from typing import (
     Dict,
+    Iterable,
     Mapping,
     MutableMapping,
     MutableSequence,
     Optional,
-    Iterable,
     Sequence,
     Tuple,
     Type,
@@ -31,29 +31,28 @@
 )
 import warnings
 
-from google.cloud.bigquery_storage_v1 import gapic_version as package_version
-
 from google.api_core import client_options as client_options_lib
 from google.api_core import exceptions as core_exceptions
 from google.api_core import gapic_v1
 from google.api_core import retry as retries
 from google.auth import credentials as ga_credentials  # type: ignore
+from google.auth.exceptions import MutualTLSChannelError  # type: ignore
 from google.auth.transport import mtls  # type: ignore
 from google.auth.transport.grpc import SslCredentials  # type: ignore
-from google.auth.exceptions import MutualTLSChannelError  # type: ignore
 from google.oauth2 import service_account  # type: ignore
 
+from google.cloud.bigquery_storage_v1 import gapic_version as package_version
+
 try:
     OptionalRetry = Union[retries.Retry, gapic_v1.method._MethodDefault, None]
 except AttributeError:  # pragma: NO COVER
     OptionalRetry = Union[retries.Retry, object, None]  # type: ignore
 
-from google.cloud.bigquery_storage_v1.types import arrow
-from google.cloud.bigquery_storage_v1.types import avro
-from google.cloud.bigquery_storage_v1.types import storage
-from google.cloud.bigquery_storage_v1.types import stream
 from google.protobuf import timestamp_pb2  # type: ignore
-from .transports.base import BigQueryReadTransport, DEFAULT_CLIENT_INFO
+
+from google.cloud.bigquery_storage_v1.types import arrow, avro, storage, stream
+
+from .transports.base import DEFAULT_CLIENT_INFO, BigQueryReadTransport
 from .transports.grpc import BigQueryReadGrpcTransport
 from .transports.grpc_asyncio import BigQueryReadGrpcAsyncIOTransport
 

google/cloud/bigquery_storage_v1/services/big_query_read/transports/__init__.py

@@ -20,7 +20,6 @@
 from .grpc import BigQueryReadGrpcTransport
 from .grpc_asyncio import BigQueryReadGrpcAsyncIOTransport
 
-
 # Compile a registry of transports.
 _transport_registry = OrderedDict()  # type: Dict[str, Type[BigQueryReadTransport]]
 _transport_registry["grpc"] = BigQueryReadGrpcTransport

google/cloud/bigquery_storage_v1/services/big_query_read/transports/base.py

@@ -16,18 +16,16 @@
 import abc
 from typing import Awaitable, Callable, Dict, Optional, Sequence, Union
 
-from google.cloud.bigquery_storage_v1 import gapic_version as package_version
-
-import google.auth  # type: ignore
 import google.api_core
 from google.api_core import exceptions as core_exceptions
 from google.api_core import gapic_v1
 from google.api_core import retry as retries
+import google.auth  # type: ignore
 from google.auth import credentials as ga_credentials  # type: ignore
 from google.oauth2 import service_account  # type: ignore
 
-from google.cloud.bigquery_storage_v1.types import storage
-from google.cloud.bigquery_storage_v1.types import stream
+from google.cloud.bigquery_storage_v1 import gapic_version as package_version
+from google.cloud.bigquery_storage_v1.types import storage, stream
 
 DEFAULT_CLIENT_INFO = gapic_v1.client_info.ClientInfo(
     gapic_version=package_version.__version__

google/cloud/bigquery_storage_v1/services/big_query_read/transports/grpc.py

@@ -13,20 +13,18 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 #
-import warnings
 from typing import Callable, Dict, Optional, Sequence, Tuple, Union
+import warnings
 
-from google.api_core import grpc_helpers
-from google.api_core import gapic_v1
+from google.api_core import gapic_v1, grpc_helpers
 import google.auth  # type: ignore
 from google.auth import credentials as ga_credentials  # type: ignore
 from google.auth.transport.grpc import SslCredentials  # type: ignore
-
 import grpc  # type: ignore
 
-from google.cloud.bigquery_storage_v1.types import storage
-from google.cloud.bigquery_storage_v1.types import stream
-from .base import BigQueryReadTransport, DEFAULT_CLIENT_INFO
+from google.cloud.bigquery_storage_v1.types import storage, stream
+
+from .base import DEFAULT_CLIENT_INFO, BigQueryReadTransport
 
 
 class BigQueryReadGrpcTransport(BigQueryReadTransport):

google/cloud/bigquery_storage_v1/services/big_query_read/transports/grpc_asyncio.py

@@ -13,20 +13,18 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 #
-import warnings
 from typing import Awaitable, Callable, Dict, Optional, Sequence, Tuple, Union
+import warnings
 
-from google.api_core import gapic_v1
-from google.api_core import grpc_helpers_async
+from google.api_core import gapic_v1, grpc_helpers_async
 from google.auth import credentials as ga_credentials  # type: ignore
 from google.auth.transport.grpc import SslCredentials  # type: ignore
-
 import grpc  # type: ignore
 from grpc.experimental import aio  # type: ignore
 
-from google.cloud.bigquery_storage_v1.types import storage
-from google.cloud.bigquery_storage_v1.types import stream
-from .base import BigQueryReadTransport, DEFAULT_CLIENT_INFO
+from google.cloud.bigquery_storage_v1.types import storage, stream
+
+from .base import DEFAULT_CLIENT_INFO, BigQueryReadTransport
 from .grpc import BigQueryReadGrpcTransport
 
 

google/cloud/bigquery_storage_v1/services/big_query_write/__init__.py

@@ -13,8 +13,8 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 #
-from .client import BigQueryWriteClient
 from .async_client import BigQueryWriteAsyncClient
+from .client import BigQueryWriteClient
 
 __all__ = (
     "BigQueryWriteClient",