Skip to content

Commit 08ce293

Browse files
gcf-owl-bot[bot]gcf-owl-bot[bot]
authored
chore(python): use black==22.3.0 (#69)
Source-Link: googleapis/synthtool@6fab84a Post-Processor: gcr.io/cloud-devrel-public-resources/owlbot-python:latest@sha256:7cffbc10910c3ab1b852c05114a08d374c195a81cdec1d4a67a1d129331d0bfe
1 parent 6661a1f commit 08ce293

10 files changed

Lines changed: 788 additions & 219 deletions

File tree

‎packages/google-cloud-storage-transfer/.github/.OwlBot.lock.yaml‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,4 +13,4 @@
1313
# limitations under the License.
1414
docker:
1515
image: gcr.io/cloud-devrel-public-resources/owlbot-python:latest
16-
digest: sha256:2d13c2172a5d6129c861edaa48b60ead15aeaf58aa75e02d870c4cbdfa63aaba
16+
digest: sha256:7cffbc10910c3ab1b852c05114a08d374c195a81cdec1d4a67a1d129331d0bfe

‎packages/google-cloud-storage-transfer/docs/conf.py‎

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -361,7 +361,10 @@
361361
intersphinx_mapping = {
362362
"python": ("https://python.readthedocs.org/en/latest/", None),
363363
"google-auth": ("https://googleapis.dev/python/google-auth/latest/", None),
364-
"google.api_core": ("https://googleapis.dev/python/google-api-core/latest/", None,),
364+
"google.api_core": (
365+
"https://googleapis.dev/python/google-api-core/latest/",
366+
None,
367+
),
365368
"grpc": ("https://grpc.github.io/grpc/python/", None),
366369
"proto-plus": ("https://proto-plus-python.readthedocs.io/en/latest/", None),
367370
"protobuf": ("https://googleapis.dev/python/protobuf/latest/", None),

‎packages/google-cloud-storage-transfer/google/cloud/storage_transfer_v1/services/storage_transfer_service/async_client.py‎

Lines changed: 48 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -276,7 +276,12 @@ def sample_get_google_service_account():
276276
)
277277

278278
# Send the request.
279-
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
279+
response = await rpc(
280+
request,
281+
retry=retry,
282+
timeout=timeout,
283+
metadata=metadata,
284+
)
280285

281286
# Done; return the response.
282287
return response
@@ -337,7 +342,12 @@ def sample_create_transfer_job():
337342
)
338343

339344
# Send the request.
340-
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
345+
response = await rpc(
346+
request,
347+
retry=retry,
348+
timeout=timeout,
349+
metadata=metadata,
350+
)
341351

342352
# Done; return the response.
343353
return response
@@ -417,7 +427,12 @@ def sample_update_transfer_job():
417427
)
418428

419429
# Send the request.
420-
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
430+
response = await rpc(
431+
request,
432+
retry=retry,
433+
timeout=timeout,
434+
metadata=metadata,
435+
)
421436

422437
# Done; return the response.
423438
return response
@@ -486,7 +501,12 @@ def sample_get_transfer_job():
486501
)
487502

488503
# Send the request.
489-
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
504+
response = await rpc(
505+
request,
506+
retry=retry,
507+
timeout=timeout,
508+
metadata=metadata,
509+
)
490510

491511
# Done; return the response.
492512
return response
@@ -552,12 +572,20 @@ def sample_list_transfer_jobs():
552572
)
553573

554574
# Send the request.
555-
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
575+
response = await rpc(
576+
request,
577+
retry=retry,
578+
timeout=timeout,
579+
metadata=metadata,
580+
)
556581

557582
# This method is paged; wrap the response in a pager, which provides
558583
# an `__aiter__` convenience method.
559584
response = pagers.ListTransferJobsAsyncPager(
560-
method=rpc, request=request, response=response, metadata=metadata,
585+
method=rpc,
586+
request=request,
587+
response=response,
588+
metadata=metadata,
561589
)
562590

563591
# Done; return the response.
@@ -618,7 +646,10 @@ def sample_pause_transfer_operation():
618646

619647
# Send the request.
620648
await rpc(
621-
request, retry=retry, timeout=timeout, metadata=metadata,
649+
request,
650+
retry=retry,
651+
timeout=timeout,
652+
metadata=metadata,
622653
)
623654

