code: def create_dict(futures):
      w_to_p_map = collections.OrderedDict()
      for w, k, p in futures:
          if w not in w_to_p_map:
              w_to_p_map[w] = []
          w_to_p_map[w].append([p, k])
      return w_to_p_map
  
imports: import numpy
  from dask.distributed import futures_of, default_client, wait
  from toolz import first
  import collections
  import dask_cudf
  from dask.array.core import Array
  from dask_cudf.core import DataFrame
  from dask_cudf.core import Series
  from functools import reduce
  import cugraph.dask.comms.comms
  from dask.delayed import delayed
  import cudf
label_desc: Use image node_id 10 for calling a global function with example usage: create_dict(futures) and returns: w_to_p_map