Method Run

dali/pipeline/executor/executor2/exec_node_task.cc:148–174

};

OpTask::OpTaskOutputs OpTask::Run() {
  InitMeta();

  // We cannot use DomainTimeRange, because it would outlive workspace_scope - we can use `optional`
  // to shorten the life of the range.
  std::optional<DomainTimeRange> ws_init_tr;
  ws_init_tr.emplace(meta_->nvtx.init_ws_range_name);
  auto workspace_scope = GetWorkspace();

  // SetWorkspaceInputs must not go into the try/catch because it rethrows errors
  // from the inputs and we don't want them to be wrapped again as this operator's error.
  SetWorkspaceInputs();

  ws_init_tr.reset();  // the range ends here

  try {
    SetupOp();
    RunOp();
    auto &&ret = GetWorkspaceOutputs();
    return ret;
  } catch (...) {
    PropagateError({
      std::current_exception(),
      "Critical error in pipeline:\n" + GetErrorContextMessage(node_->op->GetSpec()),
      "\nCurrent pipeline object is no longer valid."});
  }
}

bool OpTask::ShouldSkip() const {
  int ninp_reg = ws_->NumInput();