Skip to content

Commit 13c39c6

Browse files
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>
1 parent 2f21e69 commit 13c39c6

File tree

30 files changed

+365
-361
lines changed

30 files changed

+365
-361
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -13,5 +13,5 @@
1313
# limitations under the License.
1414
docker:
1515
image: gcr.io/cloud-devrel-public-resources/owlbot-python:latest
16-
digest: sha256:8a5d3f6a2e43ed8293f34e06a2f56931d1e88a2694c3bb11b15df4eb256ad163
17-
# created: 2022-04-06T10:30:21.687684602Z
16+
digest: sha256:00c9d764fd1cd56265f12a5ef4b99a0c9e87cf261018099141e2ca5158890416
17+
# created: 2022-04-20T23:42:53.970438194Z

packages/google-cloud-datastream/docs/conf.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,9 +24,9 @@
2424
# All configuration values have a default; values that are commented out
2525
# serve to show the default.
2626

27-
import sys
2827
import os
2928
import shlex
29+
import sys
3030

3131
# If extensions (or modules to document with autodoc) are in another directory,
3232
# add these directories to sys.path here. If the directory is relative to the

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

Lines changed: 67 additions & 70 deletions
Original file line numberDiff line numberDiff line change
@@ -14,86 +14,83 @@
1414
# limitations under the License.
1515
#
1616

