Method taskCompletionFuture

bolt/exec/Task.cpp:2485–2497

}

ContinueFuture Task::taskCompletionFuture() {
  std::lock_guard<std::timed_mutex> l(mutex_);
  // If 'this' is running, the future is realized on timeout or when
  // this no longer is running.
  if (not isRunningLocked()) {
    return makeFinishFutureLocked(
        fmt::format("Task::taskCompletionFuture {}", taskId_).data());
  }
  auto [promise, future] = makeBoltContinuePromiseContract(
      fmt::format("Task::taskCompletionFuture {}", taskId_));
  taskCompletionPromises_.emplace_back(std::move(promise));
  return std::move(future);
}

std::string Task::toString() const {
  std::lock_guard<std::timed_mutex> l(mutex_);