python/ray/experimental/dag/py_obj_scanner.py
def replace_nodes(self, table: Dict["DAGNode", T]) -> Any:
        """Replace previously found DAGNodes per the given table."""
        assert self._found is not None, "find_nodes must be called first"
        self._replace_table = table
        self._buf.seek(0)
        return pickle.load(self._buf)
Replace previously found DAGNodes per the given table.
Replace previously found DAGNodes per the given table.
Replace previously found DAGNodes per the given table .
def replace_nodes(self, table: Dict["DAGNode", T]) -> Any:
        assert self._found is not None, "find_nodes must be called first"
        self._replace_table = table
        self._buf.seek(0)
        return pickle.load(self._buf)
def replace_nodes ( self , table : Dict [ "DAGNode" , T ] ) -> Any : assert self . _found is not None , "find_nodes must be called first" self . _replace_table = table self . _buf . seek ( 0 ) return pickle . load ( self . _buf )
Replace previously found DAGNodes per the given table.
Replace previously found DAGNodes per the given table .
"""Replace previously found DAGNodes per the given table."""
self
table
Dict["DAGNode", T]