fixing synthax and format

Author: IdirLISN

src/apps/competitions/tasks.py

@@ -43,6 +43,7 @@
 from asgiref.sync import async_to_sync
 
 import logging
+
 logger = logging.getLogger(__name__)
 
 r = get_redis_connection("default")
@@ -940,9 +941,8 @@ def refresh_compute_worker_health():
         if not is_compute_worker:
             continue
 
-        running_jobs = (
-            len(active.get(worker_name, []))
-            + len(reserved.get(worker_name, []))
+        running_jobs = len(active.get(worker_name, [])) + len(
+            reserved.get(worker_name, [])
         )
         status = "busy" if running_jobs > 0 else "available"
 
@@ -964,15 +964,17 @@ def refresh_compute_worker_health():
         r.hset(
             WORKERS_REGISTRY_KEY,
             worker_name,
-            json.dumps({
-                "hostname": worker_name,
-                "status": status,
-                "running_jobs": running_jobs,
-                "last_seen": payload["timestamp"],
-            }),
+            json.dumps(
+                {
+                    "hostname": worker_name,
+                    "status": status,
+                    "running_jobs": running_jobs,
+                    "last_seen": payload["timestamp"],
+                }
+            ),
         )
 
         _broadcast_worker_state(payload)
         logger.info(
             f"[WORKER-HEALTH] {worker_name} status={status} jobs={running_jobs}"
-        )
+        )

src/celery_config.py

@@ -42,9 +42,10 @@ def app_for_vhost(vhost):
         _vhost_apps[vhost] = vhost_app
     return _vhost_apps[vhost]
 
+
 app.conf.beat_schedule = {
     "refresh-compute-worker-health": {
         "task": "apps.competitions.tasks.refresh_compute_worker_health",
         "schedule": 3.0,
     },
-}
+}

src/utils/consumers.py

@@ -79,9 +79,8 @@ def _load_snapshot(self):
             if not is_compute_worker:
                 continue
 
-            running_jobs = (
-                len(active.get(worker_name, []))
-                + len(reserved.get(worker_name, []))
+            running_jobs = len(active.get(worker_name, [])) + len(
+                reserved.get(worker_name, [])
             )
             status = "busy" if running_jobs > 0 else "available"
 
@@ -94,4 +93,4 @@ def _load_snapshot(self):
                 }
             )
 
-        return workers
+        return workers