Skip to content

Commit 99aca4a

Browse files
gcf-owl-bot[bot]dizcology
gcf-owl-bot[bot]
and
dizcology
authored
feat: add template_metadata to PipelineJob in aiplatform v1beta1 pipeline_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 <[email protected]>
1 parent c773539 commit 99aca4a

File tree

66 files changed

+2791
-2745
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

66 files changed

+2791
-2745
lines changed

‎.kokoro/continuous/continuous.cfg

+1-1
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
# Format: //devtools/kokoro/config/proto/build.proto
1+
# Format: //devtools/kokoro/config/proto/build.proto

‎google/cloud/aiplatform_v1/services/dataset_service/async_client.py

+30-30
Original file line numberDiff line numberDiff line change
@@ -241,9 +241,9 @@ async def create_dataset(
241241
242242
from google.cloud import aiplatform_v1
243243
244-
def sample_create_dataset():
244+
async def sample_create_dataset():
245245
# Create a client
246-
client = aiplatform_v1.DatasetServiceClient()
246+
client = aiplatform_v1.DatasetServiceAsyncClient()
247247
248248
# Initialize request argument(s)
249249
dataset = aiplatform_v1.Dataset()
@@ -261,7 +261,7 @@ def sample_create_dataset():
261261
262262
print("Waiting for operation to complete...")
263263
264-
response = operation.result()
264+
response = await operation.result()
265265
266266
# Handle the response
267267
print(response)
@@ -365,17 +365,17 @@ async def get_dataset(
365365
366366
from google.cloud import aiplatform_v1
367367
368-
def sample_get_dataset():
368+
async def sample_get_dataset():
369369
# Create a client
370-
client = aiplatform_v1.DatasetServiceClient()
370+
client = aiplatform_v1.DatasetServiceAsyncClient()
371371
372372
# Initialize request argument(s)
373373
request = aiplatform_v1.GetDatasetRequest(
374374
name="name_value",
375375
)
376376
377377
# Make the request
378-
response = client.get_dataset(request=request)
378+
response = await client.get_dataset(request=request)
379379
380380
# Handle the response
381381
print(response)
@@ -461,9 +461,9 @@ async def update_dataset(
461461
462462
from google.cloud import aiplatform_v1
463463
464-
def sample_update_dataset():
464+
async def sample_update_dataset():
465465
# Create a client
466-
client = aiplatform_v1.DatasetServiceClient()
466+
client = aiplatform_v1.DatasetServiceAsyncClient()
467467
468468
# Initialize request argument(s)
469469
dataset = aiplatform_v1.Dataset()
@@ -476,7 +476,7 @@ def sample_update_dataset():
476476
)
477477
478478
# Make the request
479-
response = client.update_dataset(request=request)
479+
response = await client.update_dataset(request=request)
480480
481481
# Handle the response
482482
print(response)
@@ -578,9 +578,9 @@ async def list_datasets(
578578
579579
from google.cloud import aiplatform_v1
580580
581-
def sample_list_datasets():
581+
async def sample_list_datasets():
582582
# Create a client
583-
client = aiplatform_v1.DatasetServiceClient()
583+
client = aiplatform_v1.DatasetServiceAsyncClient()
584584
585585
# Initialize request argument(s)
586586
request = aiplatform_v1.ListDatasetsRequest(
@@ -591,7 +591,7 @@ def sample_list_datasets():
591591
page_result = client.list_datasets(request=request)
592592
593593
# Handle the response
594-
for response in page_result:
594+
async for response in page_result:
595595
print(response)
596596
597597
Args:
@@ -686,9 +686,9 @@ async def delete_dataset(
686686
687687
from google.cloud import aiplatform_v1
688688
689-
def sample_delete_dataset():
689+
async def sample_delete_dataset():
690690
# Create a client
691-
client = aiplatform_v1.DatasetServiceClient()
691+
client = aiplatform_v1.DatasetServiceAsyncClient()
692692
693693
# Initialize request argument(s)
694694
request = aiplatform_v1.DeleteDatasetRequest(
@@ -700,7 +700,7 @@ def sample_delete_dataset():
700700
701701
print("Waiting for operation to complete...")
702702
703-
response = operation.result()
703+
response = await operation.result()
704704
705705
# Handle the response
706706
print(response)
@@ -808,9 +808,9 @@ async def import_data(
808808
809809
from google.cloud import aiplatform_v1
810810
811-
def sample_import_data():
811+
async def sample_import_data():
812812
# Create a client
813-
client = aiplatform_v1.DatasetServiceClient()
813+
client = aiplatform_v1.DatasetServiceAsyncClient()
814814
815815
# Initialize request argument(s)
816816
import_configs = aiplatform_v1.ImportDataConfig()
@@ -827,7 +827,7 @@ def sample_import_data():
827827
828828
print("Waiting for operation to complete...")
829829
830-
response = operation.result()
830+
response = await operation.result()
831831
832832
# Handle the response
833833
print(response)
@@ -935,9 +935,9 @@ async def export_data(
935935
936936
from google.cloud import aiplatform_v1
937937
938-
def sample_export_data():
938+
async def sample_export_data():
939939
# Create a client
940-
client = aiplatform_v1.DatasetServiceClient()
940+
client = aiplatform_v1.DatasetServiceAsyncClient()
941941
942942
# Initialize request argument(s)
943943
export_config = aiplatform_v1.ExportDataConfig()
@@ -953,7 +953,7 @@ def sample_export_data():
953953
954954
print("Waiting for operation to complete...")
955955
956-
response = operation.result()
956+
response = await operation.result()
957957
958958
# Handle the response
959959
print(response)
@@ -1059,9 +1059,9 @@ async def list_data_items(
10591059
10601060
from google.cloud import aiplatform_v1
10611061
1062-
def sample_list_data_items():
1062+
async def sample_list_data_items():
10631063
# Create a client
1064-
client = aiplatform_v1.DatasetServiceClient()
1064+
client = aiplatform_v1.DatasetServiceAsyncClient()
10651065
10661066
# Initialize request argument(s)
10671067
request = aiplatform_v1.ListDataItemsRequest(
@@ -1072,7 +1072,7 @@ def sample_list_data_items():
10721072
page_result = client.list_data_items(request=request)
10731073
10741074
# Handle the response
1075-
for response in page_result:
1075+
async for response in page_result:
10761076
print(response)
10771077
10781078
Args:
@@ -1168,17 +1168,17 @@ async def get_annotation_spec(
11681168
11691169
from google.cloud import aiplatform_v1
11701170
1171-
def sample_get_annotation_spec():
1171+
async def sample_get_annotation_spec():
11721172
# Create a client
1173-
client = aiplatform_v1.DatasetServiceClient()
1173+
client = aiplatform_v1.DatasetServiceAsyncClient()
11741174
11751175
# Initialize request argument(s)
11761176
request = aiplatform_v1.GetAnnotationSpecRequest(
11771177
name="name_value",
11781178
)
11791179
11801180
# Make the request
1181-
response = client.get_annotation_spec(request=request)
1181+
response = await client.get_annotation_spec(request=request)
11821182
11831183
# Handle the response
11841184
print(response)
@@ -1264,9 +1264,9 @@ async def list_annotations(
12641264
12651265
from google.cloud import aiplatform_v1
12661266
1267-
def sample_list_annotations():
1267+
async def sample_list_annotations():
12681268
# Create a client
1269-
client = aiplatform_v1.DatasetServiceClient()
1269+
client = aiplatform_v1.DatasetServiceAsyncClient()
12701270
12711271
# Initialize request argument(s)
12721272
request = aiplatform_v1.ListAnnotationsRequest(
@@ -1277,7 +1277,7 @@ def sample_list_annotations():
12771277
page_result = client.list_annotations(request=request)
12781278
12791279
# Handle the response
1280-
for response in page_result:
1280+
async for response in page_result:
12811281
print(response)
12821282
12831283
Args:

‎google/cloud/aiplatform_v1/services/endpoint_service/async_client.py

+21-21
Original file line numberDiff line numberDiff line change
@@ -238,9 +238,9 @@ async def create_endpoint(
238238
239239
from google.cloud import aiplatform_v1
240240
241-
def sample_create_endpoint():
241+
async def sample_create_endpoint():
242242
# Create a client
243-
client = aiplatform_v1.EndpointServiceClient()
243+
client = aiplatform_v1.EndpointServiceAsyncClient()
244244
245245
# Initialize request argument(s)
246246
endpoint = aiplatform_v1.Endpoint()
@@ -256,7 +256,7 @@ def sample_create_endpoint():
256256
257257
print("Waiting for operation to complete...")
258258
259-
response = operation.result()
259+
response = await operation.result()
260260
261261
# Handle the response
262262
print(response)
@@ -376,17 +376,17 @@ async def get_endpoint(
376376
377377
from google.cloud import aiplatform_v1
378378
379-
def sample_get_endpoint():
379+
async def sample_get_endpoint():
380380
# Create a client
381-
client = aiplatform_v1.EndpointServiceClient()
381+
client = aiplatform_v1.EndpointServiceAsyncClient()
382382
383383
# Initialize request argument(s)
384384
request = aiplatform_v1.GetEndpointRequest(
385385
name="name_value",
386386
)
387387
388388
# Make the request
389-
response = client.get_endpoint(request=request)
389+
response = await client.get_endpoint(request=request)
390390
391391
# Handle the response
392392
print(response)
@@ -472,9 +472,9 @@ async def list_endpoints(
472472
473473
from google.cloud import aiplatform_v1
474474
475-
def sample_list_endpoints():
475+
async def sample_list_endpoints():
476476
# Create a client
477-
client = aiplatform_v1.EndpointServiceClient()
477+
client = aiplatform_v1.EndpointServiceAsyncClient()
478478
479479
# Initialize request argument(s)
480480
request = aiplatform_v1.ListEndpointsRequest(
@@ -485,7 +485,7 @@ def sample_list_endpoints():
485485
page_result = client.list_endpoints(request=request)
486486
487487
# Handle the response
488-
for response in page_result:
488+
async for response in page_result:
489489
print(response)
490490
491491
Args:
@@ -582,9 +582,9 @@ async def update_endpoint(
582582
583583
from google.cloud import aiplatform_v1
584584
585-
def sample_update_endpoint():
585+
async def sample_update_endpoint():
586586
# Create a client
587-
client = aiplatform_v1.EndpointServiceClient()
587+
client = aiplatform_v1.EndpointServiceAsyncClient()
588588
589589
# Initialize request argument(s)
590590
endpoint = aiplatform_v1.Endpoint()
@@ -595,7 +595,7 @@ def sample_update_endpoint():
595595
)
596596
597597
# Make the request
598-
response = client.update_endpoint(request=request)
598+
response = await client.update_endpoint(request=request)
599599
600600
# Handle the response
601601
print(response)
@@ -692,9 +692,9 @@ async def delete_endpoint(
692692
693693
from google.cloud import aiplatform_v1
694694
695-
def sample_delete_endpoint():
695+
async def sample_delete_endpoint():
696696
# Create a client
697-
client = aiplatform_v1.EndpointServiceClient()
697+
client = aiplatform_v1.EndpointServiceAsyncClient()
698698
699699
# Initialize request argument(s)
700700
request = aiplatform_v1.DeleteEndpointRequest(
@@ -706,7 +706,7 @@ def sample_delete_endpoint():
706706
707707
print("Waiting for operation to complete...")
708708
709-
response = operation.result()
709+
response = await operation.result()
710710
711711
# Handle the response
712712
print(response)
@@ -816,9 +816,9 @@ async def deploy_model(
816816
817817
from google.cloud import aiplatform_v1
818818
819-
def sample_deploy_model():
819+
async def sample_deploy_model():
820820
# Create a client
821-
client = aiplatform_v1.EndpointServiceClient()
821+
client = aiplatform_v1.EndpointServiceAsyncClient()
822822
823823
# Initialize request argument(s)
824824
deployed_model = aiplatform_v1.DeployedModel()
@@ -835,7 +835,7 @@ def sample_deploy_model():
835835
836836
print("Waiting for operation to complete...")
837837
838-
response = operation.result()
838+
response = await operation.result()
839839
840840
# Handle the response
841841
print(response)
@@ -973,9 +973,9 @@ async def undeploy_model(
973973
974974
from google.cloud import aiplatform_v1
975975
976-
def sample_undeploy_model():
976+
async def sample_undeploy_model():
977977
# Create a client
978-
client = aiplatform_v1.EndpointServiceClient()
978+
client = aiplatform_v1.EndpointServiceAsyncClient()
979979
980980
# Initialize request argument(s)
981981
request = aiplatform_v1.UndeployModelRequest(
@@ -988,7 +988,7 @@ def sample_undeploy_model():
988988
989989
print("Waiting for operation to complete...")
990990
991-
response = operation.result()
991+
response = await operation.result()
992992
993993
# Handle the response
994994
print(response)

0 commit comments

Comments
 (0)