code: def test_parallel_write(self, tmpdir, single_submit, overlap_events):
      ref_file, ref_buffer = _do_ref_write(tmpdir)
      aio_file, aio_buffer = _get_test_file_and_buffer(
          tmpdir, ref_buffer, False
      )
  
      h = (
          AsyncIOBuilder()
          .load()
          .aio_handle(
              BLOCK_SIZE,
              QUEUE_DEPTH,
              single_submit,
              overlap_events,
              IO_PARALLEL,
          )
      )
  
      _validate_handle_state(h, single_submit, overlap_events)
  
      write_status = h.sync_pwrite(aio_buffer, aio_file)
      assert write_status == 1
  
      assert os.path.isfile(aio_file)
  
      filecmp.clear_cache()
      assert filecmp.cmp(ref_file, aio_file, shallow=False)
  
imports: import pytest
  import os
  import filecmp
  import torch
  import deepspeed
  import deepspeed.comm
  from deepspeed.ops.aio import AsyncIOBuilder
  from unit.common import DistributedTest
label_desc: Use image node_id 1 for calling the TestWrite obj's underlying member method code with example usage: obj.test_parallel_write(tmpdir, single_submit, overlap_events) without return types