From f1fbdf3c472a3e8df9b045384cfe9738ab56cae1 Mon Sep 17 00:00:00 2001 From: A Vertex SDK engineer Date: Thu, 21 Mar 2024 12:40:10 -0700 Subject: [PATCH] feat: Create Data Labeling kube-flow container component PiperOrigin-RevId: 617930970 --- .../aiplatform_v1/services/job_service/client.py | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/google/cloud/aiplatform_v1/services/job_service/client.py b/google/cloud/aiplatform_v1/services/job_service/client.py index ac78b7bd68..409ba2f344 100644 --- a/google/cloud/aiplatform_v1/services/job_service/client.py +++ b/google/cloud/aiplatform_v1/services/job_service/client.py @@ -1704,6 +1704,8 @@ def sample_create_data_labeling_job(): from the following Dataset: """ + import logging + logging.error("hahaha req first: %s", request) # Create or coerce a protobuf request object. # Quick check: If we got a request object, we should *not* have # gotten any keyword arguments that map to the request. @@ -1727,6 +1729,14 @@ def sample_create_data_labeling_job(): if data_labeling_job is not None: request.data_labeling_job = data_labeling_job + # string_value = struct_pb2.Value() + # string_value.string_value = "blabla" + + # struct_value = struct_pb2.Struct() + # struct_value.fields["annotation_specs"].list_value.values.append(string_value) + + # request.data_labeling_job.inputs = struct_value + # Wrap the RPC method; this adds retry and timeout information, # and friendly error handling. rpc = self._transport._wrapped_methods[self._transport.create_data_labeling_job] @@ -1740,6 +1750,7 @@ def sample_create_data_labeling_job(): # Validate the universe domain. self._validate_universe_domain() + logging.error("hahaha request: %s", request) # Send the request. response = rpc( request,