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,
)
| 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 | |
| 78 | class DPackedFunc(DRef): |
no outgoing calls