You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
{{ message }}
Repository navigation
PyTests for distributed workflows for PyTorch #199
train_dataloader = DataLoader(
train_dataset, # type: ignore[reportArgumentType] --> Torch datasets do not have a len method, but still works.
batch_size=batch_size,
num_workers=num_workers,
sampler=train_sampler,
shuffle=shuffle,
pin_memory=pin_mem,
drop_last=True,
persistent_workers=persist,
multiprocessing_context="spawn" # PROBLEM Here
)
Without passing this potentially get errors like this:
This is slightly confusing since it presents itself as a nccl error, but passing a multiprocessing_context onto the Dataloader seems to resolve this issue.
Proposed Solution
We probably have to write some PyTests to test compatibility of DDP workflows on HPC clusters. This is slightly annoying to test since we would have to run the PyTests on NERSC on an interactive job. Not quite sure what the best things to do for PyTests in this case, but will give some more thought on it and open a PR at some point.
Activity