utils.async module

class utils.async.ResultsPool(*args, **kwargs)[source]

Bases: multiprocessing.pool.Pool

multiprocessing.Pool boilerplate wrapper

  • Stores results on a results property
  • Task result successes are aggregated by the sucessful property
apply_async(*args, **kwargs)[source]
map_async(*args, **kwargs)[source]
successful[source]