File tree Expand file tree Collapse file tree 1 file changed +7
-5
lines changed
x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/plugin Expand file tree Collapse file tree 1 file changed +7
-5
lines changed Original file line number Diff line number Diff line change @@ -435,11 +435,13 @@ Runnable cancelQueryOnFailure(CancellableTask task) {
435435
436436 CancellableTask createGroupTask (Task parentTask , Supplier <String > description ) throws TaskCancelledException {
437437 final TaskManager taskManager = transportService .getTaskManager ();
438- return (CancellableTask ) taskManager .register (
439- "transport" ,
440- "esql_compute_group" ,
441- new ComputeGroupTaskRequest (parentTask .taskInfo (transportService .getLocalNode ().getId (), false ).taskId (), description )
442- );
438+ try (var ignored = transportService .getThreadPool ().getThreadContext ().newTraceContext ()) {
439+ return (CancellableTask ) taskManager .register (
440+ "transport" ,
441+ "esql_compute_group" ,
442+ new ComputeGroupTaskRequest (parentTask .taskInfo (transportService .getLocalNode ().getId (), false ).taskId (), description )
443+ );
444+ }
443445 }
444446
445447 private static class ComputeGroupTaskRequest extends TransportRequest {
You can’t perform that action at this time.
0 commit comments