diff --git a/google/cloud/aiplatform/pipeline_jobs.py b/google/cloud/aiplatform/pipeline_jobs.py index 389a6171aa..395e4102d3 100644 --- a/google/cloud/aiplatform/pipeline_jobs.py +++ b/google/cloud/aiplatform/pipeline_jobs.py @@ -204,9 +204,10 @@ def __init__( pipeline_root=pipeline_root, parameter_types={ key: value["type"] - for key, value in pipeline_job["pipelineSpec"]["root"][ - "inputDefinitions" - ]["parameters"].items() + for key, value in pipeline_job["pipelineSpec"]["root"] + .get("inputDefinitions", {}) + .get("parameters", {}) + .items() }, parameter_values=parameter_values, ).build()