624655
async def resume_transfer_operation(
@@ -676,7 +707,10 @@ def sample_resume_transfer_operation():
676707

677708
# Send the request.
678709
await rpc(
679-
request, retry=retry, timeout=timeout, metadata=metadata,
710+
request,
711+
retry=retry,
712+
timeout=timeout,
713+
metadata=metadata,
680714
)
681715

682716
async def run_transfer_job(
@@ -763,7 +797,12 @@ def sample_run_transfer_job():
763797
)
764798

765799
# Send the request.
766-
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
800+
response = await rpc(
801+
request,
802+
retry=retry,
803+
timeout=timeout,
804+
metadata=metadata,
805+
)
767806

768807
# Wrap the response in an operation future.
769808
response = operation_async.from_gapic(

‎packages/google-cloud-storage-transfer/google/cloud/storage_transfer_v1/services/storage_transfer_service/client.py‎

Lines changed: 77 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,8 @@ class StorageTransferServiceClientMeta(type):
6161
_transport_registry["grpc_asyncio"] = StorageTransferServiceGrpcAsyncIOTransport
6262

6363
def get_transport_class(
64-
cls, label: str = None,
64+
cls,
65+
label: str = None,
6566
) -> Type[StorageTransferServiceTransport]:
6667
"""Returns an appropriate transport class.
6768
@@ -170,7 +171,9 @@ def transport(self) -> StorageTransferServiceTransport:
170171
return self._transport
171172

172173
@staticmethod
173-
def common_billing_account_path(billing_account: str,) -> str:
174+
def common_billing_account_path(
175+
billing_account: str,
176+
) -> str:
174177
"""Returns a fully-qualified billing_account string."""
175178
return "billingAccounts/{billing_account}".format(
176179
billing_account=billing_account,
@@ -183,9 +186,13 @@ def parse_common_billing_account_path(path: str) -> Dict[str, str]:
183186
return m.groupdict() if m else {}
184187

185188
@staticmethod
186-
def common_folder_path(folder: str,) -> str:
189+
def common_folder_path(
190+
folder: str,
191+
) -> str:
187192
"""Returns a fully-qualified folder string."""
188-
return "folders/{folder}".format(folder=folder,)
193+
return "folders/{folder}".format(
194+
folder=folder,
195+
)
189196

190197
@staticmethod
191198
def parse_common_folder_path(path: str) -> Dict[str, str]:
@@ -194,9 +201,13 @@ def parse_common_folder_path(path: str) -> Dict[str, str]:
194201
return m.groupdict() if m else {}
195202

196203
@staticmethod
197-
def common_organization_path(organization: str,) -> str:
204+
def common_organization_path(
205+
organization: str,
206+
) -> str:
198207
"""Returns a fully-qualified organization string."""
199-
return "organizations/{organization}".format(organization=organization,)
208+
return "organizations/{organization}".format(
209+
organization=organization,
210+
)
200211

201212
@staticmethod
202213
def parse_common_organization_path(path: str) -> Dict[str, str]:
@@ -205,9 +216,13 @@ def parse_common_organization_path(path: str) -> Dict[str, str]:
205216
return m.groupdict() if m else {}
206217

207218
@staticmethod
208-
def common_project_path(project: str,) -> str:
219+
def common_project_path(
220+
project: str,
221+
) -> str:
209222
"""Returns a fully-qualified project string."""
210-
return "projects/{project}".format(project=project,)
223+
return "projects/{project}".format(
224+
project=project,
225+
)
211226

212227
@staticmethod
213228
def parse_common_project_path(path: str) -> Dict[str, str]:
@@ -216,10 +231,14 @@ def parse_common_project_path(path: str) -> Dict[str, str]:
216231
return m.groupdict() if m else {}
217232

218233
@staticmethod
219-
def common_location_path(project: str, location: str,) -> str:
234+
def common_location_path(
235+
project: str,
236+
location: str,
237+
) -> str:
220238
"""Returns a fully-qualified location string."""
221239
return "projects/{project}/locations/{location}".format(
222-
project=project, location=location,
240+
project=project,
241+
location=location,
223242
)
224243

225244
@staticmethod
@@ -461,7 +480,12 @@ def sample_get_google_service_account():
461480
]
462481

463482
# Send the request.
464-
response = rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
483+
response = rpc(
484+
request,
485+
retry=retry,
486+
timeout=timeout,
487+
metadata=metadata,
488+
)
465489

466490
# Done; return the response.
467491
return response
@@ -523,7 +547,12 @@ def sample_create_transfer_job():
523547
rpc = self._transport._wrapped_methods[self._transport.create_transfer_job]
524548

525549
# Send the request.
526-
response = rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
550+
response = rpc(
551+
request,
552+
retry=retry,
553+
timeout=timeout,
554+
metadata=metadata,
555+
)
527556

528557
# Done; return the response.
529558
return response
@@ -604,7 +633,12 @@ def sample_update_transfer_job():
604633
)
605634

606635
# Send the request.
607-
response = rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
636+
response = rpc(
637+
request,
638+
retry=retry,
639+
timeout=timeout,
640+
metadata=metadata,
641+
)
608642

609643
# Done; return the response.
610644
return response
@@ -674,7 +708,12 @@ def sample_get_transfer_job():
674708
)
675709

676710
# Send the request.
677-
response = rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
711+
response = rpc(
712+
request,
713+
retry=retry,
714+
timeout=timeout,
715+
metadata=metadata,
716+
)
678717

679718
# Done; return the response.
680719
return response
@@ -741,12 +780,20 @@ def sample_list_transfer_jobs():
741780
rpc = self._transport._wrapped_methods[self._transport.list_transfer_jobs]
742781

743782
# Send the request.
744-
response = rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
783+
response = rpc(
784+
request,
785+
retry=retry,
786+
timeout=timeout,
787+
metadata=metadata,
788+
)
745789

746790
# This method is paged; wrap the response in a pager, which provides
747791
# an `__iter__` convenience method.
748792
response = pagers.ListTransferJobsPager(
749-
method=rpc, request=request, response=response, metadata=metadata,
793+
method=rpc,
794+
request=request,
795+
response=response,
796+
metadata=metadata,
750797
)
751798

752799
# Done; return the response.
@@ -808,7 +855,10 @@ def sample_pause_transfer_operation():
808855

809856
# Send the request.
810857
rpc(
811-
request, retry=retry, timeout=timeout, metadata=metadata,
858+
request,
859+
retry=retry,
860+
timeout=timeout,
861+
metadata=metadata,
812862
)
813863

814864
def resume_transfer_operation(
@@ -869,7 +919,10 @@ def sample_resume_transfer_operation():
869919

870920
# Send the request.
871921
rpc(
872-
request, retry=retry, timeout=timeout, metadata=metadata,
922+
request,
923+
retry=retry,
924+
timeout=timeout,
925+
metadata=metadata,
873926
)
874927

875928
def run_transfer_job(
@@ -957,7 +1010,12 @@ def sample_run_transfer_job():
9571010
)
9581011

9591012
# Send the request.
960-
response = rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
1013+
response = rpc(
1014+
request,
1015+
retry=retry,
1016+
timeout=timeout,
1017+
metadata=metadata,
1018+
)
9611019

9621020
# Wrap the response in an operation future.
9631021
response = operation.from_gapic(

‎packages/google-cloud-storage-transfer/google/cloud/storage_transfer_v1/services/storage_transfer_service/transports/base.py‎

Lines changed: 18 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -130,16 +130,24 @@ def _prep_wrapped_messages(self, client_info):
130130
client_info=client_info,
131131
),
132132
self.create_transfer_job: gapic_v1.method.wrap_method(
133-
self.create_transfer_job, default_timeout=None, client_info=client_info,
133+
self.create_transfer_job,
134+
default_timeout=None,
135+
client_info=client_info,
134136
),
135137
self.update_transfer_job: gapic_v1.method.wrap_method(
136-
self.update_transfer_job, default_timeout=None, client_info=client_info,
138+
self.update_transfer_job,
139+
default_timeout=None,
140+
client_info=client_info,
137141
),
138142
self.get_transfer_job: gapic_v1.method.wrap_method(
139-
self.get_transfer_job, default_timeout=None, client_info=client_info,
143+
self.get_transfer_job,
144+
default_timeout=None,
145+
client_info=client_info,
140146
),
141147
self.list_transfer_jobs: gapic_v1.method.wrap_method(
142-
self.list_transfer_jobs, default_timeout=None, client_info=client_info,
148+
self.list_transfer_jobs,
149+
default_timeout=None,
150+
client_info=client_info,
143151
),
144152
self.pause_transfer_operation: gapic_v1.method.wrap_method(
145153
self.pause_transfer_operation,
@@ -152,16 +160,18 @@ def _prep_wrapped_messages(self, client_info):
152160
client_info=client_info,
153161
),
154162
self.run_transfer_job: gapic_v1.method.wrap_method(
155-
self.run_transfer_job, default_timeout=None, client_info=client_info,
163+
self.run_transfer_job,
164+
default_timeout=None,
165+
client_info=client_info,
156166
),
157167
}
158168

159169
def close(self):
160170
"""Closes resources associated with the transport.
161171
162-
.. warning::
163-
Only call this method if the transport is NOT shared
164-
with other clients - this may cause errors in other clients!
172+
.. warning::
173+
Only call this method if the transport is NOT shared
174+
with other clients - this may cause errors in other clients!
165175
"""
166176
raise NotImplementedError()
167177

‎packages/google-cloud-storage-transfer/google/cloud/storage_transfer_v1/services/storage_transfer_service/transports/grpc.py‎

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -231,8 +231,7 @@ def create_channel(
231231

232232
@property
233233
def grpc_channel(self) -> grpc.Channel:
234-
"""Return the channel designed to connect to this service.
235-
"""
234+
"""Return the channel designed to connect to this service."""
236235
return self._grpc_channel
237236

238237
@property

0 commit comments

Comments
 (0)