uf3.util.parallelΒΆ

This module provides functions for splitting/merging collections, handling parallel tasks, and managing progress indicators.

Functions

batch_submit

param func

function to call using client.

gather_and_merge

param future_list

list of futures.

progress_iter

select_wait_function

split_dataframe

Split dataframe using np.array_split.

split_zip

General splitting function for one or more list-like objects.

wait_progress

Visualize progress while waiting for futures to complete.

Classes

ProgressText

Makeshift progress counter.