code: def run(self):
      if (
          not self.future.set_running_or_notify_cancel()
      ):  # pragma: no cover
          return
  
      try:
          result = self.fn(*self.args, **self.kwargs)
      except BaseException as e:
          self.future.set_exception(e)
      else:
          self.future.set_result(result)
  
file_path: distributed/distributed/_concurrent_futures_thread.py
imports: from __future__ import annotations
  import atexit
  import itertools
  import os
  import queue
  import threading
  import weakref
  from concurrent.futures import _base
label_desc: Use image node_id 2 for calling the _WorkItem obj's underlying member method code with example usage: obj.run() without return types