From 9c9c7e80e59d57dd787331ae20111043f1bba3c4 Mon Sep 17 00:00:00 2001 From: Hongze Zhang Date: Sat, 14 Sep 2024 17:10:24 +0800 Subject: [PATCH] [oap] Expose Task::numThreads() --- velox/exec/Task.h | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/velox/exec/Task.h b/velox/exec/Task.h index 9d66c1e1548c..0ae89e795528 100644 --- a/velox/exec/Task.h +++ b/velox/exec/Task.h @@ -681,6 +681,10 @@ class Task : public std::enable_shared_from_this { terminate(TaskState::kFinished).wait(); } + int32_t numThreads() { + return numThreads_; + } + private: // Hook of system-wide running task list. struct TaskListEntry {