MCPcopy Create free account
hub / github.com/Oneflow-Inc/oneflow / update_new_task_id

Method update_new_task_id

oneflow/core/graph/task_node.cpp:396–401  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

394}
395
396void TaskNode::update_new_task_id(const TaskId& task_id) {
397 CHECK(static_cast<bool>(new_task_id_));
398 CHECK(new_task_id_->stream_id() == task_id.stream_id());
399 *new_task_id_ = task_id;
400 task_id_ = EncodeTaskIdToInt64(*new_task_id_);
401}
402
403void TaskNode::EraseConsumedRegstsByName(const std::string& name) {
404 if (consumed_regsts_.find(name) != consumed_regsts_.end()) {

Calls 1

EncodeTaskIdToInt64Function · 0.85

Tested by

no test coverage detected