chore(python): add nox session to sort python imports (#92)

Source-Link: googleapis/synthtool@1b71c10
Post-Processor: gcr.io/cloud-devrel-public-resources/owlbot-python:latest@sha256:00c9d764fd1cd56265f12a5ef4b99a0c9e87cf261018099141e2ca5158890416

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

packages/google-cloud-datastream/.github/.OwlBot.lock.yaml

@@ -13,5 +13,5 @@
 # limitations under the License.
 docker:
   image: gcr.io/cloud-devrel-public-resources/owlbot-python:latest
-  digest: sha256:8a5d3f6a2e43ed8293f34e06a2f56931d1e88a2694c3bb11b15df4eb256ad163
-# created: 2022-04-06T10:30:21.687684602Z
+  digest: sha256:00c9d764fd1cd56265f12a5ef4b99a0c9e87cf261018099141e2ca5158890416
+# created: 2022-04-20T23:42:53.970438194Z

packages/google-cloud-datastream/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

packages/google-cloud-datastream/google/cloud/datastream/__init__.py

@@ -14,86 +14,83 @@
 # limitations under the License.
 #
 
-from google.cloud.datastream_v1.services.datastream.client import DatastreamClient
 from google.cloud.datastream_v1.services.datastream.async_client import (
     DatastreamAsyncClient,
 )
-
-from google.cloud.datastream_v1.types.datastream import CreateConnectionProfileRequest
-from google.cloud.datastream_v1.types.datastream import CreatePrivateConnectionRequest
-from google.cloud.datastream_v1.types.datastream import CreateRouteRequest
-from google.cloud.datastream_v1.types.datastream import CreateStreamRequest
-from google.cloud.datastream_v1.types.datastream import DeleteConnectionProfileRequest
-from google.cloud.datastream_v1.types.datastream import DeletePrivateConnectionRequest
-from google.cloud.datastream_v1.types.datastream import DeleteRouteRequest
-from google.cloud.datastream_v1.types.datastream import DeleteStreamRequest
-from google.cloud.datastream_v1.types.datastream import DiscoverConnectionProfileRequest
+from google.cloud.datastream_v1.services.datastream.client import DatastreamClient
 from google.cloud.datastream_v1.types.datastream import (
+    CreateConnectionProfileRequest,
+    CreatePrivateConnectionRequest,
+    CreateRouteRequest,
+    CreateStreamRequest,
+    DeleteConnectionProfileRequest,
+    DeletePrivateConnectionRequest,
+    DeleteRouteRequest,
+    DeleteStreamRequest,
+    DiscoverConnectionProfileRequest,
     DiscoverConnectionProfileResponse,
+    FetchStaticIpsRequest,
+    FetchStaticIpsResponse,
+    GetConnectionProfileRequest,
+    GetPrivateConnectionRequest,
+    GetRouteRequest,
+    GetStreamObjectRequest,
+    GetStreamRequest,
+    ListConnectionProfilesRequest,
+    ListConnectionProfilesResponse,
+    ListPrivateConnectionsRequest,
+    ListPrivateConnectionsResponse,
+    ListRoutesRequest,
+    ListRoutesResponse,
+    ListStreamObjectsRequest,
+    ListStreamObjectsResponse,
+    ListStreamsRequest,
+    ListStreamsResponse,
+    LookupStreamObjectRequest,
+    OperationMetadata,
+    StartBackfillJobRequest,
+    StartBackfillJobResponse,
+    StopBackfillJobRequest,
+    StopBackfillJobResponse,
+    UpdateConnectionProfileRequest,
+    UpdateStreamRequest,
 )
-from google.cloud.datastream_v1.types.datastream import FetchStaticIpsRequest
-from google.cloud.datastream_v1.types.datastream import FetchStaticIpsResponse
-from google.cloud.datastream_v1.types.datastream import GetConnectionProfileRequest
-from google.cloud.datastream_v1.types.datastream import GetPrivateConnectionRequest
-from google.cloud.datastream_v1.types.datastream import GetRouteRequest
-from google.cloud.datastream_v1.types.datastream import GetStreamObjectRequest
-from google.cloud.datastream_v1.types.datastream import GetStreamRequest
-from google.cloud.datastream_v1.types.datastream import ListConnectionProfilesRequest
-from google.cloud.datastream_v1.types.datastream import ListConnectionProfilesResponse
-from google.cloud.datastream_v1.types.datastream import ListPrivateConnectionsRequest
-from google.cloud.datastream_v1.types.datastream import ListPrivateConnectionsResponse
-from google.cloud.datastream_v1.types.datastream import ListRoutesRequest
-from google.cloud.datastream_v1.types.datastream import ListRoutesResponse
-from google.cloud.datastream_v1.types.datastream import ListStreamObjectsRequest
-from google.cloud.datastream_v1.types.datastream import ListStreamObjectsResponse
-from google.cloud.datastream_v1.types.datastream import ListStreamsRequest
-from google.cloud.datastream_v1.types.datastream import ListStreamsResponse
-from google.cloud.datastream_v1.types.datastream import LookupStreamObjectRequest
-from google.cloud.datastream_v1.types.datastream import OperationMetadata
-from google.cloud.datastream_v1.types.datastream import StartBackfillJobRequest
-from google.cloud.datastream_v1.types.datastream import StartBackfillJobResponse
-from google.cloud.datastream_v1.types.datastream import StopBackfillJobRequest
-from google.cloud.datastream_v1.types.datastream import StopBackfillJobResponse
-from google.cloud.datastream_v1.types.datastream import UpdateConnectionProfileRequest
-from google.cloud.datastream_v1.types.datastream import UpdateStreamRequest
-from google.cloud.datastream_v1.types.datastream_resources import AvroFileFormat
-from google.cloud.datastream_v1.types.datastream_resources import BackfillJob
-from google.cloud.datastream_v1.types.datastream_resources import ConnectionProfile
-from google.cloud.datastream_v1.types.datastream_resources import DestinationConfig
-from google.cloud.datastream_v1.types.datastream_resources import Error
 from google.cloud.datastream_v1.types.datastream_resources import (
+    AvroFileFormat,
+    BackfillJob,
+    ConnectionProfile,
+    DestinationConfig,
+    Error,
     ForwardSshTunnelConnectivity,
-)
-from google.cloud.datastream_v1.types.datastream_resources import GcsDestinationConfig
-from google.cloud.datastream_v1.types.datastream_resources import GcsProfile
-from google.cloud.datastream_v1.types.datastream_resources import JsonFileFormat
-from google.cloud.datastream_v1.types.datastream_resources import MysqlColumn
-from google.cloud.datastream_v1.types.datastream_resources import MysqlDatabase
-from google.cloud.datastream_v1.types.datastream_resources import MysqlProfile
-from google.cloud.datastream_v1.types.datastream_resources import MysqlRdbms
-from google.cloud.datastream_v1.types.datastream_resources import MysqlSourceConfig
-from google.cloud.datastream_v1.types.datastream_resources import MysqlSslConfig
-from google.cloud.datastream_v1.types.datastream_resources import MysqlTable
-from google.cloud.datastream_v1.types.datastream_resources import OracleColumn
-from google.cloud.datastream_v1.types.datastream_resources import OracleProfile
-from google.cloud.datastream_v1.types.datastream_resources import OracleRdbms
-from google.cloud.datastream_v1.types.datastream_resources import OracleSchema
-from google.cloud.datastream_v1.types.datastream_resources import OracleSourceConfig
-from google.cloud.datastream_v1.types.datastream_resources import OracleTable
-from google.cloud.datastream_v1.types.datastream_resources import PrivateConnection
-from google.cloud.datastream_v1.types.datastream_resources import PrivateConnectivity
-from google.cloud.datastream_v1.types.datastream_resources import Route
-from google.cloud.datastream_v1.types.datastream_resources import SourceConfig
-from google.cloud.datastream_v1.types.datastream_resources import SourceObjectIdentifier
-from google.cloud.datastream_v1.types.datastream_resources import (
+    GcsDestinationConfig,
+    GcsProfile,
+    JsonFileFormat,
+    MysqlColumn,
+    MysqlDatabase,
+    MysqlProfile,
+    MysqlRdbms,
+    MysqlSourceConfig,
+    MysqlSslConfig,
+    MysqlTable,
+    OracleColumn,
+    OracleProfile,
+    OracleRdbms,
+    OracleSchema,
+    OracleSourceConfig,
+    OracleTable,
+    PrivateConnection,
+    PrivateConnectivity,
+    Route,
+    SourceConfig,
+    SourceObjectIdentifier,
     StaticServiceIpConnectivity,
+    Stream,
+    StreamObject,
+    Validation,
+    ValidationMessage,
+    ValidationResult,
+    VpcPeeringConfig,
 )
-from google.cloud.datastream_v1.types.datastream_resources import Stream
-from google.cloud.datastream_v1.types.datastream_resources import StreamObject
-from google.cloud.datastream_v1.types.datastream_resources import Validation
-from google.cloud.datastream_v1.types.datastream_resources import ValidationMessage
-from google.cloud.datastream_v1.types.datastream_resources import ValidationResult
-from google.cloud.datastream_v1.types.datastream_resources import VpcPeeringConfig
 
 __all__ = (
     "DatastreamClient",

packages/google-cloud-datastream/google/cloud/datastream_v1/__init__.py

@@ -14,78 +14,80 @@
 # limitations under the License.
 #
 
-from .services.datastream import DatastreamClient
-from .services.datastream import DatastreamAsyncClient
-
-from .types.datastream import CreateConnectionProfileRequest
-from .types.datastream import CreatePrivateConnectionRequest
-from .types.datastream import CreateRouteRequest
-from .types.datastream import CreateStreamRequest
-from .types.datastream import DeleteConnectionProfileRequest
-from .types.datastream import DeletePrivateConnectionRequest
-from .types.datastream import DeleteRouteRequest
-from .types.datastream import DeleteStreamRequest
-from .types.datastream import DiscoverConnectionProfileRequest
-from .types.datastream import DiscoverConnectionProfileResponse
-from .types.datastream import FetchStaticIpsRequest
-from .types.datastream import FetchStaticIpsResponse
-from .types.datastream import GetConnectionProfileRequest
-from .types.datastream import GetPrivateConnectionRequest
-from .types.datastream import GetRouteRequest
-from .types.datastream import GetStreamObjectRequest
-from .types.datastream import GetStreamRequest
-from .types.datastream import ListConnectionProfilesRequest
-from .types.datastream import ListConnectionProfilesResponse
-from .types.datastream import ListPrivateConnectionsRequest
-from .types.datastream import ListPrivateConnectionsResponse
-from .types.datastream import ListRoutesRequest
-from .types.datastream import ListRoutesResponse
-from .types.datastream import ListStreamObjectsRequest
-from .types.datastream import ListStreamObjectsResponse
-from .types.datastream import ListStreamsRequest
-from .types.datastream import ListStreamsResponse
-from .types.datastream import LookupStreamObjectRequest
-from .types.datastream import OperationMetadata
-from .types.datastream import StartBackfillJobRequest
-from .types.datastream import StartBackfillJobResponse
-from .types.datastream import StopBackfillJobRequest
-from .types.datastream import StopBackfillJobResponse
-from .types.datastream import UpdateConnectionProfileRequest
-from .types.datastream import UpdateStreamRequest
-from .types.datastream_resources import AvroFileFormat
-from .types.datastream_resources import BackfillJob
-from .types.datastream_resources import ConnectionProfile
-from .types.datastream_resources import DestinationConfig
-from .types.datastream_resources import Error
-from .types.datastream_resources import ForwardSshTunnelConnectivity
-from .types.datastream_resources import GcsDestinationConfig
-from .types.datastream_resources import GcsProfile
-from .types.datastream_resources import JsonFileFormat
-from .types.datastream_resources import MysqlColumn
-from .types.datastream_resources import MysqlDatabase
-from .types.datastream_resources import MysqlProfile
-from .types.datastream_resources import MysqlRdbms
-from .types.datastream_resources import MysqlSourceConfig
-from .types.datastream_resources import MysqlSslConfig
-from .types.datastream_resources import MysqlTable
-from .types.datastream_resources import OracleColumn
-from .types.datastream_resources import OracleProfile
-from .types.datastream_resources import OracleRdbms
-from .types.datastream_resources import OracleSchema
-from .types.datastream_resources import OracleSourceConfig
-from .types.datastream_resources import OracleTable
-from .types.datastream_resources import PrivateConnection
-from .types.datastream_resources import PrivateConnectivity
-from .types.datastream_resources import Route
-from .types.datastream_resources import SourceConfig
-from .types.datastream_resources import SourceObjectIdentifier
-from .types.datastream_resources import StaticServiceIpConnectivity
-from .types.datastream_resources import Stream
-from .types.datastream_resources import StreamObject
-from .types.datastream_resources import Validation
-from .types.datastream_resources import ValidationMessage
-from .types.datastream_resources import ValidationResult
-from .types.datastream_resources import VpcPeeringConfig
+from .services.datastream import DatastreamAsyncClient, DatastreamClient
+from .types.datastream import (
+    CreateConnectionProfileRequest,
+    CreatePrivateConnectionRequest,
+    CreateRouteRequest,
+    CreateStreamRequest,
+    DeleteConnectionProfileRequest,
+    DeletePrivateConnectionRequest,
+    DeleteRouteRequest,
+    DeleteStreamRequest,
+    DiscoverConnectionProfileRequest,
+    DiscoverConnectionProfileResponse,
+    FetchStaticIpsRequest,
+    FetchStaticIpsResponse,
+    GetConnectionProfileRequest,
+    GetPrivateConnectionRequest,
+    GetRouteRequest,
+    GetStreamObjectRequest,
+    GetStreamRequest,
+    ListConnectionProfilesRequest,
+    ListConnectionProfilesResponse,
+    ListPrivateConnectionsRequest,
+    ListPrivateConnectionsResponse,
+    ListRoutesRequest,
+    ListRoutesResponse,
+    ListStreamObjectsRequest,
+    ListStreamObjectsResponse,
+    ListStreamsRequest,
+    ListStreamsResponse,
+    LookupStreamObjectRequest,
+    OperationMetadata,
+    StartBackfillJobRequest,
+    StartBackfillJobResponse,
+    StopBackfillJobRequest,
+    StopBackfillJobResponse,
+    UpdateConnectionProfileRequest,
+    UpdateStreamRequest,
+)
+from .types.datastream_resources import (
+    AvroFileFormat,
+    BackfillJob,
+    ConnectionProfile,
+    DestinationConfig,
+    Error,
+    ForwardSshTunnelConnectivity,
+    GcsDestinationConfig,
+    GcsProfile,
+    JsonFileFormat,
+    MysqlColumn,
+    MysqlDatabase,
+    MysqlProfile,
+    MysqlRdbms,
+    MysqlSourceConfig,
+    MysqlSslConfig,
+    MysqlTable,
+    OracleColumn,
+    OracleProfile,
+    OracleRdbms,
+    OracleSchema,
+    OracleSourceConfig,
+    OracleTable,
+    PrivateConnection,
+    PrivateConnectivity,
+    Route,
+    SourceConfig,
+    SourceObjectIdentifier,
+    StaticServiceIpConnectivity,
+    Stream,
+    StreamObject,
+    Validation,
+    ValidationMessage,
+    ValidationResult,
+    VpcPeeringConfig,
+)
 
 __all__ = (
     "DatastreamAsyncClient",

packages/google-cloud-datastream/google/cloud/datastream_v1/services/datastream/__init__.py

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

packages/google-cloud-datastream/google/cloud/datastream_v1/services/datastream/async_client.py

@@ -17,14 +17,14 @@
 import functools
 import re
 from typing import Dict, Mapping, Optional, Sequence, Tuple, Type, Union
-import pkg_resources
 
-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 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
+import pkg_resources
 
 try:
     OptionalRetry = Union[retries.Retry, gapic_v1.method._MethodDefault]
@@ -33,15 +33,16 @@
 
 from google.api_core import operation  # type: ignore
 from google.api_core import operation_async  # type: ignore
-from google.cloud.datastream_v1.services.datastream import pagers
-from google.cloud.datastream_v1.types import datastream
-from google.cloud.datastream_v1.types import datastream_resources
 from google.protobuf import empty_pb2  # type: ignore
 from google.protobuf import field_mask_pb2  # type: ignore
 from google.protobuf import timestamp_pb2  # type: ignore
-from .transports.base import DatastreamTransport, DEFAULT_CLIENT_INFO
-from .transports.grpc_asyncio import DatastreamGrpcAsyncIOTransport
+
+from google.cloud.datastream_v1.services.datastream import pagers
+from google.cloud.datastream_v1.types import datastream, datastream_resources
+
 from .client import DatastreamClient
+from .transports.base import DEFAULT_CLIENT_INFO, DatastreamTransport
+from .transports.grpc_asyncio import DatastreamGrpcAsyncIOTransport
 
 
 class DatastreamAsyncClient: