Method toString

bolt/exec/Task.cpp:2499–2550

}

std::string Task::toString() const {
  std::lock_guard<std::timed_mutex> l(mutex_);
  std::stringstream out;
  out << "{Task " << shortId(taskId_) << " (" << taskId_ << ")" << std::endl;

  if (exception_) {
    out << "Error: " << errorMessageLocked() << std::endl;
  }

  if (planFragment_.planNode) {
    out << "Plan:\n"
        << planFragment_.planNode->toString(true, true) << std::endl;
  }

  size_t numRemainingDrivers{0};
  for (const auto& driver : drivers_) {
    if (driver) {
      ++numRemainingDrivers;
    }
  }

  if (numRemainingDrivers > 0) {
    bool addedCaption{false};
    for (auto& driver : drivers_) {
      if (driver) {
        if (!addedCaption) {
          out << "drivers:\n";
          addedCaption = true;
        }
        out << driver->toString() << std::endl;
      }
    }
  }

  if (!driversClosedByTask_.empty()) {
    bool addedCaption{false};
    for (auto& driver : driversClosedByTask_) {
      auto zombieDriver = driver.lock();
      if (zombieDriver) {
        if (!addedCaption) {
          out << "zombie drivers:\n";
          addedCaption = true;
        }
        out << zombieDriver->toString()
            << ", refcount: " << zombieDriver.use_count() - 1 << std::endl;
      }
    }
  }

  out << "}";
  return out.str();
}

folly::dynamic Task::toShortJsonLocked() const {
  folly::dynamic obj = folly::dynamic::object;