MCPcopy Create free account
hub / github.com/Oneflow-Inc/oneflow / send

Function send

python/oneflow/distributed/__init__.py:66–73  ·  view source on GitHub ↗

Alias of `oneflow.comm.send()` for PyTorch compatibility. See also :func:`oneflow.comm.send()`

(tensor: flow.Tensor, dst: int, group=None, tag: int = 0)

Source from the content-addressed store, hash-verified

64
65
66def send(tensor: flow.Tensor, dst: int, group=None, tag: int = 0) -> None:
67 """Alias of `oneflow.comm.send()` for PyTorch compatibility.
68
69 See also :func:`oneflow.comm.send()`
70 """
71 assert group is None, "group is not supported yet"
72 assert tag == 0, "tag is not supported yet"
73 return flow.comm.send(tensor, dst)
74
75
76def recv(tensor: flow.Tensor, src: int, group=None, tag: int = 0) -> None:

Callers

nothing calls this directly

Calls 1

sendMethod · 0.80

Tested by

no test coverage detected