code: def _create_queues(self):
      # Set up processing queues
      self.queues[HANDLER_METHODS[0] + "_in"] = queue.Queue()
      for i in range(len(HANDLER_METHODS) - 1):
          # Each "out" queue is the "in" queue of the next processing step
          self.queues[HANDLER_METHODS[i] + "_out"] = queue.Queue()
          self.queues[HANDLER_METHODS[i + 1] + "_in"] = self.queues[
              HANDLER_METHODS[i] + "_out"
          ]
      self.queues[HANDLER_METHODS[-1] + "_out"] = queue.Queue()
  
imports: import os
  import queue
  import threading
  import time
  from copy import copy
  from dataclasses import dataclass
  from typing import Dict
label_desc: Use image node_id 6 for calling the MicroBatching obj's underlying member method code with example usage: obj._create_queues() without return types