598
599
if pm.partition.IsRoot() {
600
>
// Only emit the no-recent-poller metric if BOTH conditions are met:
task_queue_partition_manager.go
601
>
// 1. Partition has been loaded for more than noPollerThreshold (2 minutes)
602
>
// 2. No pollers have polled in the last noPollerThreshold (2 minutes)
603
>
// This prevents false positives for newly loaded partitions that haven't had time to receive pollers yet.
604
>
if time.Since(pm.loadTime) > noPollerThreshold && !pm.HasAnyPollerAfter(time.Now().Add(-noPollerThreshold)) {
605
pm.metricsHandler.Counter(metrics.NoRecentPollerTasksPerTaskQueueCounter.Name()).Record(1)
606
}