diff --git a/x-pack/plugin/ql/src/main/java/org/elasticsearch/xpack/ql/async/AsyncTaskManagementService.java b/x-pack/plugin/ql/src/main/java/org/elasticsearch/xpack/ql/async/AsyncTaskManagementService.java
index eacb25b10d622..d42f2619a166a 100644
--- a/x-pack/plugin/ql/src/main/java/org/elasticsearch/xpack/ql/async/AsyncTaskManagementService.java
+++ b/x-pack/plugin/ql/src/main/java/org/elasticsearch/xpack/ql/async/AsyncTaskManagementService.java
@@ -170,20 +170,22 @@ public void asyncExecute(
         ActionListener<Response> listener
     ) {
         String nodeId = clusterService.localNode().getId();
-        @SuppressWarnings("unchecked")
-        T searchTask = (T) taskManager.register("transport", action + "[a]", new AsyncRequestWrapper(request, nodeId));
-        boolean operationStarted = false;
-        try {
-            operation.execute(
-                request,
-                searchTask,
-                wrapStoringListener(searchTask, waitForCompletionTimeout, keepAlive, keepOnCompletion, listener)
-            );
-            operationStarted = true;
-        } finally {
-            // If we didn't start operation for any reason, we need to clean up the task that we have created
-            if (operationStarted == false) {
-                taskManager.unregister(searchTask);
+        try (var ignored = threadPool.getThreadContext().newTraceContext()) {
+            @SuppressWarnings("unchecked")
+            T searchTask = (T) taskManager.register("transport", action + "[a]", new AsyncRequestWrapper(request, nodeId));
+            boolean operationStarted = false;
+            try {
+                operation.execute(
+                    request,
+                    searchTask,
+                    wrapStoringListener(searchTask, waitForCompletionTimeout, keepAlive, keepOnCompletion, listener)
+                );
+                operationStarted = true;
+            } finally {
+                // If we didn't start operation for any reason, we need to clean up the task that we have created
+                if (operationStarted == false) {
+                    taskManager.unregister(searchTask);
+                }
             }
         }
     }