code: def test_downstream_trials(
      trial_associated_artifact, trial_obj, sagemaker_session
  ):
      # allow trial components to index, 30 seconds max
      def validate():
          for i in range(3):
              time.sleep(10)
              trials = trial_associated_artifact.downstream_trials(
                  sagemaker_session=sagemaker_session
              )
              logging.info(f"Found {len(trials)} downstream trials.")
              if len(trials) > 0:
                  break
  
          assert len(trials) == 1
          assert trial_obj.trial_name in trials
  
      retry_with_backoff(validate, num_attempts=3)
  
file_path: sagemaker-python-sdk/tests/integ/sagemaker/lineage/test_artifact.py
imports: from __future__ import absolute_import
  import datetime
  import logging
  import time
  import pytest
  from sagemaker.lineage import artifact
  from sagemaker.utils import retry_with_backoff
label_desc: Use image node_id 8 for calling a global function with example usage: test_downstream_trials(trial_associated_artifact, trial_obj, sagemaker_session) without return types