|
34 | 34 | from google.api_core.client_options import ClientOptions
|
35 | 35 | from google.auth import credentials as ga_credentials # type: ignore
|
36 | 36 | from google.oauth2 import service_account # type: ignore
|
37 |
| -import pkg_resources |
| 37 | + |
| 38 | +from google.cloud.video.transcoder_v1 import gapic_version as package_version |
38 | 39 |
|
39 | 40 | try:
|
40 | 41 | OptionalRetry = Union[retries.Retry, gapic_v1.method._MethodDefault]
|
@@ -234,7 +235,7 @@ async def create_job(
|
234 | 235 | parent: Optional[str] = None,
|
235 | 236 | job: Optional[resources.Job] = None,
|
236 | 237 | retry: OptionalRetry = gapic_v1.method.DEFAULT,
|
237 |
| - timeout: Optional[float] = None, |
| 238 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
238 | 239 | metadata: Sequence[Tuple[str, str]] = (),
|
239 | 240 | ) -> resources.Job:
|
240 | 241 | r"""Creates a job in the specified region.
|
@@ -347,7 +348,7 @@ async def list_jobs(
|
347 | 348 | *,
|
348 | 349 | parent: Optional[str] = None,
|
349 | 350 | retry: OptionalRetry = gapic_v1.method.DEFAULT,
|
350 |
| - timeout: Optional[float] = None, |
| 351 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
351 | 352 | metadata: Sequence[Tuple[str, str]] = (),
|
352 | 353 | ) -> pagers.ListJobsAsyncPager:
|
353 | 354 | r"""Lists jobs in the specified region.
|
@@ -462,7 +463,7 @@ async def get_job(
|
462 | 463 | *,
|
463 | 464 | name: Optional[str] = None,
|
464 | 465 | retry: OptionalRetry = gapic_v1.method.DEFAULT,
|
465 |
| - timeout: Optional[float] = None, |
| 466 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
466 | 467 | metadata: Sequence[Tuple[str, str]] = (),
|
467 | 468 | ) -> resources.Job:
|
468 | 469 | r"""Returns the job data.
|
@@ -562,7 +563,7 @@ async def delete_job(
|
562 | 563 | *,
|
563 | 564 | name: Optional[str] = None,
|
564 | 565 | retry: OptionalRetry = gapic_v1.method.DEFAULT,
|
565 |
| - timeout: Optional[float] = None, |
| 566 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
566 | 567 | metadata: Sequence[Tuple[str, str]] = (),
|
567 | 568 | ) -> None:
|
568 | 569 | r"""Deletes a job.
|
@@ -654,7 +655,7 @@ async def create_job_template(
|
654 | 655 | job_template: Optional[resources.JobTemplate] = None,
|
655 | 656 | job_template_id: Optional[str] = None,
|
656 | 657 | retry: OptionalRetry = gapic_v1.method.DEFAULT,
|
657 |
| - timeout: Optional[float] = None, |
| 658 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
658 | 659 | metadata: Sequence[Tuple[str, str]] = (),
|
659 | 660 | ) -> resources.JobTemplate:
|
660 | 661 | r"""Creates a job template in the specified region.
|
@@ -779,7 +780,7 @@ async def list_job_templates(
|
779 | 780 | *,
|
780 | 781 | parent: Optional[str] = None,
|
781 | 782 | retry: OptionalRetry = gapic_v1.method.DEFAULT,
|
782 |
| - timeout: Optional[float] = None, |
| 783 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
783 | 784 | metadata: Sequence[Tuple[str, str]] = (),
|
784 | 785 | ) -> pagers.ListJobTemplatesAsyncPager:
|
785 | 786 | r"""Lists job templates in the specified region.
|
@@ -894,7 +895,7 @@ async def get_job_template(
|
894 | 895 | *,
|
895 | 896 | name: Optional[str] = None,
|
896 | 897 | retry: OptionalRetry = gapic_v1.method.DEFAULT,
|
897 |
| - timeout: Optional[float] = None, |
| 898 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
898 | 899 | metadata: Sequence[Tuple[str, str]] = (),
|
899 | 900 | ) -> resources.JobTemplate:
|
900 | 901 | r"""Returns the job template data.
|
@@ -995,7 +996,7 @@ async def delete_job_template(
|
995 | 996 | *,
|
996 | 997 | name: Optional[str] = None,
|
997 | 998 | retry: OptionalRetry = gapic_v1.method.DEFAULT,
|
998 |
| - timeout: Optional[float] = None, |
| 999 | + timeout: Union[float, object] = gapic_v1.method.DEFAULT, |
999 | 1000 | metadata: Sequence[Tuple[str, str]] = (),
|
1000 | 1001 | ) -> None:
|
1001 | 1002 | r"""Deletes a job template.
|
@@ -1086,14 +1087,9 @@ async def __aexit__(self, exc_type, exc, tb):
|
1086 | 1087 | await self.transport.close()
|
1087 | 1088 |
|
1088 | 1089 |
|
1089 |
| -try: |
1090 |
| - DEFAULT_CLIENT_INFO = gapic_v1.client_info.ClientInfo( |
1091 |
| - gapic_version=pkg_resources.get_distribution( |
1092 |
| - "google-cloud-video-transcoder", |
1093 |
| - ).version, |
1094 |
| - ) |
1095 |
| -except pkg_resources.DistributionNotFound: |
1096 |
| - DEFAULT_CLIENT_INFO = gapic_v1.client_info.ClientInfo() |
| 1090 | +DEFAULT_CLIENT_INFO = gapic_v1.client_info.ClientInfo( |
| 1091 | + gapic_version=package_version.__version__ |
| 1092 | +) |
1097 | 1093 |
|
1098 | 1094 |
|
1099 | 1095 | __all__ = ("TranscoderServiceAsyncClient",)
|
0 commit comments