This repository was archived by the owner on Sep 21, 2023. It is now read-only.
Merged
Show file tree
Hide file tree
Changes from all commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Jump to
Failed to load files.
Original file line numberDiff line numberDiff line change
Expand Up@@ -182,6 +182,15 @@ def _prep_wrapped_messages(self, client_info):
),
}

def close(self):
"""Closes resources associated with the transport.

.. warning::
Only call this method if the transport is NOT shared
with other clients - this may cause errors in other clients!
"""
raise NotImplementedError()

@property
def create_job(
self,
Expand Down
Original file line numberDiff line numberDiff line change
Expand Up@@ -446,5 +446,8 @@ def delete_job_template(
)
return self._stubs["delete_job_template"]

def close(self):
return self.grpc_channel.close()


__all__ = ("TranscoderServiceGrpcAsyncIOTransport",)
Original file line numberDiff line numberDiff line change
Expand Up@@ -37,6 +37,7 @@

class CreateJobRequest(proto.Message):
r"""Request message for ``TranscoderService.CreateJob``.

Attributes:
parent (str):
Required. The parent location to create and process this
Expand DownExpand Up@@ -81,6 +82,7 @@ class ListJobsRequest(proto.Message):

class GetJobRequest(proto.Message):
r"""Request message for ``TranscoderService.GetJob``.

Attributes:
name (str):
Required. The name of the job to retrieve. Format:
Expand All@@ -92,6 +94,7 @@ class GetJobRequest(proto.Message):

class DeleteJobRequest(proto.Message):
r"""Request message for ``TranscoderService.DeleteJob``.

Attributes:
name (str):
Required. The name of the job to delete. Format:
Expand All@@ -108,6 +111,7 @@ class DeleteJobRequest(proto.Message):

class ListJobsResponse(proto.Message):
r"""Response message for ``TranscoderService.ListJobs``.

Attributes:
jobs (Sequence[google.cloud.video.transcoder_v1.types.Job]):
List of jobs in the specified region.
Expand All@@ -128,6 +132,7 @@ def raw_page(self):

class CreateJobTemplateRequest(proto.Message):
r"""Request message for ``TranscoderService.CreateJobTemplate``.

Attributes:
parent (str):
Required. The parent location to create this job template.
Expand All@@ -152,6 +157,7 @@ class CreateJobTemplateRequest(proto.Message):

class ListJobTemplatesRequest(proto.Message):
r"""Request message for ``TranscoderService.ListJobTemplates``.

Attributes:
parent (str):
Required. The parent location from which to retrieve the
Expand DownExpand Up@@ -180,6 +186,7 @@ class ListJobTemplatesRequest(proto.Message):

class GetJobTemplateRequest(proto.Message):
r"""Request message for ``TranscoderService.GetJobTemplate``.

Attributes:
name (str):
Required. The name of the job template to retrieve. Format:
Expand All@@ -191,6 +198,7 @@ class GetJobTemplateRequest(proto.Message):

class DeleteJobTemplateRequest(proto.Message):
r"""Request message for ``TranscoderService.DeleteJobTemplate``.

Attributes:
name (str):
Required. The name of the job template to delete.
Expand All@@ -207,6 +215,7 @@ class DeleteJobTemplateRequest(proto.Message):

class ListJobTemplatesResponse(proto.Message):
r"""Response message for ``TranscoderService.ListJobTemplates``.

Attributes:
job_templates (Sequence[google.cloud.video.transcoder_v1.types.JobTemplate]):
List of job templates in the specified
Expand Down
Original file line numberDiff line numberDiff line change
Expand Up@@ -775,6 +775,12 @@ async def delete_job_template(
request, retry=retry, timeout=timeout, metadata=metadata,
)

async def __aenter__(self):
return self

async def __aexit__(self, exc_type, exc, tb):
await self.transport.close()


try:
DEFAULT_CLIENT_INFO = gapic_v1.client_info.ClientInfo(
Expand Down
Loading