integrator.distributed_mp module

integrator.distributed_mp.worker_scan(ai_config, dataset, out_dir, stack_size=200, target_device=None)

integrator.distributed_mp.process_datasets(ai_config, datasets, output_files, n_workers=4)