From 004fe99a28850f0cd957d354cb56758bb9dca515 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 b3e159624904..8f5bb4064891 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 {