diff --git a/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/plugin/ComputeService.java b/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/plugin/ComputeService.java index d8d7913473251..cf077002eec13 100644 --- a/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/plugin/ComputeService.java +++ b/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/plugin/ComputeService.java @@ -433,11 +433,13 @@ Runnable cancelQueryOnFailure(CancellableTask task) { CancellableTask createGroupTask(Task parentTask, Supplier description) throws TaskCancelledException { final TaskManager taskManager = transportService.getTaskManager(); - return (CancellableTask) taskManager.register( - "transport", - "esql_compute_group", - new ComputeGroupTaskRequest(parentTask.taskInfo(transportService.getLocalNode().getId(), false).taskId(), description) - ); + try (var ignored = transportService.getThreadPool().getThreadContext().newTraceContext()) { + return (CancellableTask) taskManager.register( + "transport", + "esql_compute_group", + new ComputeGroupTaskRequest(parentTask.taskInfo(transportService.getLocalNode().getId(), false).taskId(), description) + ); + } } private static class ComputeGroupTaskRequest extends TransportRequest {