From 2d6f22701a5a37f6e9321a4da92c81ddbda347de Mon Sep 17 00:00:00 2001
From: Alexey Volkov <alexey.volkov@ark-kun.com>
Date: Fri, 22 Jul 2022 11:58:08 -0700
Subject: [PATCH] fix: Pass the PipelineJob credentials to
 `create_gcs_bucket_for_pipeline_artifacts_if_it_does_not_exist`

---
 google/cloud/aiplatform/pipeline_jobs.py | 1 +
 1 file changed, 1 insertion(+)

diff --git a/google/cloud/aiplatform/pipeline_jobs.py b/google/cloud/aiplatform/pipeline_jobs.py
index 31adf372f3..850b12ffaf 100644
--- 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