uf3.util.parallel.gather_and_merge

gather_and_merge(future_list, client=None, cancel=False, progress='bar', asynchronous=True)[source]
Parameters
  • future_list (list) – list of futures.

  • client (concurrent.futures.Executor, dask.distributed.Client) –

  • cancel (bool) – whether to cancel futures after gathering.

Returns

merged result, if datatype is supported, or list of results.

Return type

result