From d7ad727a0fca1f4b1339b29e2cb33c104bbc3ae7 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 7f421952ce51..b8f122e6889e 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 {