weblib.pwork.make_work(callback, tasks, limit, ignore_exceptions=True, taskq_size=50)[source]

Run up to “limit” processes, do tasks and yield results.

  • callback – the function that will process single task
  • tasks – the sequence or iterator or queue of tasks, each task in turn is sequence of arguments, if task is just signle argument it should be wrapped into list or tuple
  • limit – the maximum number of processes