Update pipeline_ops.py

GoogleCloudPlatform · Oct 28, 2024 · b4d0fa7 · b4d0fa7
1 parent b8fe773
commit b4d0fa7
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/python/pipelines/pipeline_ops.py b/python/pipelines/pipeline_ops.py
@@ -676,6 +676,7 @@ def schedule_pipeline(
     pipeline_job = aiplatform.PipelineJob(
         template_path=template_path,
         pipeline_root=pipeline_root,
+        location=region,
         display_name=f"{pipeline_name}",
     )
 
@@ -903,4 +904,4 @@ def run_pipeline(
         if (pl.has_failed):
             raise RuntimeError("Pipeline execution failed")
     return pl
-
+