code: def run(self) -> Dict[WorkOrder, WorkerOutput]:
      try:
          return self._run()
  
      except KeyboardInterrupt:
          print(
              "\n\nKeyboardInterrupt (ctrl-c) detected. Shutting down children."
          )
          self._force_shutdown(verbose=False)
          raise
  
      except subprocess.TimeoutExpired:
          print("\n\nJob timed out. Shutting down children.")
          self._force_shutdown(verbose=True)
          raise
  
      except WorkerFailed as e:
          print("Shutting down all outstanding jobs before re-raising.")
          self._force_shutdown(verbose=True)
          print(f"Cmd: {e.cmd}")
          if e.wrapped_trace:
              print(e.wrapped_trace)
          else:
              print(
                  "Unknown failure. (Worker did not report exception contents.)"
              )
          raise
  
      except BaseException:
          print(
              "\n\nUnknown exception. Shutting down jobs before re-raising."
          )
          self._force_shutdown(verbose=True)
          raise
  
imports: import math
  import multiprocessing
  import subprocess
  import textwrap
  import threading
  import time
  from typing import Dict, List, Optional, Set, Tuple, Union
  from worker.main import WorkerFailure, WorkerOutput
  from execution.work import InProgress, PYTHON_CMD, SHELL, WorkOrder
label_desc: Use image node_id 2 for calling the Runner obj's underlying member method code with example usage: obj.run() and returns: self