From 5530aa6b9e5db69d7ee31dc06e887e795cd7ada2 Mon Sep 17 00:00:00 2001
From: Eduardo Silva <eduardo@eth0.com.br>
Date: Tue, 13 Jan 2026 16:48:55 -0300
Subject: [PATCH] filter worker statuses by recent wireguard status update time
 in cluster cache function

---
 api/views.py | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git a/api/views.py b/api/views.py
index c179602..25e4e7e 100644
--- a/api/views.py
+++ b/api/views.py
@@ -4,6 +4,7 @@ import os
 import subprocess
 import time
 import uuid
+from datetime import timedelta
 from typing import Any, Dict
 
 import pytz
@@ -13,7 +14,6 @@ from django.contrib import auth
 from django.contrib.auth.decorators import login_required
 from django.contrib.auth.models import User
 from django.core.exceptions import PermissionDenied
-from django.db import transaction
 from django.http import HttpResponseForbidden
 from django.http import JsonResponse
 from django.shortcuts import get_object_or_404, redirect
@@ -326,7 +326,6 @@ def _latest_handshake_as_int(peer_info) -> int:
         return 0
 
 
-@transaction.atomic
 def func_concatenate_cluster_wireguard_status_cache() -> None:
     start_time = time.monotonic()
 
@@ -341,7 +340,10 @@ def func_concatenate_cluster_wireguard_status_cache() -> None:
     if master_cache and isinstance(master_cache.data, dict):
         cache_entries.append({"source_name": "master", "source_uuid": "", "data": master_cache.data,})
 
-    worker_statuses = (WorkerStatus.objects.filter(worker__enabled=True).select_related("worker").all())
+    worker_statuses = (WorkerStatus.objects.filter(
+        worker__enabled=True, wireguard_status_updated__gt=timezone.now() - timedelta(minutes=10)
+    ).select_related("worker").all())
+
     for ws in worker_statuses:
         cache_entries.append(
             {