/usr/local/lib64/python3.6/site-packages/torch/distributed/pipeline/sync
NameSizeModeActions
skip/-0755rm
_balance/-0755rm
__pycache__/-0755rm
batchnorm.py56030644editdlrm
checkpoint.py114640644editdlrm
copy.py37160644editdlrm
dependency.py16940644editdlrm
microbatch.py74270644editdlrm
phony.py15360644editdlrm
pipe.py178830644editdlrm
pipeline.py96380644editdlrm
stream.py38070644editdlrm
utils.py11470644editdlrm
worker.py42840644editdlrm
__init__.py4510644editdlrm
Edit: /usr/local/lib64/python3.6/site-packages/torch/distributed/pipeline/sync/phony.py (1536B)
# Copyright 2019 Kakao Brain # # Copyright (c) Facebook, Inc. and its affiliates. All rights reserved. # # This source code is licensed under the BSD license found in the # LICENSE file in the root directory of this source tree. """Provides phony for arbitrary dependency in a autograd graph.""" from typing import Dict, List, Tuple import torch from torch import Tensor from .stream import default_stream, use_stream __all__: List[str] = [] _phonies: Dict[Tuple[torch.device, bool], Tensor] = {} def get_phony(device: torch.device, *, requires_grad: bool) -> Tensor: """Gets a phony. Phony is tensor without space. It is useful to make arbitrary dependency in a autograd graph because it doesn't require any gradient accumulation. .. note:: Phonies for each device are cached. If an autograd function gets a phony internally, the phony must be detached to be returned. Otherwise, the autograd engine will mutate the cached phony in-place:: class Phonify(torch.autograd.Function): @staticmethod def forward(ctx, input): phony = get_phony(input.device, requires_grad=False) return phony.detach() # detach() is necessary. """ key = (device, requires_grad) try: phony = _phonies[key] except KeyError: with use_stream(default_stream(device)): phony = torch.empty(0, device=device, requires_grad=requires_grad) _phonies[key] = phony return phony