From 16fe96651f037303b272b914a1bad4b7a4db1a0c 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 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 { terminate(TaskState::kFinished).wait(); } + int32_t numThreads() { + return numThreads_; + } + private: // Hook of system-wide running task list. struct TaskListEntry {