class_docstr: Pack of parameters passed to the worker process on initialization.
  ----------
  `worker_id` : Ordinal of the worker in the workers pool
  `start_method` : Python's multiprocessing start method - `spawn` or `fork`
  `source_descs` : Dictionary with External Source's SourceDescription instances as values.
      Keys are ordinals corresponding to the order in which callbacks were passed to the pool.
      If `callback_pickler` is not None, actual callback in SourceDescription is replaced
      with result of its serialization.
  `shm_chunks` : list of BufShmChunk instances that describes all the shared memory chunks
      available to the worker (they are identified by ids unique inside the pool).
  `general_task_queue` : Optional[ShmQueue]
      Queue with tasks for sources without dedicated worker
      or None if all sources have dedicated worker
  `dedicated_task_queue`: Optional[ShmQueue]
      Queue with tasks for sources that are run solely in the given worker.
      If `dedicated_task_queue` is None, `general_task_queue` must be provided.
  `result_queue`: ShmQueue
      Queue to report any task done, no matter if dedicated or general.
  `setup_socket` : Optional[socket]
      Python wrapper around Unix socket used to pass file descriptors identifying
      shared memory chunk to child process. None if `start_method='fork'`
  `callback_pickler`
      Optional custom pickler that was applied to serialize callbacks in `source_descs`
code: def __init__(
      self,
      *,
      worker_id,
      start_method,
      source_descs,
      shm_chunks,
      general_task_queue,
      dedicated_task_queue,
      result_queue,
      setup_socket,
      callback_pickler,
  ):
      self.worker_id = worker_id
      self.start_method = start_method
      self.source_descs = source_descs
      self.shm_chunks = shm_chunks
      self.general_task_queue = general_task_queue
      self.dedicated_task_queue = dedicated_task_queue
      self.result_queue = result_queue
      self.setup_socket = setup_socket
      self.callback_pickler = callback_pickler
  
imports: from typing import Optional
  from nvidia.dali.types import SampleInfo
  from nvidia.dali._multiproc.struct_message import Structure
label_desc: Use image node_id 1 to create a new WorkerArgs object  with example: obj = WorkerArgs()