mirror of
https://github.com/zebrajr/pytorch.git
synced 2025-12-06 12:20:52 +01:00
e2a3817dfd
Apparently https://github.com/pytorch/pytorch/pull/78142 made torch.JIT allow for simple generator expressions which allows us to enable rules that replace unnecessary list comprehensions with generators in any/all. This was originally part of #99280 but I split it off into this PR so that it can be easily reverted should anything break. Pull Request resolved: https://github.com/pytorch/pytorch/pull/99890 Approved by: https://github.com/justinchuby, https://github.com/kit1980, https://github.com/malfet
43 lines
2.4 KiB
Python
43 lines
2.4 KiB
Python
from collections import defaultdict
|
|
from typing import List, Dict, Tuple, Optional, Union
|
|
|
|
import torch
|
|
from torch import Tensor
|
|
from torch.autograd.grad_mode import no_grad
|
|
|
|
|
|
# This util function splits tensors into groups by device and dtype, which is useful before sending
|
|
# tensors off to a foreach implementation, which requires tensors to be on one device and dtype.
|
|
# If tensorlistlist contains more than one tensorlist, the following assumptions are made BUT NOT verified:
|
|
# - tensorlists CAN be None
|
|
# - all tensors in the first specified list cannot be None
|
|
# - given an index i, all specified tensorlist[i]s match in dtype and device
|
|
# with_indices (bool, optional): whether to track previous indices as the last list per dictionary entry.
|
|
# It comes in handy if there are Nones or literals in the tensorlists that are getting scattered out.
|
|
# Whereas mutating a tensor in the resulting split-up tensorlists WILL propagate changes back to the
|
|
# original input tensorlists, changing up Nones/literals WILL NOT propagate, and manual propagation
|
|
# may be necessary. Check out torch/optim/sgd.py for an example.
|
|
@no_grad()
|
|
def _group_tensors_by_device_and_dtype(tensorlistlist: List[List[Tensor]],
|
|
with_indices: Optional[bool] = False) -> \
|
|
Dict[Tuple[torch.device, torch.dtype], List[List[Union[Tensor, int]]]]:
|
|
assert all(not x or len(x) == len(tensorlistlist[0]) for x in tensorlistlist), (
|
|
"all specified tensorlists must match in length")
|
|
per_device_and_dtype_tensors: Dict[Tuple[torch.device, torch.dtype], List[List[Union[Tensor, int]]]] = defaultdict(
|
|
lambda: [[] for _ in range(len(tensorlistlist) + (1 if with_indices else 0))])
|
|
for i, t in enumerate(tensorlistlist[0]):
|
|
key = (t.device, t.dtype)
|
|
for j in range(len(tensorlistlist)):
|
|
# a tensorlist may be empty/None
|
|
if tensorlistlist[j]:
|
|
per_device_and_dtype_tensors[key][j].append(tensorlistlist[j][i])
|
|
if with_indices:
|
|
# tack on previous index
|
|
per_device_and_dtype_tensors[key][j + 1].append(i)
|
|
return per_device_and_dtype_tensors
|
|
|
|
def _has_foreach_support(tensors: List[Tensor], device: torch.device) -> bool:
|
|
if device.type not in ['cpu', 'cuda'] or torch.jit.is_scripting():
|
|
return False
|
|
return all(t is None or type(t) == torch.Tensor for t in tensors)
|