Method CreateTask

dali/pipeline/executor/executor2/exec_node_task.cc:572–585

// ExecNodeTask

tasking::SharedTask ExecNodeTask::CreateTask(ExecNode *node, const WorkspaceParams &params) {
  if (node->is_pipeline_output) {
    return tasking::Task::Create(
      OutputTask(node, params).GetRunnable());
  } else {
    int nout = node->outputs.size();
    // the size of outputs is limited by the compile-time operator schema
    // that uses int to represent the number of outputs
    assert(nout >= 0 && static_cast<size_t>(nout) == node->outputs.size());
    return tasking::Task::Create(
      nout,
      OpTask(node, params).GetRunnable());
  }
}

void ClearWorkspacePayload(Workspace &ws, ExecNode &node) {
  DomainTimeRange r("[Exec] ClearWokspacePayload", RangeBase::kMagenta);