docstr: Set number of threads for each of the processing steps.
  
  Args:
      parallelism (Dict): New number of threads per processing step
  
  Returns:
      None
docstr_tok: ["Set","number","of","threads","for","each","of","the","processing","steps",".","Args",":","parallelism","(","Dict",")",":","New","number","of","threads","per","processing","step","Returns",":","None"]
code: def parallelism(self, parallelism: Dict):
      """Set number of threads for each of the processing steps.
  
      Args:
          parallelism (Dict): New number of threads per processing step
  
      Returns:
          None
      """
      assert all(k in HANDLER_METHODS for k in parallelism.keys())
  
      self._parallelism.update(parallelism)
      self._update_threads()
  
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 4 for calling the MicroBatching obj's underlying member method code with example usage: obj.parallelism(parallelism) without return types