Method toString

bolt/exec/Driver.cpp:1082–1120

}

std::string Driver::toString() const {
  std::stringstream out;
  out << "{Driver." << driverCtx()->pipelineId << "." << driverCtx()->driverId
      << ": ";
  if (state_.isTerminated) {
    out << "terminated, ";
  }
  if (state_.hasBlockingFuture) {
    std::string blockedOp = (blockedOperatorId_ < operators_.size())
        ? operators_[blockedOperatorId_]->toString()
        : "<unknown op>";
    out << "blocked (" << blockingReasonToString(blockingReason_) << " "
        << blockedOp << "), ";
  } else if (state_.isEnqueued) {
    out << "enqueued ";
  } else if (state_.isOnThread()) {
    out << "running ";
  } else {
    out << "unknown state";
  }

  out << "{Operators: ";
  std::vector<std::string> opStrs;
  opStrs.reserve(operators_.size());
  std::ranges::transform(
      operators_, std::back_inserter(opStrs), [](const auto& op) {
        return op->toString();
      });
  out << folly::join(", ", opStrs);
  out << "}";
  const auto ocs = opCallStatus();
  if (!ocs.empty()) {
    out << "{OpCallStatus: executing "
        << ocs.formatCall(findOperatorNoThrow(ocs.opId), ocs.method) << " for "
        << ocs.callDuration() << "ms}";
  }
  out << "}";
  return out.str();
}

folly::dynamic Driver::toJson() const {
  folly::dynamic obj = folly::dynamic::object;