code: def test_parallel_load_should_raise_exception_or_pass(self):
      # Create images.
      large_scale_image_files_path = create_large_scale_image_dataset(
          mp.cpu_count() * 10
      )
  
      # Corrupt an image.
      with open(
          os.path.join(large_scale_image_files_path, "img0.jpg"), "w"
      ) as f:
          f.write("aa")
  
      load_query = f"LOAD IMAGE '{large_scale_image_files_path}/**/*.jpg' INTO MyLargeScaleImages;"
      result = execute_query_fetch_all(self.evadb, load_query)
  
      file_count = len(
          [
              entry
              for entry in os.listdir(large_scale_image_files_path)
              if os.path.isfile(
                  os.path.join(large_scale_image_files_path, entry)
              )
          ]
      )
      expected = Batch(
          pd.DataFrame(
              [
                  f"Number of loaded {FileFormatType.IMAGE.name}: {file_count-1}"
              ]
          )
      )
      self.assertEqual(result, expected)
  
      drop_query = "DROP TABLE IF EXISTS MyLargeScaleImages;"
      execute_query_fetch_all(self.evadb, drop_query)
  
      # Clean up large scale image directory.
      shutil.rmtree(large_scale_image_files_path)
  
imports: import glob
  import multiprocessing
  import os
  import shutil
  import tempfile
  import unittest
  from pathlib import Path
  from test.util import create_dummy_batches, create_dummy_csv_batches, create_large_scale_image_dataset, create_sample_csv, create_sample_video, file_remove, get_evadb_for_testing, shutdown_ray
  import numpy
  import pandas
  import pytest
  from evadb.binder.binder_utils import BinderError
  from evadb.configuration.constants import EvaDB_ROOT_DIR
  from evadb.executor.executor_utils import ExecutorError
  from evadb.models.storage.batch import Batch
  from evadb.parser.types import FileFormatType
  from evadb.server.command_handler import execute_query_fetch_all
label_desc: Use image node_id 22 for calling the LoadExecutorTests obj's underlying member method code with example usage: obj.test_parallel_load_should_raise_exception_or_pass() without return types