Skip to content

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

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
dizcology merged 11 commits into from
May 9, 2022
Merged

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

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
11 commits
Select commit Hold shift + click to select a range
b2f4755
chore: use gapic-generator-python 0.65.2
gcf-owl-bot[bot] Apr 27, 2022
87147ef
🦉 Updates from OwlBot post-processor
gcf-owl-bot[bot] Apr 27, 2022
91f791f
chore: remove unused imports
gcf-owl-bot[bot] May 4, 2022
9aa84fb
🦉 Updates from OwlBot post-processor
gcf-owl-bot[bot] May 4, 2022
dde7627
chore: use gapic-generator-python 0.65.3
gcf-owl-bot[bot] May 5, 2022
35aa8e8
🦉 Updates from OwlBot post-processor
gcf-owl-bot[bot] May 5, 2022
4c15187
feat: add template_metadata to PipelineJob in aiplatform v1beta1 pipe…
gcf-owl-bot[bot] May 6, 2022
7a241cf
🦉 Updates from OwlBot post-processor
gcf-owl-bot[bot] May 6, 2022
a096bb3
Merge branch 'main' into owl-bot-copy
dizcology May 9, 2022
bb17a9f
🦉 Updates from OwlBot post-processor
gcf-owl-bot[bot] May 9, 2022
8189b4d
Merge branch 'main' into owl-bot-copy
dizcology May 9, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion .kokoro/continuous/continuous.cfg
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -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
Open in desktop
Original file line number Diff line number Diff line change
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
Open in desktop
Original file line number Diff line number Diff line change
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
Loading