code: def run_worker(coordinator, worker):
      while coordinator.is_active():
          worker.start()
          try:
              worker.run()
          except Exception as e:
              worker.handle_exception(e)
          finally:
              worker.finish()
  
imports: import logging
  import threading
  import atexit
  import time
  import collections
  import traceback
  from abc import ABCMeta, abstractmethod
label_desc: Use image node_id 2 for calling a global function with example usage: run_worker(coordinator, worker) without return types