elphick.mass_composition.utils.parallel.TqdmParallel

class elphick.mass_composition.utils.parallel.TqdmParallel(*args, **kwargs)[source]
__init__(*args, **kwargs)[source]
Parameters:
  • depth (int, optional) – The depth of objects printed.

  • name (str, optional) – The namespace to log to. If None, defaults to joblib.

Methods

__init__(*args, **kwargs)

param depth:

The depth of objects printed.

debug(msg)

dispatch_next()

Dispatch more data for parallel processing

dispatch_one_batch(iterator)

Prefetch the tasks for the next batch and dispatch them.

format(obj[, indent])

Return the formatted representation of the object.

info(msg)

print_progress()

Display the process of the parallel execution only a fraction of time, controlled by self.verbose.

warn(msg)

print_progress()[source]

Display the process of the parallel execution only a fraction of time, controlled by self.verbose.