17-
from google.cloud.datastream_v1.services.datastream.client import DatastreamClient
1817
from google.cloud.datastream_v1.services.datastream.async_client import (
1918
DatastreamAsyncClient,
2019
)
21-
22-
from google.cloud.datastream_v1.types.datastream import CreateConnectionProfileRequest
23-
from google.cloud.datastream_v1.types.datastream import CreatePrivateConnectionRequest
24-
from google.cloud.datastream_v1.types.datastream import CreateRouteRequest
25-
from google.cloud.datastream_v1.types.datastream import CreateStreamRequest
26-
from google.cloud.datastream_v1.types.datastream import DeleteConnectionProfileRequest
27-
from google.cloud.datastream_v1.types.datastream import DeletePrivateConnectionRequest
28-
from google.cloud.datastream_v1.types.datastream import DeleteRouteRequest
29-
from google.cloud.datastream_v1.types.datastream import DeleteStreamRequest
30-
from google.cloud.datastream_v1.types.datastream import DiscoverConnectionProfileRequest
20+
from google.cloud.datastream_v1.services.datastream.client import DatastreamClient
3121
from google.cloud.datastream_v1.types.datastream import (
22+
CreateConnectionProfileRequest,
23+
CreatePrivateConnectionRequest,
24+
CreateRouteRequest,
25+
CreateStreamRequest,
26+
DeleteConnectionProfileRequest,
27+
DeletePrivateConnectionRequest,
28+
DeleteRouteRequest,
29+
DeleteStreamRequest,
30+
DiscoverConnectionProfileRequest,
3231
DiscoverConnectionProfileResponse,
32+
FetchStaticIpsRequest,
33+
FetchStaticIpsResponse,
34+
GetConnectionProfileRequest,
35+
GetPrivateConnectionRequest,
36+
GetRouteRequest,
37+
GetStreamObjectRequest,
38+
GetStreamRequest,
39+
ListConnectionProfilesRequest,
40+
ListConnectionProfilesResponse,
41+
ListPrivateConnectionsRequest,
42+
ListPrivateConnectionsResponse,
43+
ListRoutesRequest,
44+
ListRoutesResponse,
45+
ListStreamObjectsRequest,
46+
ListStreamObjectsResponse,
47+
ListStreamsRequest,
48+
ListStreamsResponse,
49+
LookupStreamObjectRequest,
50+
OperationMetadata,
51+
StartBackfillJobRequest,
52+
StartBackfillJobResponse,
53+
StopBackfillJobRequest,
54+
StopBackfillJobResponse,
55+
UpdateConnectionProfileRequest,
56+
UpdateStreamRequest,
3357
)
34-
from google.cloud.datastream_v1.types.datastream import FetchStaticIpsRequest
35-
from google.cloud.datastream_v1.types.datastream import FetchStaticIpsResponse
36-
from google.cloud.datastream_v1.types.datastream import GetConnectionProfileRequest
37-
from google.cloud.datastream_v1.types.datastream import GetPrivateConnectionRequest
38-
from google.cloud.datastream_v1.types.datastream import GetRouteRequest
39-
from google.cloud.datastream_v1.types.datastream import GetStreamObjectRequest
40-
from google.cloud.datastream_v1.types.datastream import GetStreamRequest
41-
from google.cloud.datastream_v1.types.datastream import ListConnectionProfilesRequest
42-
from google.cloud.datastream_v1.types.datastream import ListConnectionProfilesResponse
43-
from google.cloud.datastream_v1.types.datastream import ListPrivateConnectionsRequest
44-
from google.cloud.datastream_v1.types.datastream import ListPrivateConnectionsResponse
45-
from google.cloud.datastream_v1.types.datastream import ListRoutesRequest
46-
from google.cloud.datastream_v1.types.datastream import ListRoutesResponse
47-
from google.cloud.datastream_v1.types.datastream import ListStreamObjectsRequest
48-
from google.cloud.datastream_v1.types.datastream import ListStreamObjectsResponse
49-
from google.cloud.datastream_v1.types.datastream import ListStreamsRequest
50-
from google.cloud.datastream_v1.types.datastream import ListStreamsResponse
51-
from google.cloud.datastream_v1.types.datastream import LookupStreamObjectRequest
52-
from google.cloud.datastream_v1.types.datastream import OperationMetadata
53-
from google.cloud.datastream_v1.types.datastream import StartBackfillJobRequest
54-
from google.cloud.datastream_v1.types.datastream import StartBackfillJobResponse
55-
from google.cloud.datastream_v1.types.datastream import StopBackfillJobRequest
56-
from google.cloud.datastream_v1.types.datastream import StopBackfillJobResponse
57-
from google.cloud.datastream_v1.types.datastream import UpdateConnectionProfileRequest
58-
from google.cloud.datastream_v1.types.datastream import UpdateStreamRequest
59-
from google.cloud.datastream_v1.types.datastream_resources import AvroFileFormat
60-
from google.cloud.datastream_v1.types.datastream_resources import BackfillJob
61-
from google.cloud.datastream_v1.types.datastream_resources import ConnectionProfile
62-
from google.cloud.datastream_v1.types.datastream_resources import DestinationConfig
63-
from google.cloud.datastream_v1.types.datastream_resources import Error
6458
from google.cloud.datastream_v1.types.datastream_resources import (
59+
AvroFileFormat,
60+
BackfillJob,
61+
ConnectionProfile,
62+
DestinationConfig,
63+
Error,
6564
ForwardSshTunnelConnectivity,
66-
)
67-
from google.cloud.datastream_v1.types.datastream_resources import GcsDestinationConfig
68-
from google.cloud.datastream_v1.types.datastream_resources import GcsProfile
69-
from google.cloud.datastream_v1.types.datastream_resources import JsonFileFormat
70-
from google.cloud.datastream_v1.types.datastream_resources import MysqlColumn
71-
from google.cloud.datastream_v1.types.datastream_resources import MysqlDatabase
72-
from google.cloud.datastream_v1.types.datastream_resources import MysqlProfile
73-
from google.cloud.datastream_v1.types.datastream_resources import MysqlRdbms
74-
from google.cloud.datastream_v1.types.datastream_resources import MysqlSourceConfig
75-
from google.cloud.datastream_v1.types.datastream_resources import MysqlSslConfig
76-
from google.cloud.datastream_v1.types.datastream_resources import MysqlTable
77-
from google.cloud.datastream_v1.types.datastream_resources import OracleColumn
78-
from google.cloud.datastream_v1.types.datastream_resources import OracleProfile
79-
from google.cloud.datastream_v1.types.datastream_resources import OracleRdbms
80-
from google.cloud.datastream_v1.types.datastream_resources import OracleSchema
81-
from google.cloud.datastream_v1.types.datastream_resources import OracleSourceConfig
82-
from google.cloud.datastream_v1.types.datastream_resources import OracleTable
83-
from google.cloud.datastream_v1.types.datastream_resources import PrivateConnection
84-
from google.cloud.datastream_v1.types.datastream_resources import PrivateConnectivity
85-
from google.cloud.datastream_v1.types.datastream_resources import Route
86-
from google.cloud.datastream_v1.types.datastream_resources import SourceConfig
87-
from google.cloud.datastream_v1.types.datastream_resources import SourceObjectIdentifier
88-
from google.cloud.datastream_v1.types.datastream_resources import (
65+
GcsDestinationConfig,
66+
GcsProfile,
67+
JsonFileFormat,
68+
MysqlColumn,
69+
MysqlDatabase,
70+
MysqlProfile,
71+
MysqlRdbms,
72+
MysqlSourceConfig,
73+
MysqlSslConfig,
74+
MysqlTable,
75+
OracleColumn,
76+
OracleProfile,
77+
OracleRdbms,
78+
OracleSchema,
79+
OracleSourceConfig,
80+
OracleTable,
81+
PrivateConnection,
82+
PrivateConnectivity,
83+
Route,
84+
SourceConfig,
85+
SourceObjectIdentifier,
8986
StaticServiceIpConnectivity,
87+
Stream,
88+
StreamObject,
89+
Validation,
90+
ValidationMessage,
91+
ValidationResult,
92+
VpcPeeringConfig,
9093
)
91-
from google.cloud.datastream_v1.types.datastream_resources import Stream
92-
from google.cloud.datastream_v1.types.datastream_resources import StreamObject
93-
from google.cloud.datastream_v1.types.datastream_resources import Validation
94-
from google.cloud.datastream_v1.types.datastream_resources import ValidationMessage
95-
from google.cloud.datastream_v1.types.datastream_resources import ValidationResult
96-
from google.cloud.datastream_v1.types.datastream_resources import VpcPeeringConfig
9794

