docstr: Tell the client to cancel any task submitted via this instance
  
  joblib.Parallel will never access those results
docstr_tok: ["Tell","the","client","to","cancel","any","task","submitted","via","this","instance","joblib.Parallel","will","never","access","those","results"]
code: def abort_everything(self, ensure_ready=True):
      """Tell the client to cancel any task submitted via this instance
  
      joblib.Parallel will never access those results
      """
      with self.waiting_futures.lock:
          self.waiting_futures.futures.clear()
          while not self.waiting_futures.queue.empty():
              self.waiting_futures.queue.get()
  
imports: from __future__ import print_function, division, absolute_import
  import asyncio
  import concurrent.futures
  import contextlib
  import time
  from uuid import uuid4
  import weakref
  from .parallel import parallel_config
  from .parallel import AutoBatchingMixin, ParallelBackendBase
label_desc: Use image node_id 9 for calling the DaskDistributedBackend obj's underlying member method code with example usage: obj.abort_everything(ensure_ready) without return types