From fa9d7eaba9f93b14661f71b3c1cb29c2963a8763 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 11bb852f56b6..3ad9c10e4745 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 {