|
16 | 16 | from collections import OrderedDict |
17 | 17 | import functools |
18 | 18 | import re |
19 | | -from typing import Dict, Mapping, Optional, Sequence, Tuple, Type, Union |
| 19 | +from typing import ( |
| 20 | + Dict, |
| 21 | + Mapping, |
| 22 | + MutableMapping, |
| 23 | + MutableSequence, |
| 24 | + Optional, |
| 25 | + Sequence, |
| 26 | + Tuple, |
| 27 | + Type, |
| 28 | + Union, |
| 29 | +) |
20 | 30 |
|
21 | 31 | from google.api_core import exceptions as core_exceptions |
22 | 32 | from google.api_core import gapic_v1 |
@@ -176,9 +186,9 @@ def transport(self) -> AssuredWorkloadsServiceTransport: |
176 | 186 | def __init__( |
177 | 187 | self, |
178 | 188 | *, |
179 | | - credentials: ga_credentials.Credentials = None, |
| 189 | + credentials: Optional[ga_credentials.Credentials] = None, |
180 | 190 | transport: Union[str, AssuredWorkloadsServiceTransport] = "grpc_asyncio", |
181 | | - client_options: ClientOptions = None, |
| 191 | + client_options: Optional[ClientOptions] = None, |
182 | 192 | client_info: gapic_v1.client_info.ClientInfo = DEFAULT_CLIENT_INFO, |
183 | 193 | ) -> None: |
184 | 194 | """Instantiates the assured workloads service client. |
@@ -222,12 +232,12 @@ def __init__( |
222 | 232 |
|
223 | 233 | async def create_workload( |
224 | 234 | self, |
225 | | - request: Union[assuredworkloads.CreateWorkloadRequest, dict] = None, |
| 235 | + request: Optional[Union[assuredworkloads.CreateWorkloadRequest, dict]] = None, |
226 | 236 | *, |
227 | | - parent: str = None, |
228 | | - workload: assuredworkloads.Workload = None, |
| 237 | + parent: Optional[str] = None, |
| 238 | + workload: Optional[assuredworkloads.Workload] = None, |
229 | 239 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
230 | | - timeout: float = None, |
| 240 | + timeout: Optional[float] = None, |
231 | 241 | metadata: Sequence[Tuple[str, str]] = (), |
232 | 242 | ) -> operation_async.AsyncOperation: |
233 | 243 | r"""Creates Assured Workload. |
@@ -268,7 +278,7 @@ async def sample_create_workload(): |
268 | 278 | print(response) |
269 | 279 |
|
270 | 280 | Args: |
271 | | - request (Union[google.cloud.assuredworkloads_v1.types.CreateWorkloadRequest, dict]): |
| 281 | + request (Optional[Union[google.cloud.assuredworkloads_v1.types.CreateWorkloadRequest, dict]]): |
272 | 282 | The request object. Request for creating a workload. |
273 | 283 | parent (:class:`str`): |
274 | 284 | Required. The resource name of the new Workload's |
@@ -351,12 +361,12 @@ async def sample_create_workload(): |
351 | 361 |
|
352 | 362 | async def update_workload( |
353 | 363 | self, |
354 | | - request: Union[assuredworkloads.UpdateWorkloadRequest, dict] = None, |
| 364 | + request: Optional[Union[assuredworkloads.UpdateWorkloadRequest, dict]] = None, |
355 | 365 | *, |
356 | | - workload: assuredworkloads.Workload = None, |
357 | | - update_mask: field_mask_pb2.FieldMask = None, |
| 366 | + workload: Optional[assuredworkloads.Workload] = None, |
| 367 | + update_mask: Optional[field_mask_pb2.FieldMask] = None, |
358 | 368 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
359 | | - timeout: float = None, |
| 369 | + timeout: Optional[float] = None, |
360 | 370 | metadata: Sequence[Tuple[str, str]] = (), |
361 | 371 | ) -> assuredworkloads.Workload: |
362 | 372 | r"""Updates an existing workload. Currently allows updating of |
@@ -395,7 +405,7 @@ async def sample_update_workload(): |
395 | 405 | print(response) |
396 | 406 |
|
397 | 407 | Args: |
398 | | - request (Union[google.cloud.assuredworkloads_v1.types.UpdateWorkloadRequest, dict]): |
| 408 | + request (Optional[Union[google.cloud.assuredworkloads_v1.types.UpdateWorkloadRequest, dict]]): |
399 | 409 | The request object. Request for Updating a workload. |
400 | 410 | workload (:class:`google.cloud.assuredworkloads_v1.types.Workload`): |
401 | 411 | Required. The workload to update. The workload's |
@@ -473,10 +483,12 @@ async def sample_update_workload(): |
473 | 483 |
|
474 | 484 | async def restrict_allowed_resources( |
475 | 485 | self, |
476 | | - request: Union[assuredworkloads.RestrictAllowedResourcesRequest, dict] = None, |
| 486 | + request: Optional[ |
| 487 | + Union[assuredworkloads.RestrictAllowedResourcesRequest, dict] |
| 488 | + ] = None, |
477 | 489 | *, |
478 | 490 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
479 | | - timeout: float = None, |
| 491 | + timeout: Optional[float] = None, |
480 | 492 | metadata: Sequence[Tuple[str, str]] = (), |
481 | 493 | ) -> assuredworkloads.RestrictAllowedResourcesResponse: |
482 | 494 | r"""Restrict the list of resources allowed in the |
@@ -516,7 +528,7 @@ async def sample_restrict_allowed_resources(): |
516 | 528 | print(response) |
517 | 529 |
|
518 | 530 | Args: |
519 | | - request (Union[google.cloud.assuredworkloads_v1.types.RestrictAllowedResourcesRequest, dict]): |
| 531 | + request (Optional[Union[google.cloud.assuredworkloads_v1.types.RestrictAllowedResourcesRequest, dict]]): |
520 | 532 | The request object. Request for restricting list of |
521 | 533 | available resources in Workload environment. |
522 | 534 | retry (google.api_core.retry.Retry): Designation of what errors, if any, |
@@ -561,11 +573,11 @@ async def sample_restrict_allowed_resources(): |
561 | 573 |
|
562 | 574 | async def delete_workload( |
563 | 575 | self, |
564 | | - request: Union[assuredworkloads.DeleteWorkloadRequest, dict] = None, |
| 576 | + request: Optional[Union[assuredworkloads.DeleteWorkloadRequest, dict]] = None, |
565 | 577 | *, |
566 | | - name: str = None, |
| 578 | + name: Optional[str] = None, |
567 | 579 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
568 | | - timeout: float = None, |
| 580 | + timeout: Optional[float] = None, |
569 | 581 | metadata: Sequence[Tuple[str, str]] = (), |
570 | 582 | ) -> None: |
571 | 583 | r"""Deletes the workload. Make sure that workload's direct children |
@@ -596,7 +608,7 @@ async def sample_delete_workload(): |
596 | 608 | await client.delete_workload(request=request) |
597 | 609 |
|
598 | 610 | Args: |
599 | | - request (Union[google.cloud.assuredworkloads_v1.types.DeleteWorkloadRequest, dict]): |
| 611 | + request (Optional[Union[google.cloud.assuredworkloads_v1.types.DeleteWorkloadRequest, dict]]): |
600 | 612 | The request object. Request for deleting a Workload. |
601 | 613 | name (:class:`str`): |
602 | 614 | Required. The ``name`` field is used to identify the |
@@ -653,11 +665,11 @@ async def sample_delete_workload(): |
653 | 665 |
|
654 | 666 | async def get_workload( |
655 | 667 | self, |
656 | | - request: Union[assuredworkloads.GetWorkloadRequest, dict] = None, |
| 668 | + request: Optional[Union[assuredworkloads.GetWorkloadRequest, dict]] = None, |
657 | 669 | *, |
658 | | - name: str = None, |
| 670 | + name: Optional[str] = None, |
659 | 671 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
660 | | - timeout: float = None, |
| 672 | + timeout: Optional[float] = None, |
661 | 673 | metadata: Sequence[Tuple[str, str]] = (), |
662 | 674 | ) -> assuredworkloads.Workload: |
663 | 675 | r"""Gets Assured Workload associated with a CRM Node |
@@ -689,7 +701,7 @@ async def sample_get_workload(): |
689 | 701 | print(response) |
690 | 702 |
|
691 | 703 | Args: |
692 | | - request (Union[google.cloud.assuredworkloads_v1.types.GetWorkloadRequest, dict]): |
| 704 | + request (Optional[Union[google.cloud.assuredworkloads_v1.types.GetWorkloadRequest, dict]]): |
693 | 705 | The request object. Request for fetching a workload. |
694 | 706 | name (:class:`str`): |
695 | 707 | Required. The resource name of the Workload to fetch. |
@@ -758,11 +770,11 @@ async def sample_get_workload(): |
758 | 770 |
|
759 | 771 | async def list_workloads( |
760 | 772 | self, |
761 | | - request: Union[assuredworkloads.ListWorkloadsRequest, dict] = None, |
| 773 | + request: Optional[Union[assuredworkloads.ListWorkloadsRequest, dict]] = None, |
762 | 774 | *, |
763 | | - parent: str = None, |
| 775 | + parent: Optional[str] = None, |
764 | 776 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
765 | | - timeout: float = None, |
| 777 | + timeout: Optional[float] = None, |
766 | 778 | metadata: Sequence[Tuple[str, str]] = (), |
767 | 779 | ) -> pagers.ListWorkloadsAsyncPager: |
768 | 780 | r"""Lists Assured Workloads under a CRM Node. |
@@ -795,7 +807,7 @@ async def sample_list_workloads(): |
795 | 807 | print(response) |
796 | 808 |
|
797 | 809 | Args: |
798 | | - request (Union[google.cloud.assuredworkloads_v1.types.ListWorkloadsRequest, dict]): |
| 810 | + request (Optional[Union[google.cloud.assuredworkloads_v1.types.ListWorkloadsRequest, dict]]): |
799 | 811 | The request object. Request for fetching workloads in an |
800 | 812 | organization. |
801 | 813 | parent (:class:`str`): |
@@ -873,11 +885,11 @@ async def sample_list_workloads(): |
873 | 885 |
|
874 | 886 | async def list_violations( |
875 | 887 | self, |
876 | | - request: Union[assuredworkloads.ListViolationsRequest, dict] = None, |
| 888 | + request: Optional[Union[assuredworkloads.ListViolationsRequest, dict]] = None, |
877 | 889 | *, |
878 | | - parent: str = None, |
| 890 | + parent: Optional[str] = None, |
879 | 891 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
880 | | - timeout: float = None, |
| 892 | + timeout: Optional[float] = None, |
881 | 893 | metadata: Sequence[Tuple[str, str]] = (), |
882 | 894 | ) -> pagers.ListViolationsAsyncPager: |
883 | 895 | r"""Lists the Violations in the AssuredWorkload Environment. Callers |
@@ -915,7 +927,7 @@ async def sample_list_violations(): |
915 | 927 | print(response) |
916 | 928 |
|
917 | 929 | Args: |
918 | | - request (Union[google.cloud.assuredworkloads_v1.types.ListViolationsRequest, dict]): |
| 930 | + request (Optional[Union[google.cloud.assuredworkloads_v1.types.ListViolationsRequest, dict]]): |
919 | 931 | The request object. Request for fetching violations in |
920 | 932 | an organization. |
921 | 933 | parent (:class:`str`): |
@@ -986,11 +998,11 @@ async def sample_list_violations(): |
986 | 998 |
|
987 | 999 | async def get_violation( |
988 | 1000 | self, |
989 | | - request: Union[assuredworkloads.GetViolationRequest, dict] = None, |
| 1001 | + request: Optional[Union[assuredworkloads.GetViolationRequest, dict]] = None, |
990 | 1002 | *, |
991 | | - name: str = None, |
| 1003 | + name: Optional[str] = None, |
992 | 1004 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
993 | | - timeout: float = None, |
| 1005 | + timeout: Optional[float] = None, |
994 | 1006 | metadata: Sequence[Tuple[str, str]] = (), |
995 | 1007 | ) -> assuredworkloads.Violation: |
996 | 1008 | r"""Retrieves Assured Workload Violation based on ID. |
@@ -1022,7 +1034,7 @@ async def sample_get_violation(): |
1022 | 1034 | print(response) |
1023 | 1035 |
|
1024 | 1036 | Args: |
1025 | | - request (Union[google.cloud.assuredworkloads_v1.types.GetViolationRequest, dict]): |
| 1037 | + request (Optional[Union[google.cloud.assuredworkloads_v1.types.GetViolationRequest, dict]]): |
1026 | 1038 | The request object. Request for fetching a Workload |
1027 | 1039 | Violation. |
1028 | 1040 | name (:class:`str`): |
@@ -1082,10 +1094,12 @@ async def sample_get_violation(): |
1082 | 1094 |
|
1083 | 1095 | async def acknowledge_violation( |
1084 | 1096 | self, |
1085 | | - request: Union[assuredworkloads.AcknowledgeViolationRequest, dict] = None, |
| 1097 | + request: Optional[ |
| 1098 | + Union[assuredworkloads.AcknowledgeViolationRequest, dict] |
| 1099 | + ] = None, |
1086 | 1100 | *, |
1087 | 1101 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
1088 | | - timeout: float = None, |
| 1102 | + timeout: Optional[float] = None, |
1089 | 1103 | metadata: Sequence[Tuple[str, str]] = (), |
1090 | 1104 | ) -> assuredworkloads.AcknowledgeViolationResponse: |
1091 | 1105 | r"""Acknowledges an existing violation. By acknowledging |
@@ -1123,7 +1137,7 @@ async def sample_acknowledge_violation(): |
1123 | 1137 | print(response) |
1124 | 1138 |
|
1125 | 1139 | Args: |
1126 | | - request (Union[google.cloud.assuredworkloads_v1.types.AcknowledgeViolationRequest, dict]): |
| 1140 | + request (Optional[Union[google.cloud.assuredworkloads_v1.types.AcknowledgeViolationRequest, dict]]): |
1127 | 1141 | The request object. Request for acknowledging the |
1128 | 1142 | violation Next Id: 4 |
1129 | 1143 | retry (google.api_core.retry.Retry): Designation of what errors, if any, |
@@ -1162,10 +1176,10 @@ async def sample_acknowledge_violation(): |
1162 | 1176 |
|
1163 | 1177 | async def list_operations( |
1164 | 1178 | self, |
1165 | | - request: operations_pb2.ListOperationsRequest = None, |
| 1179 | + request: Optional[operations_pb2.ListOperationsRequest] = None, |
1166 | 1180 | *, |
1167 | 1181 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
1168 | | - timeout: float = None, |
| 1182 | + timeout: Optional[float] = None, |
1169 | 1183 | metadata: Sequence[Tuple[str, str]] = (), |
1170 | 1184 | ) -> operations_pb2.ListOperationsResponse: |
1171 | 1185 | r"""Lists operations that match the specified filter in the request. |
@@ -1216,10 +1230,10 @@ async def list_operations( |
1216 | 1230 |
|
1217 | 1231 | async def get_operation( |
1218 | 1232 | self, |
1219 | | - request: operations_pb2.GetOperationRequest = None, |
| 1233 | + request: Optional[operations_pb2.GetOperationRequest] = None, |
1220 | 1234 | *, |
1221 | 1235 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
1222 | | - timeout: float = None, |
| 1236 | + timeout: Optional[float] = None, |
1223 | 1237 | metadata: Sequence[Tuple[str, str]] = (), |
1224 | 1238 | ) -> operations_pb2.Operation: |
1225 | 1239 | r"""Gets the latest state of a long-running operation. |
|
0 commit comments