code: def run(self):
      while True:
          func, args, result_queue = self.task_queue.get()
          if func is None:
              break
          try:
              result = func(*args)
          except:
              result = ExceptionInfo()
          result_queue.put((result, args))
  
imports: import os
  import sys
  import glob
  import argparse
  import threading
  import six.moves.queue
  import traceback
  import numpy
  import tensorflow
  import PIL.Image
  import dnnlib.tflib
  from training import dataset
label_desc: Use image node_id 2 for calling the WorkerThread obj's underlying member method code with example usage: obj.run() without return types