code: def test_executor_submit_checksum_mismatch(
      sagemaker_session,
      dummy_container_without_error,
      cpu_instance_type,
  ):
      def original_func(x):
          return x * x
  
      def updated_func(x):
          return x + 25
  
      def wait_for_future_running(future, timeout_in_seconds):
          polling_timeout = time.time() + timeout_in_seconds
          while time.time() < polling_timeout:
              if future.running():
                  return True
              time.sleep(1)
          return False
  
      pickled_updated_func = CloudpickleSerializer.serialize(
          updated_func
      )
  
      with RemoteExecutor(
          max_parallel_jobs=1,
          role=ROLE,
          image_uri=dummy_container_without_error,
          instance_type=cpu_instance_type,
          sagemaker_session=sagemaker_session,
          keep_alive_period_in_seconds=30,
          pre_execution_commands=["sleep 60"],
      ) as e:
          future = e.submit(original_func, 10)
          if wait_for_future_running(future, 60):
              S3Uploader.upload_bytes(
                  pickled_updated_func,
                  s3_path_join(
                      future._job.s3_uri, "function", "payload.pkl"
                  ),
                  kms_key=None,
                  sagemaker_session=sagemaker_session,
              )
          else:
              assert (
                  False
              ), "Expected future to be in running state, but it timed-out."
  
      with pytest.raises(DeserializationError) as ex:
          future.result()
      assert (
          "Integrity check for the serialized function or data failed"
          in str(ex)
      )
  
file_path: sagemaker-python-sdk/tests/integ/sagemaker/remote_function/test_executor.py
imports: from __future__ import absolute_import
  import time
  import pytest
  from sagemaker.experiments.trial_component import _TrialComponent
  from sagemaker.remote_function import RemoteExecutor
  from sagemaker.remote_function.client import get_future, list_futures
  from sagemaker.experiments.run import Run, load_run
  from sagemaker.remote_function.core.serialization import CloudpickleSerializer
  from sagemaker.remote_function.errors import DeserializationError
  from sagemaker.s3 import S3Uploader
  from sagemaker.s3_utils import s3_path_join
  from tests.integ.sagemaker.experiments.helpers import cleanup_exp_resources
  from sagemaker.utils import unique_name_from_base
label_desc: Use image node_id 7 for calling a global function with example usage: test_executor_submit_checksum_mismatch(sagemaker_session, dummy_container_without_error, cpu_instance_type) and returns: unknown, unknown, False, True