fix comments

Author: idegtiarenko

x-pack/plugin/esql/compute/src/test/java/org/elasticsearch/compute/operator/exchange/ExchangeServiceTests.java

@@ -37,7 +37,6 @@
 import org.elasticsearch.compute.operator.SinkOperator;
 import org.elasticsearch.compute.operator.SourceOperator;
 import org.elasticsearch.compute.test.MockBlockFactory;
-import org.elasticsearch.compute.test.TestDriverFactory;
 import org.elasticsearch.core.ReleasableRef;
 import org.elasticsearch.core.TimeValue;
 import org.elasticsearch.tasks.Task;
@@ -301,15 +300,25 @@ Set<Integer> runConcurrentTest(
         int numSources = randomIntBetween(1, 8);
         List<Driver> drivers = new ArrayList<>(numSinks + numSources);
         for (int i = 0; i < numSinks; i++) {
-            ExchangeSinkOperator sinkOperator = new ExchangeSinkOperator(exchangeSink.get(), Function.identity());
             DriverContext dc = driverContext();
-            Driver d = TestDriverFactory.create(dc, seqNoGenerator.get(dc), List.of(), sinkOperator, () -> {});
+            Driver d = createDriver(
+                "test-session:1",
+                "sink-" + i,
+                dc,
+                seqNoGenerator.get(dc),
+                new ExchangeSinkOperator(exchangeSink.get(), Function.identity())
+            );
             drivers.add(d);
         }
         for (int i = 0; i < numSources; i++) {
-            ExchangeSourceOperator sourceOperator = new ExchangeSourceOperator(exchangeSource.get());
             DriverContext dc = driverContext();
-            Driver d = TestDriverFactory.create(dc, sourceOperator, List.of(), seqNoCollector.get(dc));
+            Driver d = createDriver(
+                "test-session:2",
+                "source-" + i,
+                dc,
+                new ExchangeSourceOperator(exchangeSource.get()),
+                seqNoCollector.get(dc)
+            );
             drivers.add(d);
         }
         PlainActionFuture<Void> future = new PlainActionFuture<>();
@@ -323,6 +332,28 @@ protected void start(Driver driver, ActionListener<Void> listener) {
         return seqNoCollector.receivedSeqNos;
     }
 
+    private static Driver createDriver(
+        String sessionId,
+        String description,
+        DriverContext dc,
+        SourceOperator sourceOperator,
+        SinkOperator sinkOperator
+    ) {
+        return new Driver(
+            sessionId,
+            "test",
+            0,
+            0,
+            dc,
+            () -> description,
+            sourceOperator,
+            List.of(),
+            sinkOperator,
+            Driver.DEFAULT_STATUS_INTERVAL,
+            () -> {}
+        );
+    }
+
     public void testConcurrentWithHandlers() {
         BlockFactory blockFactory = blockFactory();
         var sourceExchanger = new ExchangeSourceHandler(randomExchangeBuffer(), threadPool.executor(ESQL_TEST_EXECUTOR));

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

@@ -40,7 +40,7 @@ public static Driver create(
     ) {
         return new Driver(
             "unset",
-            "test-description",
+            "test-task",
             System.currentTimeMillis(),
             System.nanoTime(),
             driverContext,