Skip to content

Commit

Permalink
feat: add template_metadata to PipelineJob in aiplatform v1beta1 pipe…
Browse files Browse the repository at this point in the history 
…line_job.proto (#1186)

* chore: use gapic-generator-python 0.65.2

PiperOrigin-RevId: 444333013

Source-Link: googleapis/googleapis@f91b6cf

Source-Link: googleapis/googleapis-gen@16eb360
Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiMTZlYjM2MDk1YzI5NGU3MTJjNzRhMWJmMjM1NTA4MTdiNDIxNzRlNSJ9

* 🦉 Updates from OwlBot post-processor

See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md

* chore: remove unused imports

PiperOrigin-RevId: 446472466

Source-Link: googleapis/googleapis@9911f34

Source-Link: googleapis/googleapis-gen@a82ecd7
Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiYTgyZWNkN2Y1Y2ZkYmRlZTdhN2Y1ZTRkMzRjYjVhMzU0ODkzYjk0NSJ9

* 🦉 Updates from OwlBot post-processor

See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md

* chore: use gapic-generator-python 0.65.3

PiperOrigin-RevId: 446591767

Source-Link: googleapis/googleapis@e24febc

Source-Link: googleapis/googleapis-gen@3b4f1d3
Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiM2I0ZjFkMzExMjY2YWVhMzJlMmJlOWI5ZmUzY2U3NDI3OTU4NzUzMiJ9

* 🦉 Updates from OwlBot post-processor

See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md

* feat: add template_metadata to PipelineJob in aiplatform v1beta1 pipeline_job.proto

PiperOrigin-RevId: 447082691

Source-Link: googleapis/googleapis@02b3022

Source-Link: googleapis/googleapis-gen@753e1ac
Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiNzUzZTFhY2YwZGVkYTU5YmM0NTE0ODJlNjI3OGM3ZGFiNDkwOGI5YyJ9

* 🦉 Updates from OwlBot post-processor

See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md

* 🦉 Updates from OwlBot post-processor

See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md

Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>
Co-authored-by: Yu-Han Liu <yuhanliu@google.com>
  • Loading branch information
@gcf-owl-bot @dizcology
3 people committed May 9, 2022
1 parent c773539 commit 99aca4a
Show file tree
Hide file tree
Showing 66 changed files with 2,791 additions and 2,745 deletions.
2 changes: 1 addition & 1 deletion .kokoro/continuous/continuous.cfg
View file
@@ -1 +1 @@
# Format: //devtools/kokoro/config/proto/build.proto
# Format: //devtools/kokoro/config/proto/build.proto
60 changes: 30 additions & 30 deletions google/cloud/aiplatform_v1/services/dataset_service/async_client.py
View file
Expand Up @@ -241,9 +241,9 @@ async def create_dataset(
from google.cloud import aiplatform_v1
def sample_create_dataset():
async def sample_create_dataset():
# Create a client
client = aiplatform_v1.DatasetServiceClient()
client = aiplatform_v1.DatasetServiceAsyncClient()
# Initialize request argument(s)
dataset = aiplatform_v1.Dataset()
Expand All @@ -261,7 +261,7 @@ def sample_create_dataset():
print("Waiting for operation to complete...")
response = operation.result()
response = await operation.result()
# Handle the response
print(response)
Expand Down Expand Up @@ -365,17 +365,17 @@ async def get_dataset(
from google.cloud import aiplatform_v1
def sample_get_dataset():
async def sample_get_dataset():
# Create a client
client = aiplatform_v1.DatasetServiceClient()
client = aiplatform_v1.DatasetServiceAsyncClient()
# Initialize request argument(s)
request = aiplatform_v1.GetDatasetRequest(
name="name_value",
)
# Make the request
response = client.get_dataset(request=request)
response = await client.get_dataset(request=request)
# Handle the response
print(response)
Expand Down Expand Up @@ -461,9 +461,9 @@ async def update_dataset(
from google.cloud import aiplatform_v1
def sample_update_dataset():
async def sample_update_dataset():
# Create a client
client = aiplatform_v1.DatasetServiceClient()
client = aiplatform_v1.DatasetServiceAsyncClient()
# Initialize request argument(s)
dataset = aiplatform_v1.Dataset()
Expand All @@ -476,7 +476,7 @@ def sample_update_dataset():
)
# Make the request
response = client.update_dataset(request=request)
response = await client.update_dataset(request=request)
# Handle the response
print(response)
Expand Down Expand Up @@ -578,9 +578,9 @@ async def list_datasets(
from google.cloud import aiplatform_v1
def sample_list_datasets():
async def sample_list_datasets():
# Create a client
client = aiplatform_v1.DatasetServiceClient()
client = aiplatform_v1.DatasetServiceAsyncClient()
# Initialize request argument(s)
request = aiplatform_v1.ListDatasetsRequest(
Expand All @@ -591,7 +591,7 @@ def sample_list_datasets():
page_result = client.list_datasets(request=request)
# Handle the response
for response in page_result:
async for response in page_result:
print(response)
Args:
Expand Down Expand Up @@ -686,9 +686,9 @@ async def delete_dataset(
from google.cloud import aiplatform_v1
def sample_delete_dataset():
async def sample_delete_dataset():
# Create a client
client = aiplatform_v1.DatasetServiceClient()
client = aiplatform_v1.DatasetServiceAsyncClient()
# Initialize request argument(s)
request = aiplatform_v1.DeleteDatasetRequest(
Expand All @@ -700,7 +700,7 @@ def sample_delete_dataset():
print("Waiting for operation to complete...")
response = operation.result()
response = await operation.result()
# Handle the response
print(response)
Expand Down Expand Up @@ -808,9 +808,9 @@ async def import_data(
from google.cloud import aiplatform_v1
def sample_import_data():
async def sample_import_data():
# Create a client
client = aiplatform_v1.DatasetServiceClient()
client = aiplatform_v1.DatasetServiceAsyncClient()
# Initialize request argument(s)
import_configs = aiplatform_v1.ImportDataConfig()
Expand All @@ -827,7 +827,7 @@ def sample_import_data():
print("Waiting for operation to complete...")
response = operation.result()
response = await operation.result()
# Handle the response
print(response)
Expand Down Expand Up @@ -935,9 +935,9 @@ async def export_data(
from google.cloud import aiplatform_v1
def sample_export_data():
async def sample_export_data():
# Create a client
client = aiplatform_v1.DatasetServiceClient()
client = aiplatform_v1.DatasetServiceAsyncClient()
# Initialize request argument(s)
export_config = aiplatform_v1.ExportDataConfig()
Expand All @@ -953,7 +953,7 @@ def sample_export_data():
print("Waiting for operation to complete...")
response = operation.result()
response = await operation.result()
# Handle the response
print(response)
Expand Down Expand Up @@ -1059,9 +1059,9 @@ async def list_data_items(
from google.cloud import aiplatform_v1
def sample_list_data_items():
async def sample_list_data_items():
# Create a client
client = aiplatform_v1.DatasetServiceClient()
client = aiplatform_v1.DatasetServiceAsyncClient()
# Initialize request argument(s)
request = aiplatform_v1.ListDataItemsRequest(
Expand All @@ -1072,7 +1072,7 @@ def sample_list_data_items():
page_result = client.list_data_items(request=request)
# Handle the response
for response in page_result:
async for response in page_result:
print(response)
Args:
Expand Down Expand Up @@ -1168,17 +1168,17 @@ async def get_annotation_spec(
from google.cloud import aiplatform_v1
def sample_get_annotation_spec():
async def sample_get_annotation_spec():
# Create a client
client = aiplatform_v1.DatasetServiceClient()
client = aiplatform_v1.DatasetServiceAsyncClient()
# Initialize request argument(s)
request = aiplatform_v1.GetAnnotationSpecRequest(
name="name_value",
)
# Make the request
response = client.get_annotation_spec(request=request)
response = await client.get_annotation_spec(request=request)
# Handle the response
print(response)
Expand Down Expand Up @@ -1264,9 +1264,9 @@ async def list_annotations(
from google.cloud import aiplatform_v1
def sample_list_annotations():
async def sample_list_annotations():
# Create a client
client = aiplatform_v1.DatasetServiceClient()
client = aiplatform_v1.DatasetServiceAsyncClient()
# Initialize request argument(s)
request = aiplatform_v1.ListAnnotationsRequest(
Expand All @@ -1277,7 +1277,7 @@ def sample_list_annotations():
page_result = client.list_annotations(request=request)
# Handle the response
for response in page_result:
async for response in page_result:
print(response)
Args:
Expand Down
42 changes: 21 additions & 21 deletions google/cloud/aiplatform_v1/services/endpoint_service/async_client.py
View file
Expand Up @@ -238,9 +238,9 @@ async def create_endpoint(
from google.cloud import aiplatform_v1
def sample_create_endpoint():
async def sample_create_endpoint():
# Create a client
client = aiplatform_v1.EndpointServiceClient()
client = aiplatform_v1.EndpointServiceAsyncClient()
# Initialize request argument(s)
endpoint = aiplatform_v1.Endpoint()
Expand All @@ -256,7 +256,7 @@ def sample_create_endpoint():
print("Waiting for operation to complete...")
response = operation.result()
response = await operation.result()
# Handle the response
print(response)
Expand Down Expand Up @@ -376,17 +376,17 @@ async def get_endpoint(
from google.cloud import aiplatform_v1
def sample_get_endpoint():
async def sample_get_endpoint():
# Create a client
client = aiplatform_v1.EndpointServiceClient()
client = aiplatform_v1.EndpointServiceAsyncClient()
# Initialize request argument(s)
request = aiplatform_v1.GetEndpointRequest(
name="name_value",
)
# Make the request
response = client.get_endpoint(request=request)
response = await client.get_endpoint(request=request)
# Handle the response
print(response)
Expand Down Expand Up @@ -472,9 +472,9 @@ async def list_endpoints(
from google.cloud import aiplatform_v1
def sample_list_endpoints():
async def sample_list_endpoints():
# Create a client
client = aiplatform_v1.EndpointServiceClient()
client = aiplatform_v1.EndpointServiceAsyncClient()
# Initialize request argument(s)
request = aiplatform_v1.ListEndpointsRequest(
Expand All @@ -485,7 +485,7 @@ def sample_list_endpoints():
page_result = client.list_endpoints(request=request)
# Handle the response
for response in page_result:
async for response in page_result:
print(response)
Args:
Expand Down Expand Up @@ -582,9 +582,9 @@ async def update_endpoint(
from google.cloud import aiplatform_v1
def sample_update_endpoint():
async def sample_update_endpoint():
# Create a client
client = aiplatform_v1.EndpointServiceClient()
client = aiplatform_v1.EndpointServiceAsyncClient()
# Initialize request argument(s)
endpoint = aiplatform_v1.Endpoint()
Expand All @@ -595,7 +595,7 @@ def sample_update_endpoint():
)
# Make the request
response = client.update_endpoint(request=request)
response = await client.update_endpoint(request=request)
# Handle the response
print(response)
Expand Down Expand Up @@ -692,9 +692,9 @@ async def delete_endpoint(
from google.cloud import aiplatform_v1
def sample_delete_endpoint():
async def sample_delete_endpoint():
# Create a client
client = aiplatform_v1.EndpointServiceClient()
client = aiplatform_v1.EndpointServiceAsyncClient()
# Initialize request argument(s)
request = aiplatform_v1.DeleteEndpointRequest(
Expand All @@ -706,7 +706,7 @@ def sample_delete_endpoint():
print("Waiting for operation to complete...")
response = operation.result()
response = await operation.result()
# Handle the response
print(response)
Expand Down Expand Up @@ -816,9 +816,9 @@ async def deploy_model(
from google.cloud import aiplatform_v1
def sample_deploy_model():
async def sample_deploy_model():
# Create a client
client = aiplatform_v1.EndpointServiceClient()
client = aiplatform_v1.EndpointServiceAsyncClient()
# Initialize request argument(s)
deployed_model = aiplatform_v1.DeployedModel()
Expand All @@ -835,7 +835,7 @@ def sample_deploy_model():
print("Waiting for operation to complete...")
response = operation.result()
response = await operation.result()
# Handle the response
print(response)
Expand Down Expand Up @@ -973,9 +973,9 @@ async def undeploy_model(
from google.cloud import aiplatform_v1
def sample_undeploy_model():
async def sample_undeploy_model():
# Create a client
client = aiplatform_v1.EndpointServiceClient()
client = aiplatform_v1.EndpointServiceAsyncClient()
# Initialize request argument(s)
request = aiplatform_v1.UndeployModelRequest(
Expand All @@ -988,7 +988,7 @@ def sample_undeploy_model():
print("Waiting for operation to complete...")
response = operation.result()
response = await operation.result()
# Handle the response
print(response)
Expand Down

0 comments on commit 99aca4a

Please sign in to comment.