diff options
Diffstat (limited to 'google/api_core/operations_v1/operations_async_client.py')
| -rw-r--r-- | google/api_core/operations_v1/operations_async_client.py | 16 |
1 files changed, 12 insertions, 4 deletions
diff --git a/google/api_core/operations_v1/operations_async_client.py b/google/api_core/operations_v1/operations_async_client.py index b3d0135..5a5e556 100644 --- a/google/api_core/operations_v1/operations_async_client.py +++ b/google/api_core/operations_v1/operations_async_client.py @@ -125,7 +125,9 @@ class OperationsAsyncClient: metadata = metadata or [] metadata.append(gapic_v1.routing_header.to_grpc_metadata({"name": name})) - return await self._get_operation(request, retry=retry, timeout=timeout, metadata=metadata) + return await self._get_operation( + request, retry=retry, timeout=timeout, metadata=metadata + ) async def list_operations( self, @@ -192,7 +194,9 @@ class OperationsAsyncClient: metadata.append(gapic_v1.routing_header.to_grpc_metadata({"name": name})) # Create the method used to fetch pages - method = functools.partial(self._list_operations, retry=retry, timeout=timeout, metadata=metadata) + method = functools.partial( + self._list_operations, retry=retry, timeout=timeout, metadata=metadata + ) iterator = page_iterator_async.AsyncGRPCIterator( client=None, @@ -260,7 +264,9 @@ class OperationsAsyncClient: metadata = metadata or [] metadata.append(gapic_v1.routing_header.to_grpc_metadata({"name": name})) - await self._cancel_operation(request, retry=retry, timeout=timeout, metadata=metadata) + await self._cancel_operation( + request, retry=retry, timeout=timeout, metadata=metadata + ) async def delete_operation( self, @@ -311,4 +317,6 @@ class OperationsAsyncClient: metadata = metadata or [] metadata.append(gapic_v1.routing_header.to_grpc_metadata({"name": name})) - await self._delete_operation(request, retry=retry, timeout=timeout, metadata=metadata) + await self._delete_operation( + request, retry=retry, timeout=timeout, metadata=metadata + ) |