p60975123
/
mindspore
forked from mindspore-Ecosystem/mindspore
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

!32296 Fix correction issue of parameter on device side 

Merge pull request !32296 from ZPaC/sync-bug-fix-for-new-ps
This commit is contained in:
i-robot 2022-03-31 10:43:05 +00:00 committed by Gitee
parent 4de5f45663 a326b26580
commit 39de9aa01d
No known key found for this signature in database
GPG Key ID: 173E9B9CA92EEF8F
1 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
mindspore/ccsrc/frontend/parallel/graph_util/graph_splitter.cc
View File

@ -164,6 +164,7 @@ CNodePtr CreateRecvNode(const FuncGraphPtr &func_graph, const InterProcessOpEdge
MS_LOG(EXCEPTION) << "The src_node is PrimUpdateState must have monad abstract.";
}
auto monad_input = NewValueNode(monad_value);
MS_EXCEPTION_IF_NULL(monad_input);
monad_input->set_abstract(monad_value->ToAbstract());
recv_inputs.push_back(monad_input);
recv_node_abs = src_node->abstract();
@ -175,6 +176,15 @@ CNodePtr CreateRecvNode(const FuncGraphPtr &func_graph, const InterProcessOpEdge
common::AnfAlgo::VisitKernel(common::AnfAlgo::GetInputNode(src_node->cast<CNodePtr>(), parameter_index), 0);
auto param_node = kernel_with_index.first;
recv_inputs.push_back(param_node);
// To update the parameter on the device side in heterogeneous case, side-effect node should be added to recv's
// input.
ValuePtr monad_value = kUMonad;
auto monad_input = NewValueNode(monad_value);
MS_EXCEPTION_IF_NULL(monad_input);
monad_input->set_abstract(monad_value->ToAbstract());
recv_inputs.push_back(monad_input);
recv_node_abs = param_node->abstract();
} else {
auto mock_value = CreateFakeValueNode(true, src_node);