Skip to content

Commit 4364f9f

Browse files
committed
fix
1 parent b7b63d3 commit 4364f9f

File tree

3 files changed

+8
-15
lines changed

3 files changed

+8
-15
lines changed

x-pack/plugin/esql/compute/src/test/java/org/elasticsearch/compute/aggregation/SumFloatAggregatorFunctionTests.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -98,7 +98,7 @@ public void testSummationAccuracy() {
9898
}
9999
driverContext = driverContext();
100100
try (
101-
Driver d = TestDriver(
101+
Driver d = TestDriverFactory.create(
102102
driverContext,
103103
new SequenceFloatBlockSourceOperator(driverContext.blockFactory(), Stream.of(values)),
104104
List.of(simple().get(driverContext)),

x-pack/plugin/esql/compute/src/test/java/org/elasticsearch/compute/lucene/ValueSourceReaderTypeConversionTests.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1495,7 +1495,12 @@ protected final List<Page> drive(List<Operator> operators, Iterator<Page> input,
14951495
List<Page> results = new ArrayList<>();
14961496
boolean success = false;
14971497
try (
1498-
Driver d = TestDriver(driverContext, new CannedSourceOperator(input), operators, new TestResultPageSinkOperator(results::add))
1498+
Driver d = TestDriverFactory.create(
1499+
driverContext,
1500+
new CannedSourceOperator(input),
1501+
operators,
1502+
new TestResultPageSinkOperator(results::add)
1503+
)
14991504
) {
15001505
runDriver(d);
15011506
success = true;

x-pack/plugin/esql/compute/test/src/main/java/org/elasticsearch/compute/test/TestDriverFactory.java

Lines changed: 1 addition & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -28,19 +28,7 @@ public static Driver create(
2828
List<Operator> intermediateOperators,
2929
SinkOperator sink
3030
) {
31-
return new Driver(
32-
"unset",
33-
"test-description",
34-
System.currentTimeMillis(),
35-
System.nanoTime(),
36-
driverContext,
37-
() -> null,
38-
source,
39-
intermediateOperators,
40-
sink,
41-
Driver.DEFAULT_STATUS_INTERVAL,
42-
() -> {}
43-
);
31+
return create(driverContext, source, intermediateOperators, sink, () -> {});
4432
}
4533

4634
public static Driver create(

0 commit comments

Comments
 (0)