Function DEBUG_ONLY_TEST_F

bolt/exec/tests/DriverTest.cpp:1075–1192

                  .values({rows}, true)
                  .addNode([](std::string id, core::PlanNodePtr input) {
                    return std::make_shared<ThrowNode>(
                        id, ThrowNode::OperatorMethod::kAddInput, input);
                  })
                  .planNode();
  CursorParameters params;
  params.planNode = plan;
  params.maxDrivers = 5;
  auto cursor = TaskCursor::create(params);
  auto task = cursor->task();
  // Ensure execution threw correct error.
  BOLT_ASSERT_THROW(cursor->moveNext(), "Too many drivers");
  EXPECT_EQ(TaskState::kFailed, task->state());
}

TEST_F(DriverTest, nonBoltOperatorException) {
  Operator::registerOperator(
      std::make_unique<ThrowNodeFactory>(std::numeric_limits<uint32_t>::max()));

  auto rows = makeRowVector({makeFlatVector<int32_t>({1, 2, 3})});

  auto makePlan = [&](ThrowNode::OperatorMethod throwingMethod) {
    return PlanBuilder()
        .values({rows}, true)
        .addNode([throwingMethod](std::string id, core::PlanNodePtr input) {
          return std::make_shared<ThrowNode>(id, throwingMethod, input);
        })
        .planNode();
  };

  BOLT_ASSERT_THROW(
      AssertQueryBuilder(makePlan(ThrowNode::OperatorMethod::kIsBlocked))
          .copyResults(pool()),
      "Operator::isBlocked failed for [operator: Throw, plan node ID: 1]");

  BOLT_ASSERT_THROW(
      AssertQueryBuilder(makePlan(ThrowNode::OperatorMethod::kNeedsInput))
          .copyResults(pool()),
      "Operator::needsInput failed for [operator: Throw, plan node ID: 1]");

  BOLT_ASSERT_THROW(
      AssertQueryBuilder(makePlan(ThrowNode::OperatorMethod::kAddInput))
          .copyResults(pool()),
      "Operator::addInput failed for [operator: Throw, plan node ID: 1]");

  BOLT_ASSERT_THROW(
      AssertQueryBuilder(makePlan(ThrowNode::OperatorMethod::kNoMoreInput))
          .copyResults(pool()),
      "Operator::noMoreInput failed for [operator: Throw, plan node ID: 1]");

  BOLT_ASSERT_THROW(
      AssertQueryBuilder(makePlan(ThrowNode::OperatorMethod::kGetOutput))
          .copyResults(pool()),
      "Operator::getOutput failed for [operator: Throw, plan node ID: 1]");
}

DEBUG_ONLY_TEST_F(DriverTest, driverSuspensionRaceWithTaskPause) {
  struct {
    int numDrivers;