code: def _verify_default_monitoring_schedule_with_batch_transform(
      sagemaker_session,
      schedule_description,
      cron_expression=CronExpressionGenerator.daily(),
      statistics=None,
      constraints=None,
      output_kms_key=None,
      volume_kms_key=None,
      instant_count=INSTANCE_COUNT,
      instant_type=INSTANCE_TYPE,
      volume_size_in_gb=VOLUME_SIZE_IN_GB,
      network_config=None,
      max_runtime_in_seconds=MAX_RUNTIME_IN_SECONDS,
      publish_cloudwatch_metrics="Enabled",
      env_key=ENV_KEY_1,
      env_value=ENV_VALUE_1,
      preprocessor=None,
      postprocessor=None,
      role=ROLE,
  ):
      assert (
          schedule_description["MonitoringScheduleConfig"][
              "ScheduleConfig"
          ]["ScheduleExpression"]
          == cron_expression
      )
      assert (
          schedule_description["MonitoringScheduleConfig"][
              "MonitoringType"
          ]
          == "DataQuality"
      )
  
      job_definition_name = schedule_description[
          "MonitoringScheduleConfig"
      ].get("MonitoringJobDefinitionName")
      if job_definition_name:
          job_desc = sagemaker_session.sagemaker_client.describe_data_quality_job_definition(
              JobDefinitionName=job_definition_name,
          )
          # app specification
          app_specification = job_desc["DataQualityAppSpecification"]
          env = app_specification["Environment"]
          baseline_config = job_desc.get("DataQualityBaselineConfig")
          job_input = job_desc["DataQualityJobInput"]
          job_output_config = job_desc["DataQualityJobOutputConfig"]
          client_config = job_desc["JobResources"]["ClusterConfig"]
      else:
          job_desc = schedule_description["MonitoringScheduleConfig"][
              "MonitoringJobDefinition"
          ]
          app_specification = job_desc["MonitoringAppSpecification"]
          env = job_desc["Environment"]
          baseline_config = job_desc.get("BaselineConfig")
          job_input = job_desc["MonitoringInputs"][0]
          job_output_config = job_desc["MonitoringOutputConfig"]
          client_config = job_desc["MonitoringResources"][
              "ClusterConfig"
          ]
  
      assert DEFAULT_IMAGE_SUFFIX in app_specification["ImageUri"]
      if env.get(env_key):
          assert env[env_key] == env_value
      assert (
          env["publish_cloudwatch_metrics"]
          == publish_cloudwatch_metrics
      )
      assert (
          app_specification.get("RecordPreprocessorSourceUri")
          == preprocessor
      )
      assert (
          app_specification.get("PostAnalyticsProcessorSourceUri")
          == postprocessor
      )
  
      # baseline
      if baseline_config:
          if baseline_config["StatisticsResource"]:
              assert (
                  baseline_config["StatisticsResource"]["S3Uri"]
                  == statistics.file_s3_uri
              )
          else:
              assert statistics is None
          if baseline_config["ConstraintsResource"]:
              assert (
                  baseline_config["ConstraintsResource"]["S3Uri"]
                  == constraints.file_s3_uri
              )
          else:
              assert constraints is None
      else:
          assert statistics is None
          assert constraints is None
      # job input
      assert (
          "sagemaker-tensorflow-serving"
          in job_input["BatchTransformInput"][
              "DataCapturedDestinationS3Uri"
          ]
      )
      # job output config
      assert len(job_output_config["MonitoringOutputs"]) == 1
      assert job_output_config.get("KmsKeyId") == output_kms_key
      # job resources
      assert client_config["InstanceCount"] == instant_count
      assert client_config["InstanceType"] == instant_type
      assert client_config["VolumeSizeInGB"] == volume_size_in_gb
      assert client_config.get("VolumeKmsKeyId") == volume_kms_key
      # role
      assert role in job_desc["RoleArn"]
      # stop condition
      assert (
          job_desc["StoppingCondition"]["MaxRuntimeInSeconds"]
          == max_runtime_in_seconds
      )
      # network config
      if job_desc.get("NetworkConfig"):
          assert (
              job_desc["NetworkConfig"].get("EnableNetworkIsolation")
              == network_config.enable_network_isolation
          )
      else:
          assert network_config is None
  
imports: from __future__ import absolute_import
  import json
  import os
  import uuid
  import time
  import pytest
  import tests.integ
  import tests.integ.timeout
  from sagemaker.s3 import S3Uploader
  from datetime import datetime, timedelta
  from tests.integ import DATA_DIR
  from sagemaker.model_monitor import DatasetFormat
  from sagemaker.model_monitor import MonitoringDatasetFormat
  from sagemaker.model_monitor import NetworkConfig, Statistics, Constraints
  from sagemaker.model_monitor import ModelMonitor
  from sagemaker.model_monitor import DefaultModelMonitor
  from sagemaker.model_monitor import MonitoringOutput
  from sagemaker.model_monitor import DataCaptureConfig
  from sagemaker.model_monitor import BatchTransformInput
  from sagemaker.model_monitor import DataQualityMonitoringConfig
  from sagemaker.model_monitor import DataQualityDistributionConstraints
  from sagemaker.model_monitor.data_capture_config import _MODEL_MONITOR_S3_PATH
  from sagemaker.model_monitor.data_capture_config import _DATA_CAPTURE_S3_PATH
  from sagemaker.model_monitor import CronExpressionGenerator
  from sagemaker.model_monitor.monitoring_alert import MonitoringAlertSummary
  from sagemaker.processing import ProcessingInput
  from sagemaker.processing import ProcessingOutput
  from sagemaker.tensorflow.model import TensorFlowModel
  from sagemaker.utils import unique_name_from_base
  from tests.integ.kms_utils import get_or_create_kms_key
  from tests.integ.retry import retries
label_desc: Use image node_id 32 for calling a global function with example usage: _verify_default_monitoring_schedule_with_batch_transform(sagemaker_session, schedule_description, cron_expression, statistics, constraints, output_kms_key, volume_kms_key, instant_count, instant_type, volume_size_in_gb, network_config, max_runtime_in_seconds, publish_cloudwatch_metrics, env_key, env_value, preprocessor, postprocessor, role) without return types