MCPcopy Index your code
hub / github.com/apache/tvm / debug_copy_from

Method debug_copy_from

python/tvm/runtime/disco/session.py:58–75  ·  view source on GitHub ↗

Copy an Tensor value to remote for debugging purposes. Parameters ---------- worker_id : int The id of the worker to be copied to. value : Union[numpy.ndarray, Tensor] The value to be copied.

(
        self,
        worker_id: int,
        value: np.ndarray | Tensor,
    )

Source from the content-addressed store, hash-verified

56 return _ffi_api.DRefDebugGetFromRemote(self, worker_id) # type: ignore # pylint: disable=no-member
57
58 def debug_copy_from(
59 self,
60 worker_id: int,
61 value: np.ndarray | Tensor,
62 ) -> None:
63 """Copy an Tensor value to remote for debugging purposes.
64
65 Parameters
66 ----------
67 worker_id : int
68 The id of the worker to be copied to.
69
70 value : Union[numpy.ndarray, Tensor]
71 The value to be copied.
72 """
73 if not isinstance(value, Tensor):
74 value = _as_Tensor(value)
75 return _ffi_api.DRefDebugCopyFrom(self, worker_id, value) # type: ignore # pylint: disable=no-member
76
77
78class DPackedFunc(DRef):

Callers 15

test_allreduceFunction · 0.80
_compileFunction · 0.80
test_allreduceFunction · 0.80
test_group_allreduceFunction · 0.80
test_allgatherFunction · 0.80
test_group_allgatherFunction · 0.80
test_broadcastFunction · 0.80
test_group_broadcastFunction · 0.80
test_scatterFunction · 0.80
test_group_scatterFunction · 0.80

Calls

no outgoing calls

Tested by 15

test_allreduceFunction · 0.64
_compileFunction · 0.64
test_allreduceFunction · 0.64
test_group_allreduceFunction · 0.64
test_allgatherFunction · 0.64
test_group_allgatherFunction · 0.64
test_broadcastFunction · 0.64
test_group_broadcastFunction · 0.64
test_scatterFunction · 0.64
test_group_scatterFunction · 0.64