data_loader = grain.DataLoader(
    data_source=source,
    sampler=sampler,
    operations=operations,
    worker_count=8,   # Parallel, using multiprocessing
)

        __
        __