code: def _stop_vertex_ai(mark_as_completed=False):
      del mark_as_completed
      from google.cloud import aiplatform
      from google.api_core import exceptions
  
      aiplatform.init(project=os.environ["CLOUD_ML_PROJECT_ID"])
      try:
          aiplatform.CustomJob.get(
              os.environ["CLOUD_ML_JOB_ID"]
          ).cancel()
      except exceptions.FailedPrecondition:
          # Experiment could have been already cancelled.
          pass
  
file_path: launchpad/launchpad/program_stopper/program_stopper.py
imports: import functools
  import os
  import signal
  import sys
  from typing import Union
  from absl import logging
  from launchpad import context
  from launchpad import flags
  from launchpad.launch import worker_manager
  from launchpad.launch import worker_manager_v2
label_desc: Use image node_id 1 for calling a global function with example usage: _stop_vertex_ai(mark_as_completed) without return types