code: def wait_pipeline_execution(
      execution: _PipelineExecution,
      delay: int = 30,
      max_attempts: int = 60,
  ):
      try:
          execution.wait(delay=delay, max_attempts=max_attempts)
      except WaiterError:
          pass
  
file_path: sagemaker-python-sdk/tests/integ/sagemaker/workflow/helpers.py
imports: from __future__ import absolute_import
  import re
  from botocore.exceptions import WaiterError
  from sagemaker import Session
  from sagemaker.workflow.pipeline import _PipelineExecution
  from sagemaker.workflow.pipeline import Pipeline
label_desc: Use image node_id 1 for calling a global function with example usage: wait_pipeline_execution(execution, delay, max_attempts) without return types