chore: Migrate gsutil usage to gcloud storage (#2150)

Co-authored-by: Anthonios Partheniou <partheniou@google.com>

Author: bhandarivijay-png

synthtool/gcp/templates/python_library/.kokoro/trampoline_v2.sh

@@ -26,8 +26,8 @@
 # To run this script, first download few files from gcs to /dev/shm.
 # (/dev/shm is passed into the container as KOKORO_GFILE_DIR).
 #
-# gsutil cp gs://cloud-devrel-kokoro-resources/python-docs-samples/secrets_viewer_service_account.json /dev/shm
-# gsutil cp gs://cloud-devrel-kokoro-resources/python-docs-samples/automl_secrets.txt /dev/shm
+# gcloud storage cp gs://cloud-devrel-kokoro-resources/python-docs-samples/secrets_viewer_service_account.json /dev/shm
+# gcloud storage cp gs://cloud-devrel-kokoro-resources/python-docs-samples/automl_secrets.txt /dev/shm
 #
 # Then run the script.
 # .kokoro/trampoline_v2.sh

synthtool/gcp/templates/python_notebooks_testing_pipeline/.cloud-build/execute_changed_notebooks_helper.py

@@ -84,7 +84,7 @@ def _process_notebook(
         resources,
     ) = remove_no_execute_cells_preprocessor.preprocess(nb)
 
-    (nb, resources) = update_variables_preprocessor.preprocess(nb, resources)
+    nb, resources = update_variables_preprocessor.preprocess(nb, resources)
 
     with open(notebook_path, mode="w", encoding="utf-8") as new_file:
         nbformat.write(nb, new_file)
@@ -172,7 +172,8 @@ def process_and_execute_notebook(
             # Use gcloud to get tail
             try:
                 result.error_message = subprocess.check_output(
-                    ["gsutil", "cat", "-r", "-1000", log_file_uri], encoding="UTF-8"
+                    ["gcloud", "storage", "cat", "--range=-1000", log_file_uri],
+                    encoding="UTF-8",
                 )
             except Exception as error:
                 result.error_message = str(error)

synthtool/gcp/templates/python_notebooks_testing_pipeline/.cloud-build/utils/utils.py

@@ -25,7 +25,8 @@ def download_file(bucket_name: str, blob_name: str, destination_file: str) -> st
     remote_file_path = "".join(["gs://", "/".join([bucket_name, blob_name])])
 
     subprocess.check_output(
-        ["gsutil", "cp", remote_file_path, destination_file], encoding="UTF-8"
+        ["gcloud", "storage", "cp", remote_file_path, destination_file],
+        encoding="UTF-8",
     )
 
     return destination_file
@@ -37,7 +38,7 @@ def upload_file(
 ) -> str:
     """Copies a local file to a GCS path"""
     subprocess.check_output(
-        ["gsutil", "cp", local_file_path, remote_file_path], encoding="UTF-8"
+        ["gcloud", "storage", "cp", local_file_path, remote_file_path], encoding="UTF-8"
     )
 
     return remote_file_path