code: def test_one_step_data_bias_pipeline_constraint_violation(
      sagemaker_session,
      role,
      pipeline_name,
      check_job_config,
      fail_on_violation,
      data_bias_check_config,
      supplied_baseline_constraints_uri_param,
  ):
      data_bias_supplied_baseline_constraints = Constraints.from_file_path(
          constraints_file_path=os.path.join(
              DATA_DIR,
              "pipeline/clarify_check_step/data_bias/bad_cases/analysis.json",
          ),
          sagemaker_session=sagemaker_session,
      ).file_s3_uri
      data_bias_check_step = ClarifyCheckStep(
          name="DataBiasCheckStep",
          clarify_check_config=data_bias_check_config,
          check_job_config=check_job_config,
          skip_check=False,
          fail_on_violation=fail_on_violation,
          register_new_baseline=False,
          supplied_baseline_constraints=supplied_baseline_constraints_uri_param,
      )
      pipeline = Pipeline(
          name=pipeline_name,
          steps=[data_bias_check_step],
          parameters=[supplied_baseline_constraints_uri_param],
          sagemaker_session=sagemaker_session,
      )
  
      try:
          response = pipeline.create(role)
          create_arn = response["PipelineArn"]
          monitoring_analysis_cfg_json = S3Downloader.read_file(
              data_bias_check_config.monitoring_analysis_config_uri,
              sagemaker_session,
          )
          monitoring_analysis_cfg = json.loads(
              monitoring_analysis_cfg_json
          )
  
          assert (
              monitoring_analysis_cfg is not None
              and len(monitoring_analysis_cfg) > 0
          )
  
          for _ in retries(
              max_retry_count=5,
              exception_message_prefix="Waiting for a successful execution of pipeline",
              seconds_to_sleep=10,
          ):
              execution = pipeline.start(
                  parameters={
                      "SuppliedBaselineConstraintsUri": data_bias_supplied_baseline_constraints
                  },
              )
              response = execution.describe()
  
              assert response["PipelineArn"] == create_arn
  
              wait_pipeline_execution(execution=execution)
              execution_steps = execution.list_steps()
  
              assert len(execution_steps) == 1
              assert (
                  execution_steps[0]["StepName"] == "DataBiasCheckStep"
              )
              failure_reason = execution_steps[0].get(
                  "FailureReason", ""
              )
  
              if fail_on_violation is None or fail_on_violation:
                  if _CHECK_FAIL_ERROR_MSG not in failure_reason:
                      logging.error(
                          f"Pipeline execution failed with error: {failure_reason}. Retrying.."
                      )
                      continue
                  assert execution_steps[0]["StepStatus"] == "Failed"
              else:
                  assert _CHECK_FAIL_ERROR_MSG not in failure_reason
                  assert execution_steps[0]["StepStatus"] == "Succeeded"
              break
      finally:
          try:
              pipeline.delete()
          except Exception:
              pass
  
imports: from __future__ import absolute_import
  import json
  import logging
  import os
  import pytest
  from tests.integ.sagemaker.workflow.helpers import wait_pipeline_execution
  from sagemaker.clarify import BiasConfig, DataConfig
  from sagemaker.s3 import S3Uploader, S3Downloader
  from sagemaker.workflow.clarify_check_step import DataBiasCheckConfig, ClarifyCheckStep
  from sagemaker.workflow.parameters import ParameterString
  from tests.integ import DATA_DIR
  from sagemaker import get_execution_role, utils
  from sagemaker.model_monitor import Constraints
  from sagemaker.workflow.pipeline import Pipeline
  from sagemaker.workflow.check_job_config import CheckJobConfig
  from tests.integ.retry import retries
label_desc: Use image node_id 10 for calling a global function with example usage: test_one_step_data_bias_pipeline_constraint_violation(sagemaker_session, role, pipeline_name, check_job_config, fail_on_violation, data_bias_check_config, supplied_baseline_constraints_uri_param) without return types