Skip to content

Commit ed76cbe

Browse files
author
Rafał Hibner
committed
Restore test
1 parent a1c896f commit ed76cbe

1 file changed

Lines changed: 3 additions & 0 deletions

File tree

cpp/src/arrow/acero/util_test.cc

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -297,6 +297,9 @@ TEST(BackpressureConcurrentQueue, BackpressureTest) {
297297
queue.Push(11);
298298
ASSERT_TRUE(dummy_node.paused);
299299
ASSERT_FALSE(dummy_node.stopped);
300+
queue.ForceShutdown();
301+
ASSERT_FALSE(dummy_node.paused);
302+
ASSERT_TRUE(dummy_node.stopped);
300303
}
301304

302305
} // namespace acero

0 commit comments

Comments
 (0)