monarch_tensor_worker::py_pipe

Function run_py_pipe

Source 
pub fn run_py_pipe(
    pipe: PyPipe,
    func: ResolvableFunction,
    args: Vec<PyTree<RValue>>,
    kwargs: HashMap<String, PyTree<RValue>>,
) -> PyResult<()>
Expand description

Run a Python pipe server, which loads a remote function sent over the pipe then delegates to it.