9895
__all__ = (
9996
"DatastreamClient",

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

Lines changed: 74 additions & 72 deletions
Original file line numberDiff line numberDiff line change
@@ -14,78 +14,80 @@
1414
# limitations under the License.
1515
#
1616

17-
from .services.datastream import DatastreamClient
18-
from .services.datastream import DatastreamAsyncClient
19-
20-
from .types.datastream import CreateConnectionProfileRequest
21-
from .types.datastream import CreatePrivateConnectionRequest
22-
from .types.datastream import CreateRouteRequest
23-
from .types.datastream import CreateStreamRequest
24-
from .types.datastream import DeleteConnectionProfileRequest
25-
from .types.datastream import DeletePrivateConnectionRequest
26-
from .types.datastream import DeleteRouteRequest
27-
from .types.datastream import DeleteStreamRequest
28-
from .types.datastream import DiscoverConnectionProfileRequest
29-
from .types.datastream import DiscoverConnectionProfileResponse
30-
from .types.datastream import FetchStaticIpsRequest
31-
from .types.datastream import FetchStaticIpsResponse
32-
from .types.datastream import GetConnectionProfileRequest
33-
from .types.datastream import GetPrivateConnectionRequest
34-
from .types.datastream import GetRouteRequest
35-
from .types.datastream import GetStreamObjectRequest
36-
from .types.datastream import GetStreamRequest
37-
from .types.datastream import ListConnectionProfilesRequest
38-
from .types.datastream import ListConnectionProfilesResponse
39-
from .types.datastream import ListPrivateConnectionsRequest
40-
from .types.datastream import ListPrivateConnectionsResponse
41-
from .types.datastream import ListRoutesRequest
42-
from .types.datastream import ListRoutesResponse
43-
from .types.datastream import ListStreamObjectsRequest
44-
from .types.datastream import ListStreamObjectsResponse
45-
from .types.datastream import ListStreamsRequest
46-
from .types.datastream import ListStreamsResponse
47-
from .types.datastream import LookupStreamObjectRequest
48-
from .types.datastream import OperationMetadata
49-
from .types.datastream import StartBackfillJobRequest
50-
from .types.datastream import StartBackfillJobResponse
51-
from .types.datastream import StopBackfillJobRequest
52-
from .types.datastream import StopBackfillJobResponse
53-
from .types.datastream import UpdateConnectionProfileRequest
54-
from .types.datastream import UpdateStreamRequest
55-
from .types.datastream_resources import AvroFileFormat
56-
from .types.datastream_resources import BackfillJob
57-
from .types.datastream_resources import ConnectionProfile
58-
from .types.datastream_resources import DestinationConfig
59-
from .types.datastream_resources import Error
60-
from .types.datastream_resources import ForwardSshTunnelConnectivity
61-
from .types.datastream_resources import GcsDestinationConfig
62-
from .types.datastream_resources import GcsProfile
63-
from .types.datastream_resources import JsonFileFormat
64-
from .types.datastream_resources import MysqlColumn
65-
from .types.datastream_resources import MysqlDatabase
66-
from .types.datastream_resources import MysqlProfile
67-
from .types.datastream_resources import MysqlRdbms
68-
from .types.datastream_resources import MysqlSourceConfig
69-
from .types.datastream_resources import MysqlSslConfig
70-
from .types.datastream_resources import MysqlTable
71-
from .types.datastream_resources import OracleColumn
72-
from .types.datastream_resources import OracleProfile
73-
from .types.datastream_resources import OracleRdbms
74-
from .types.datastream_resources import OracleSchema
75-
from .types.datastream_resources import OracleSourceConfig
76-
from .types.datastream_resources import OracleTable
77-
from .types.datastream_resources import PrivateConnection
78-
from .types.datastream_resources import PrivateConnectivity
79-
from .types.datastream_resources import Route
80-
from .types.datastream_resources import SourceConfig
81-
from .types.datastream_resources import SourceObjectIdentifier
82-
from .types.datastream_resources import StaticServiceIpConnectivity
83-
from .types.datastream_resources import Stream
84-
from .types.datastream_resources import StreamObject
85-
from .types.datastream_resources import Validation
86-
from .types.datastream_resources import ValidationMessage
87-
from .types.datastream_resources import ValidationResult
88-
from .types.datastream_resources import VpcPeeringConfig
17+
from .services.datastream import DatastreamAsyncClient, DatastreamClient
18+
from .types.datastream import (
19+
CreateConnectionProfileRequest,
20+
CreatePrivateConnectionRequest,
21+
CreateRouteRequest,
22+
CreateStreamRequest,
23+
DeleteConnectionProfileRequest,
24+
DeletePrivateConnectionRequest,
25+
DeleteRouteRequest,
26+
DeleteStreamRequest,
27+
DiscoverConnectionProfileRequest,
28+
DiscoverConnectionProfileResponse,
29+
FetchStaticIpsRequest,
30+
FetchStaticIpsResponse,
31+
GetConnectionProfileRequest,
32+
GetPrivateConnectionRequest,
33+
GetRouteRequest,
34+
GetStreamObjectRequest,
35+
GetStreamRequest,
36+
ListConnectionProfilesRequest,
37+
ListConnectionProfilesResponse,
38+
ListPrivateConnectionsRequest,
39+
ListPrivateConnectionsResponse,
40+
ListRoutesRequest,
41+
ListRoutesResponse,
42+
ListStreamObjectsRequest,
43+
ListStreamObjectsResponse,
44+
ListStreamsRequest,
45+
ListStreamsResponse,
46+
LookupStreamObjectRequest,
47+
OperationMetadata,
48+
StartBackfillJobRequest,
49+
StartBackfillJobResponse,
50+
StopBackfillJobRequest,
51+
StopBackfillJobResponse,
52+
UpdateConnectionProfileRequest,
53+
UpdateStreamRequest,
54+
)
55+
from .types.datastream_resources import (
56+
AvroFileFormat,
57+
BackfillJob,
58+
ConnectionProfile,
59+
DestinationConfig,
60+
Error,
61+
ForwardSshTunnelConnectivity,
62+
GcsDestinationConfig,
63+
GcsProfile,
64+
JsonFileFormat,
65+
MysqlColumn,
66+
MysqlDatabase,
67+
MysqlProfile,
68+
MysqlRdbms,
69+
MysqlSourceConfig,
70+
MysqlSslConfig,
71+
MysqlTable,
72+
OracleColumn,
73+
OracleProfile,
74+
OracleRdbms,
75+
OracleSchema,
76+
OracleSourceConfig,
77+
OracleTable,
78+
PrivateConnection,
79+
PrivateConnectivity,
80+
Route,
81+
SourceConfig,
82+
SourceObjectIdentifier,
83+
StaticServiceIpConnectivity,
84+
Stream,
85+
StreamObject,
86+
Validation,
87+
ValidationMessage,
88+
ValidationResult,
89+
VpcPeeringConfig,
90+
)
8991

9092
__all__ = (
9193
"DatastreamAsyncClient",

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,8 +13,8 @@
1313
# See the License for the specific language governing permissions and
1414
# limitations under the License.
1515
#
16-
from .client import DatastreamClient
1716
from .async_client import DatastreamAsyncClient
17+
from .client import DatastreamClient
1818

1919
__all__ = (
2020
"DatastreamClient",

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

Lines changed: 8 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -17,14 +17,14 @@
1717
import functools
1818
import re
1919
from typing import Dict, Mapping, Optional, Sequence, Tuple, Type, Union
20-
import pkg_resources
2120

22-
from google.api_core.client_options import ClientOptions
2321
from google.api_core import exceptions as core_exceptions
2422
from google.api_core import gapic_v1
2523
from google.api_core import retry as retries
24+
from google.api_core.client_options import ClientOptions
2625
from google.auth import credentials as ga_credentials # type: ignore
2726
from google.oauth2 import service_account # type: ignore
27+
import pkg_resources
2828

2929
try:
3030
OptionalRetry = Union[retries.Retry, gapic_v1.method._MethodDefault]
@@ -33,15 +33,16 @@
3333

3434
from google.api_core import operation # type: ignore
3535
from google.api_core import operation_async # type: ignore
36-
from google.cloud.datastream_v1.services.datastream import pagers
37-
from google.cloud.datastream_v1.types import datastream
38-
from google.cloud.datastream_v1.types import datastream_resources
3936
from google.protobuf import empty_pb2 # type: ignore
4037
from google.protobuf import field_mask_pb2 # type: ignore
4138
from google.protobuf import timestamp_pb2 # type: ignore
42-
from .transports.base import DatastreamTransport, DEFAULT_CLIENT_INFO
43-
from .transports.grpc_asyncio import DatastreamGrpcAsyncIOTransport
39+
40+
from google.cloud.datastream_v1.services.datastream import pagers
41+
from google.cloud.datastream_v1.types import datastream, datastream_resources
42+
4443
from .client import DatastreamClient
44+
from .transports.base import DEFAULT_CLIENT_INFO, DatastreamTransport
45+
from .transports.grpc_asyncio import DatastreamGrpcAsyncIOTransport
4546

4647

4748
class DatastreamAsyncClient:

0 commit comments

Comments
 (0)