fix: Pass the PipelineJob credentials to create_gcs_bucket_for_pipeline_artifacts_if_it_does_not_exist (#1537)

Ark-kun · sararob · web-flow · commit b53e2b5942fa · 2022-07-25T11:02:12.000-04:00
Co-authored-by: Sara Robinson &lt;sararob@users.noreply.github.com&gt;
diff --git a/google/cloud/aiplatform/pipeline_jobs.py b/google/cloud/aiplatform/pipeline_jobs.py
@@ -348,6 +348,7 @@ def submit(
             service_account=self._gca_resource.service_account,
             project=self.project,
             location=self.location,
+            credentials=self.credentials,
         )
 
         # Prevents logs from being supressed on TFX pipelines

Original file line number	Diff line number	Diff line change
`@@ -348,6 +348,7 @@ def submit(`
`348`	`348`	`service_account=self._gca_resource.service_account,`
`349`	`349`	`project=self.project,`
`350`	`350`	`location=self.location,`
	`351`	`+ credentials=self.credentials,`
`351`	`352`	`)`
`352`	`353`
`353`	`354`	`# Prevents logs from being supressed on TFX pipelines`