code: def submit_comp_job(self, path, callback, method, *args, **kwargs):
          
          if self.executor is None:
              with self.handling_exceptions():
                  callback(getattr(self.comp, method)(*args, **kwargs))
          else:
              path = showpath(path)
              with logger.in_path(path):  # pickle the compiler in the path context
                  future = self.executor.submit(multiprocess_wrapper(self.comp, method), *args, **kwargs)
  
              def callback_wrapper(completed_future):
                  """Ensures that all errors are always caught, since errors raised in a callback won't be propagated."""
                  with logger.in_path(path):  # handle errors in the path context
                      with self.handling_exceptions():
                          result = completed_future.result()
                          callback(result)
              future.add_done_callback(callback_wrapper)
docs: Submits a job on self.comp to be run in parallel.