feat: Create Data Labeling kube-flow container component

PiperOrigin-RevId: 617930970

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,