fixes

golemfactory · Sep 25, 2024 · ed06109 · ed06109
1 parent 269fc37
commit ed06109
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 6 deletions.
diff --git a/stats-backend/api2/scoring.py b/stats-backend/api2/scoring.py
@@ -4,6 +4,8 @@
 
 
 def calculate_uptime_percentage(node_id, node=None):
+    if node is None:
+        node = Node.objects.get(node_id=node_id)
     statuses = NodeStatusHistory.objects.filter(node_id=node_id).order_by("timestamp")
 
     online_duration = timedelta(0)

diff --git a/stats-backend/api2/tasks.py b/stats-backend/api2/tasks.py
@@ -1911,6 +1911,7 @@ def fetch_and_update_relay_nodes_online_status():
     missing_nodes = previously_online - current_online_nodes
     if missing_nodes:
         check_missing_nodes.delay(list(missing_nodes))
+    fetch_and_store_relay_nodes.apply_async(countdown=15)
 
 
 @app.task

diff --git a/stats-backend/core/celery.py b/stats-backend/core/celery.py
@@ -76,12 +76,7 @@ def setup_periodic_tasks(sender, **kwargs):
         extract_wallets_and_ids,
         fetch_and_update_relay_nodes_online_status,
     )
-    sender.add_periodic_task(
-        30.0,
-        fetch_and_update_relay_nodes_online_status.s(),
-        queue="default",
-        options={"queue": "default", "routing_key": "default"},
-    )
+    fetch_and_store_relay_nodes.delay()
     sender.add_periodic_task(
         60,
         computing_total_over_time.s(),