Add list method and fix utils

Author: ji-yaqi

google/cloud/aiplatform/pipeline_jobs.py

@@ -81,8 +81,9 @@ class PipelineJob(base.VertexAiResourceNounWithFutureManager):
     _is_client_prediction_client = False
 
     _resource_noun = "pipelineJobs"
-    _getter_method = "get_pipeline_job"
     _delete_method = "delete_pipeline_job"
+    _getter_method = "get_pipeline_job"
+    _list_method = "list_pipeline_jobs"
 
     def __init__(
         self,

google/cloud/aiplatform/utils/pipeline_utils.py

@@ -65,7 +65,7 @@ def from_job_spec_json(
         )
         parameter_types = {k: v["type"] for k, v in parameter_input_definitions.items()}
 
-        pipeline_root = runtime_config_spec.get("gcsOutputDirectory")
+        pipeline_root = runtime_config_spec.get("gcs_output_directory")
         parameter_values = _parse_runtime_parameters(runtime_config_spec)
         return cls(pipeline_root, parameter_types, parameter_values)
 

tests/unit/aiplatform/test_utils.py

@@ -360,7 +360,7 @@ class TestPipelineUtils:
             }
         },
         "runtimeConfig": {
-            "gcsOutputDirectory": "path/to/my/root",
+            "gcs_output_directory": "path/to/my/root",
             "parameters": {
                 "string_param": {"stringValue": "test-string"},
                 "int_param": {"intValue": 42},
@@ -420,7 +420,7 @@ def test_pipeline_utils_runtime_config_builder_with_merge_updates(self):
         actual_runtime_config = my_builder.build()
 
         expected_runtime_config = {
-            "gcsOutputDirectory": "path/to/my/new/root",
+            "gcs_output_directory": "path/to/my/new/root",
             "parameters": {
                 "string_param": {"stringValue": "test-string"},
                 "int_param": {"intValue": 888},