original_docstring: 
      Trigger all to all communication between workers and scheduler
      
docstring: Trigger all to all communication between workers and scheduler
docstring_tokens: Trigger all to all communication between workers and scheduler
code: async def _all_to_all(client):
      """
      Trigger all to all communication between workers and scheduler
      """
      workers = list(client.scheduler_info()["workers"])
      futs = []
      for w in workers:
          bit_of_data = b"0" * 1
          data = client.map(lambda x: bit_of_data, range(1), pure=False, workers=[w])
          futs.append(data[0])
  
      await wait(futs)
  
      def f(x):
          pass
  
      new_futs = []
      for w in workers:
          for future in futs:
              data = client.submit(f, future, workers=[w], pure=False)
              new_futs.append(data)
  
      await wait(new_futs)
code_tokens: async def _all_to_all ( client ) : workers = list ( client . scheduler_info ( ) [ "workers" ] ) futs = [ ] for w in workers : bit_of_data = b"0" * 1 data = client . map ( lambda x : bit_of_data , range ( 1 ) , pure = False , workers = [ w ] ) futs . append ( data [ 0 ] ) await wait ( futs ) def f ( x ) : pass new_futs = [ ] for w in workers : for future in futs : data = client . submit ( f , future , workers = [ w ] , pure = False ) new_futs . append ( data ) await wait ( new_futs )
short_docstring: Trigger all to all communication between workers and scheduler
short_docstring_tokens: Trigger all to all communication between workers and scheduler
comment: """
      Trigger all to all communication between workers and scheduler
      """