(sess: di.Session, remote_array, shape, dtype)
| 143 | |
| 144 | |
| 145 | def _numpy_from_worker_0(sess: di.Session, remote_array, shape, dtype): |
| 146 | host_array = tvm.runtime.empty(shape, dtype, device=tvm.cpu()) |
| 147 | sess.copy_from_worker_0(host_array, remote_array) |
| 148 | sess.sync_worker_0() |
| 149 | return host_array.numpy() |
| 150 | |
| 151 | |
| 152 | _all_session_kinds = [di.ThreadedSession, di.ProcessSession, create_socket_session] |
no test coverage detected
searching dependent graphs…