| 468 | expectWithDelay([&]() { return test; }, __FILE__, __LINE__, #test) |
| 469 | |
| 470 | #ifndef SPARK_COMPATIBLE |
| 471 | TEST_F(DriverTest, error) { |
| 472 | CursorParameters params; |
| 473 | params.planNode = |
| 474 | makeValuesFilterProject(rowType_, "m1 % 0 > 0", "", 100, 10); |
| 475 | params.maxDrivers = 20; |
| 476 | int32_t numRead = 0; |
| 477 | try { |
| 478 | readResults(params, ResultOperation::kRead, 1'000'000, &numRead); |
| 479 | EXPECT_TRUE(false) << "Expected exception"; |
| 480 | } catch (const BoltException& e) { |
| 481 | EXPECT_NE(e.message().find("Cannot divide by 0"), std::string::npos); |
| 482 | } |
| 483 | EXPECT_EQ(numRead, 0); |
| 484 | EXPECT_TRUE(stateFutures_.at(0).isReady()); |
| 485 | // Realized immediately since task not running. |
| 486 | EXPECT_TRUE(tasks_[0] |
| 487 | ->taskCompletionFuture() |
| 488 | .within(std::chrono::microseconds(1'000'000)) |
| 489 | .isReady()); |
| 490 | EXPECT_EQ(tasks_[0]->state(), TaskState::kFailed); |
| 491 | } |
| 492 | #endif |
| 493 |
nothing calls this directly
no test coverage detected