Update tasks.py

golemfactory · Nov 4, 2024 · ebf0706 · ebf0706
1 parent 7eb7dc4
commit ebf0706
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/stats-backend/api2/tasks.py b/stats-backend/api2/tasks.py
@@ -1854,3 +1854,14 @@ def bulk_update_node_statuses(nodes_data):
 
         # Bulk create status history
         NodeStatusHistory.objects.bulk_create(status_history_to_create)
+
+        #Clean up duplicate consecutive statuses !IMPORTANT KEEP HERE FOR NOW
+        subquery = NodeStatusHistory.objects.filter(
+            node_id=OuterRef('node_id'),
+            timestamp__lt=OuterRef('timestamp')
+        ).order_by('-timestamp')
+
+        duplicate_records = NodeStatusHistory.objects.annotate(
+            prev_status=Subquery(subquery.values('is_online')[:1])
+        ).filter(is_online=F('prev_status'))
+        duplicate_records.delete()