Expose worker tracked tasks count

trinodb · Jan 8, 2025 · c219ffd · c219ffd
1 parent b27dd3b
commit c219ffd
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/core/trino-main/src/main/java/io/trino/execution/SqlTaskManager.java b/core/trino-main/src/main/java/io/trino/execution/SqlTaskManager.java
@@ -359,6 +359,12 @@ public ThreadPoolExecutorMBean getTaskNotificationExecutor()
         return taskNotificationExecutorMBean;
     }
 
+    @Managed(description = "Tracked tasks count")
+    public long getTrackedTasksCount()
+    {
+        return tasks.size();
+    }
+
     @Managed(description = "Created tasks counter")
     @Nested
     public CounterStat getCreatedTasks()