data_loader = grain.DataLoader(
    data_source=source,
    sampler=sampler,
    operations=operations,
    worker_count=0,
    read_options=grain.ReadOptions(num_threads=0),
)

        __
        __