|
38 | 38 | from google.auth.transport import mtls # type: ignore |
39 | 39 | from google.auth.transport.grpc import SslCredentials # type: ignore |
40 | 40 | from google.oauth2 import service_account # type: ignore |
41 | | -import pkg_resources |
| 41 | + |
| 42 | +from google.cloud.datalabeling_v1beta1 import gapic_version as package_version |
42 | 43 |
|
43 | 44 | try: |
44 | 45 | OptionalRetry = Union[retries.Retry, gapic_v1.method._MethodDefault] |
@@ -611,7 +612,7 @@ def create_dataset( |
611 | 612 | parent: Optional[str] = None, |
612 | 613 | dataset: Optional[gcd_dataset.Dataset] = None, |
613 | 614 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
614 | | - timeout: Optional[float] = None, |
| 615 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
615 | 616 | metadata: Sequence[Tuple[str, str]] = (), |
616 | 617 | ) -> gcd_dataset.Dataset: |
617 | 618 | r"""Creates dataset. If success return a Dataset |
@@ -722,7 +723,7 @@ def get_dataset( |
722 | 723 | *, |
723 | 724 | name: Optional[str] = None, |
724 | 725 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
725 | | - timeout: Optional[float] = None, |
| 726 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
726 | 727 | metadata: Sequence[Tuple[str, str]] = (), |
727 | 728 | ) -> dataset.Dataset: |
728 | 729 | r"""Gets dataset by resource name. |
@@ -828,7 +829,7 @@ def list_datasets( |
828 | 829 | parent: Optional[str] = None, |
829 | 830 | filter: Optional[str] = None, |
830 | 831 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
831 | | - timeout: Optional[float] = None, |
| 832 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
832 | 833 | metadata: Sequence[Tuple[str, str]] = (), |
833 | 834 | ) -> pagers.ListDatasetsPager: |
834 | 835 | r"""Lists datasets under a project. Pagination is |
@@ -954,7 +955,7 @@ def delete_dataset( |
954 | 955 | *, |
955 | 956 | name: Optional[str] = None, |
956 | 957 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
957 | | - timeout: Optional[float] = None, |
| 958 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
958 | 959 | metadata: Sequence[Tuple[str, str]] = (), |
959 | 960 | ) -> None: |
960 | 961 | r"""Deletes a dataset by resource name. |
@@ -1044,7 +1045,7 @@ def import_data( |
1044 | 1045 | name: Optional[str] = None, |
1045 | 1046 | input_config: Optional[dataset.InputConfig] = None, |
1046 | 1047 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
1047 | | - timeout: Optional[float] = None, |
| 1048 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
1048 | 1049 | metadata: Sequence[Tuple[str, str]] = (), |
1049 | 1050 | ) -> operation.Operation: |
1050 | 1051 | r"""Imports data into dataset based on source locations |
@@ -1177,7 +1178,7 @@ def export_data( |
1177 | 1178 | filter: Optional[str] = None, |
1178 | 1179 | output_config: Optional[dataset.OutputConfig] = None, |
1179 | 1180 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
1180 | | - timeout: Optional[float] = None, |
| 1181 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
1181 | 1182 | metadata: Sequence[Tuple[str, str]] = (), |
1182 | 1183 | ) -> operation.Operation: |
1183 | 1184 | r"""Exports data and annotations from dataset. |
@@ -1324,7 +1325,7 @@ def get_data_item( |
1324 | 1325 | *, |
1325 | 1326 | name: Optional[str] = None, |
1326 | 1327 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
1327 | | - timeout: Optional[float] = None, |
| 1328 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
1328 | 1329 | metadata: Sequence[Tuple[str, str]] = (), |
1329 | 1330 | ) -> dataset.DataItem: |
1330 | 1331 | r"""Gets a data item in a dataset by resource name. This |
@@ -1429,7 +1430,7 @@ def list_data_items( |
1429 | 1430 | parent: Optional[str] = None, |
1430 | 1431 | filter: Optional[str] = None, |
1431 | 1432 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
1432 | | - timeout: Optional[float] = None, |
| 1433 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
1433 | 1434 | metadata: Sequence[Tuple[str, str]] = (), |
1434 | 1435 | ) -> pagers.ListDataItemsPager: |
1435 | 1436 | r"""Lists data items in a dataset. This API can be called |
@@ -1556,7 +1557,7 @@ def get_annotated_dataset( |
1556 | 1557 | *, |
1557 | 1558 | name: Optional[str] = None, |
1558 | 1559 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
1559 | | - timeout: Optional[float] = None, |
| 1560 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
1560 | 1561 | metadata: Sequence[Tuple[str, str]] = (), |
1561 | 1562 | ) -> dataset.AnnotatedDataset: |
1562 | 1563 | r"""Gets an annotated dataset by resource name. |
@@ -1665,7 +1666,7 @@ def list_annotated_datasets( |
1665 | 1666 | parent: Optional[str] = None, |
1666 | 1667 | filter: Optional[str] = None, |
1667 | 1668 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
1668 | | - timeout: Optional[float] = None, |
| 1669 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
1669 | 1670 | metadata: Sequence[Tuple[str, str]] = (), |
1670 | 1671 | ) -> pagers.ListAnnotatedDatasetsPager: |
1671 | 1672 | r"""Lists annotated datasets for a dataset. Pagination is |
@@ -1792,7 +1793,7 @@ def delete_annotated_dataset( |
1792 | 1793 | ] = None, |
1793 | 1794 | *, |
1794 | 1795 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
1795 | | - timeout: Optional[float] = None, |
| 1796 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
1796 | 1797 | metadata: Sequence[Tuple[str, str]] = (), |
1797 | 1798 | ) -> None: |
1798 | 1799 | r"""Deletes an annotated dataset by resource name. |
@@ -1864,7 +1865,7 @@ def label_image( |
1864 | 1865 | basic_config: Optional[human_annotation_config.HumanAnnotationConfig] = None, |
1865 | 1866 | feature: Optional[data_labeling_service.LabelImageRequest.Feature] = None, |
1866 | 1867 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
1867 | | - timeout: Optional[float] = None, |
| 1868 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
1868 | 1869 | metadata: Sequence[Tuple[str, str]] = (), |
1869 | 1870 | ) -> operation.Operation: |
1870 | 1871 | r"""Starts a labeling task for image. The type of image |
@@ -2012,7 +2013,7 @@ def label_video( |
2012 | 2013 | basic_config: Optional[human_annotation_config.HumanAnnotationConfig] = None, |
2013 | 2014 | feature: Optional[data_labeling_service.LabelVideoRequest.Feature] = None, |
2014 | 2015 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
2015 | | - timeout: Optional[float] = None, |
| 2016 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
2016 | 2017 | metadata: Sequence[Tuple[str, str]] = (), |
2017 | 2018 | ) -> operation.Operation: |
2018 | 2019 | r"""Starts a labeling task for video. The type of video |
@@ -2159,7 +2160,7 @@ def label_text( |
2159 | 2160 | basic_config: Optional[human_annotation_config.HumanAnnotationConfig] = None, |
2160 | 2161 | feature: Optional[data_labeling_service.LabelTextRequest.Feature] = None, |
2161 | 2162 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
2162 | | - timeout: Optional[float] = None, |
| 2163 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
2163 | 2164 | metadata: Sequence[Tuple[str, str]] = (), |
2164 | 2165 | ) -> operation.Operation: |
2165 | 2166 | r"""Starts a labeling task for text. The type of text |
@@ -2305,7 +2306,7 @@ def get_example( |
2305 | 2306 | name: Optional[str] = None, |
2306 | 2307 | filter: Optional[str] = None, |
2307 | 2308 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
2308 | | - timeout: Optional[float] = None, |
| 2309 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
2309 | 2310 | metadata: Sequence[Tuple[str, str]] = (), |
2310 | 2311 | ) -> dataset.Example: |
2311 | 2312 | r"""Gets an example by resource name, including both data |
@@ -2422,7 +2423,7 @@ def list_examples( |
2422 | 2423 | parent: Optional[str] = None, |
2423 | 2424 | filter: Optional[str] = None, |
2424 | 2425 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
2425 | | - timeout: Optional[float] = None, |
| 2426 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
2426 | 2427 | metadata: Sequence[Tuple[str, str]] = (), |
2427 | 2428 | ) -> pagers.ListExamplesPager: |
2428 | 2429 | r"""Lists examples in an annotated dataset. Pagination is |
@@ -2549,7 +2550,7 @@ def create_annotation_spec_set( |
2549 | 2550 | parent: Optional[str] = None, |
2550 | 2551 | annotation_spec_set: Optional[gcd_annotation_spec_set.AnnotationSpecSet] = None, |
2551 | 2552 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
2552 | | - timeout: Optional[float] = None, |
| 2553 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
2553 | 2554 | metadata: Sequence[Tuple[str, str]] = (), |
2554 | 2555 | ) -> gcd_annotation_spec_set.AnnotationSpecSet: |
2555 | 2556 | r"""Creates an annotation spec set by providing a set of |
@@ -2672,7 +2673,7 @@ def get_annotation_spec_set( |
2672 | 2673 | *, |
2673 | 2674 | name: Optional[str] = None, |
2674 | 2675 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
2675 | | - timeout: Optional[float] = None, |
| 2676 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
2676 | 2677 | metadata: Sequence[Tuple[str, str]] = (), |
2677 | 2678 | ) -> annotation_spec_set.AnnotationSpecSet: |
2678 | 2679 | r"""Gets an annotation spec set by resource name. |
@@ -2781,7 +2782,7 @@ def list_annotation_spec_sets( |
2781 | 2782 | parent: Optional[str] = None, |
2782 | 2783 | filter: Optional[str] = None, |
2783 | 2784 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
2784 | | - timeout: Optional[float] = None, |
| 2785 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
2785 | 2786 | metadata: Sequence[Tuple[str, str]] = (), |
2786 | 2787 | ) -> pagers.ListAnnotationSpecSetsPager: |
2787 | 2788 | r"""Lists annotation spec sets for a project. Pagination |
@@ -2910,7 +2911,7 @@ def delete_annotation_spec_set( |
2910 | 2911 | *, |
2911 | 2912 | name: Optional[str] = None, |
2912 | 2913 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
2913 | | - timeout: Optional[float] = None, |
| 2914 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
2914 | 2915 | metadata: Sequence[Tuple[str, str]] = (), |
2915 | 2916 | ) -> None: |
2916 | 2917 | r"""Deletes an annotation spec set by resource name. |
@@ -3007,7 +3008,7 @@ def create_instruction( |
3007 | 3008 | parent: Optional[str] = None, |
3008 | 3009 | instruction: Optional[gcd_instruction.Instruction] = None, |
3009 | 3010 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
3010 | | - timeout: Optional[float] = None, |
| 3011 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
3011 | 3012 | metadata: Sequence[Tuple[str, str]] = (), |
3012 | 3013 | ) -> operation.Operation: |
3013 | 3014 | r"""Creates an instruction for how data should be |
@@ -3135,7 +3136,7 @@ def get_instruction( |
3135 | 3136 | *, |
3136 | 3137 | name: Optional[str] = None, |
3137 | 3138 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
3138 | | - timeout: Optional[float] = None, |
| 3139 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
3139 | 3140 | metadata: Sequence[Tuple[str, str]] = (), |
3140 | 3141 | ) -> instruction.Instruction: |
3141 | 3142 | r"""Gets an instruction by resource name. |
@@ -3241,7 +3242,7 @@ def list_instructions( |
3241 | 3242 | parent: Optional[str] = None, |
3242 | 3243 | filter: Optional[str] = None, |
3243 | 3244 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
3244 | | - timeout: Optional[float] = None, |
| 3245 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
3245 | 3246 | metadata: Sequence[Tuple[str, str]] = (), |
3246 | 3247 | ) -> pagers.ListInstructionsPager: |
3247 | 3248 | r"""Lists instructions for a project. Pagination is |
@@ -3368,7 +3369,7 @@ def delete_instruction( |
3368 | 3369 | *, |
3369 | 3370 | name: Optional[str] = None, |
3370 | 3371 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
3371 | | - timeout: Optional[float] = None, |
| 3372 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
3372 | 3373 | metadata: Sequence[Tuple[str, str]] = (), |
3373 | 3374 | ) -> None: |
3374 | 3375 | r"""Deletes an instruction object by resource name. |
@@ -3460,7 +3461,7 @@ def get_evaluation( |
3460 | 3461 | *, |
3461 | 3462 | name: Optional[str] = None, |
3462 | 3463 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
3463 | | - timeout: Optional[float] = None, |
| 3464 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
3464 | 3465 | metadata: Sequence[Tuple[str, str]] = (), |
3465 | 3466 | ) -> evaluation.Evaluation: |
3466 | 3467 | r"""Gets an evaluation by resource name (to search, use |
@@ -3568,7 +3569,7 @@ def search_evaluations( |
3568 | 3569 | parent: Optional[str] = None, |
3569 | 3570 | filter: Optional[str] = None, |
3570 | 3571 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
3571 | | - timeout: Optional[float] = None, |
| 3572 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
3572 | 3573 | metadata: Sequence[Tuple[str, str]] = (), |
3573 | 3574 | ) -> pagers.SearchEvaluationsPager: |
3574 | 3575 | r"""Searches |
@@ -3726,7 +3727,7 @@ def search_example_comparisons( |
3726 | 3727 | *, |
3727 | 3728 | parent: Optional[str] = None, |
3728 | 3729 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
3729 | | - timeout: Optional[float] = None, |
| 3730 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
3730 | 3731 | metadata: Sequence[Tuple[str, str]] = (), |
3731 | 3732 | ) -> pagers.SearchExampleComparisonsPager: |
3732 | 3733 | r"""Searches example comparisons from an evaluation. The |
@@ -3854,7 +3855,7 @@ def create_evaluation_job( |
3854 | 3855 | parent: Optional[str] = None, |
3855 | 3856 | job: Optional[evaluation_job.EvaluationJob] = None, |
3856 | 3857 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
3857 | | - timeout: Optional[float] = None, |
| 3858 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
3858 | 3859 | metadata: Sequence[Tuple[str, str]] = (), |
3859 | 3860 | ) -> evaluation_job.EvaluationJob: |
3860 | 3861 | r"""Creates an evaluation job. |
@@ -3972,7 +3973,7 @@ def update_evaluation_job( |
3972 | 3973 | evaluation_job: Optional[gcd_evaluation_job.EvaluationJob] = None, |
3973 | 3974 | update_mask: Optional[field_mask_pb2.FieldMask] = None, |
3974 | 3975 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
3975 | | - timeout: Optional[float] = None, |
| 3976 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
3976 | 3977 | metadata: Sequence[Tuple[str, str]] = (), |
3977 | 3978 | ) -> gcd_evaluation_job.EvaluationJob: |
3978 | 3979 | r"""Updates an evaluation job. You can only update certain fields of |
@@ -4104,7 +4105,7 @@ def get_evaluation_job( |
4104 | 4105 | *, |
4105 | 4106 | name: Optional[str] = None, |
4106 | 4107 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
4107 | | - timeout: Optional[float] = None, |
| 4108 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
4108 | 4109 | metadata: Sequence[Tuple[str, str]] = (), |
4109 | 4110 | ) -> evaluation_job.EvaluationJob: |
4110 | 4111 | r"""Gets an evaluation job by resource name. |
@@ -4213,7 +4214,7 @@ def pause_evaluation_job( |
4213 | 4214 | *, |
4214 | 4215 | name: Optional[str] = None, |
4215 | 4216 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
4216 | | - timeout: Optional[float] = None, |
| 4217 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
4217 | 4218 | metadata: Sequence[Tuple[str, str]] = (), |
4218 | 4219 | ) -> None: |
4219 | 4220 | r"""Pauses an evaluation job. Pausing an evaluation job that is |
@@ -4308,7 +4309,7 @@ def resume_evaluation_job( |
4308 | 4309 | *, |
4309 | 4310 | name: Optional[str] = None, |
4310 | 4311 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
4311 | | - timeout: Optional[float] = None, |
| 4312 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
4312 | 4313 | metadata: Sequence[Tuple[str, str]] = (), |
4313 | 4314 | ) -> None: |
4314 | 4315 | r"""Resumes a paused evaluation job. A deleted evaluation |
@@ -4403,7 +4404,7 @@ def delete_evaluation_job( |
4403 | 4404 | *, |
4404 | 4405 | name: Optional[str] = None, |
4405 | 4406 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
4406 | | - timeout: Optional[float] = None, |
| 4407 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
4407 | 4408 | metadata: Sequence[Tuple[str, str]] = (), |
4408 | 4409 | ) -> None: |
4409 | 4410 | r"""Stops and deletes an evaluation job. |
@@ -4497,7 +4498,7 @@ def list_evaluation_jobs( |
4497 | 4498 | parent: Optional[str] = None, |
4498 | 4499 | filter: Optional[str] = None, |
4499 | 4500 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
4500 | | - timeout: Optional[float] = None, |
| 4501 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
4501 | 4502 | metadata: Sequence[Tuple[str, str]] = (), |
4502 | 4503 | ) -> pagers.ListEvaluationJobsPager: |
4503 | 4504 | r"""Lists all evaluation jobs within a project with |
@@ -4637,14 +4638,9 @@ def __exit__(self, type, value, traceback): |
4637 | 4638 | self.transport.close() |
4638 | 4639 |
|
4639 | 4640 |
|
4640 | | -try: |
4641 | | - DEFAULT_CLIENT_INFO = gapic_v1.client_info.ClientInfo( |
4642 | | - gapic_version=pkg_resources.get_distribution( |
4643 | | - "google-cloud-datalabeling", |
4644 | | - ).version, |
4645 | | - ) |
4646 | | -except pkg_resources.DistributionNotFound: |
4647 | | - DEFAULT_CLIENT_INFO = gapic_v1.client_info.ClientInfo() |
| 4641 | +DEFAULT_CLIENT_INFO = gapic_v1.client_info.ClientInfo( |
| 4642 | + gapic_version=package_version.__version__ |
| 4643 | +) |
4648 | 4644 |
|
4649 | 4645 |
|
4650 | 4646 | __all__ = ("DataLabelingServiceClient",) |
0 commit comments