code: def start_worker(self, target):
      if self.opt.sp:
          p = Thread(target=target, args=())
      else:
          p = mp.Process(target=target, args=())
      # p.daemon = True
      p.start()
      return p
  
imports: import os
  import time
  from queue import Queue
  from threading import Thread
  import cv2
  import numpy
  import torch
  import torch.multiprocessing
  from alphapose.utils.pPose_nms import pose_nms, write_json
  from alphapose.utils.transforms import get_func_heatmap_to_coord
  import norfair
label_desc: Use image node_id 2 for calling the DataWriter obj's underlying member method code with example usage: obj.start_worker(target) and returns: p