code: def read_shm_message(shm_chunk: BufShmChunk, shm_message):
      if shm_message.shm_capacity != shm_chunk.capacity:
          shm_chunk.resize(shm_message.shm_capacity, trunc=False)
      buffer = shm_chunk.buf[
          shm_message.offset : shm_message.offset
          + shm_message.num_bytes
      ]
      return pickle.loads(buffer)
  
imports: import os
  from nvidia.dali._multiproc import shared_mem
  from nvidia.dali._multiproc.messages import ShmMessageDesc
  from nvidia.dali._utils.external_source_impl import assert_cpu_sample_data_type, sample_to_numpy
  import pickle
label_desc: Use image node_id 10 for calling a global function with example usage: read_shm_message(shm_chunk, shm_message) and returns: pickle