code: def test_marketplace_transform_job(
      sagemaker_session, cpu_instance_type
  ):
      data_path = os.path.join(DATA_DIR, "marketplace", "training")
      region = sagemaker_session.boto_region_name
      account = REGION_ACCOUNT_MAP[region]
      algorithm_arn = ALGORITHM_ARN.format(
          partition=_aws_partition(region),
          region=region,
          account=account,
      )
  
      algo = AlgorithmEstimator(
          algorithm_arn=algorithm_arn,
          role="SageMakerRole",
          instance_count=1,
          instance_type=cpu_instance_type,
          sagemaker_session=sagemaker_session,
          base_job_name=unique_name_from_base("test-marketplace"),
      )
  
      train_input = algo.sagemaker_session.upload_data(
          path=data_path, key_prefix="integ-test-data/marketplace/train"
      )
  
      shape = pandas.read_csv(
          data_path + "/iris.csv", header=None
      ).drop([0], axis=1)
  
      transform_workdir = DATA_DIR + "/marketplace/transform"
      shape.to_csv(
          transform_workdir + "/batchtransform_test.csv",
          index=False,
          header=False,
      )
      transform_input = algo.sagemaker_session.upload_data(
          transform_workdir,
          key_prefix="integ-test-data/marketplace/transform",
      )
  
      algo.fit({"training": train_input})
  
      transformer = algo.transformer(1, cpu_instance_type)
      transformer.transform(transform_input, content_type="text/csv")
      transformer.wait()
  
imports: from __future__ import absolute_import
  import itertools
  import os
  import time
  import requests
  import pandas
  import pytest
  import docker
  import sagemaker
  import tests.integ
  from tests.integ.utils import create_repository
  from sagemaker import AlgorithmEstimator, ModelPackage, Model
  from sagemaker.serializers import CSVSerializer
  from sagemaker.tuner import IntegerParameter, HyperparameterTuner
  from sagemaker.utils import sagemaker_timestamp, _aws_partition, unique_name_from_base
  from tests.integ import DATA_DIR
  from tests.integ.timeout import timeout, timeout_and_delete_endpoint_by_name
  from tests.integ.marketplace_utils import REGION_ACCOUNT_MAP
  from tests.integ.test_multidatamodel import _ecr_image_uri, _ecr_login, _delete_repository
  from tests.integ.retry import retries
  import logging
label_desc: Use image node_id 7 for calling a global function with example usage: test_marketplace_transform_job(sagemaker_session, cpu_instance_type) without return types