diff --git a/velox/exec/Task.h b/velox/exec/Task.h
index 526ab710400c..0f266f67d738 100644
--- a/velox/exec/Task.h
+++ b/velox/exec/Task.h
@@ -681,6 +681,10 @@ class Task : public std::enable_shared_from_this<Task> {
     terminate(TaskState::kFinished).wait();
   }
 
+  int32_t numThreads() {
+    return numThreads_;
+  }
+
  private:
   // Hook of system-wide running task list.
   struct TaskListEntry {