pyphi.parallel.sampling.WorkloadPlan

class pyphi.parallel.sampling.WorkloadPlan(chunksize, sequential_threshold, items, more_items, reducer)

Bases: object

A cost-sampled workload, ready for chunked dispatch.

items and more_items are the columns still to be computed; reducer folds any reused sampled results into the reduction.

Parameters:

• chunksize (int)

• sequential_threshold (int)

• items (list[Any])

• more_items (tuple[list[Any], ...])

• reducer (Callable[[Iterable[Any]], Any])