Merge pull request #2290 from aboutcode-org/share-django-cache

fix: use shared cache backend across WSGI workers

Author: keshav-space

vulnerabilities/templates/pipeline_dashboard.html

@@ -86,13 +86,13 @@ <h1>Pipeline Dashboard</h1>
                                             worker{{ additional|pluralize }} for the {{ queue_name }} queue.">
                                         <span class="icon"><i class="fa fa-exclamation-triangle"></i></span>
                                     </span>
-                                {% elif load_factor < 1 %}
+                                {% elif additional < 1 %}
                                     <span class="has-text-weight-bold is-size-6 has-text-success has-tooltip-arrow has-tooltip-multiline has-tooltip-success"
                                             data-tooltip="{{ queue_name|capfirst }} queue perfectly balanced.">
                                         {{ load_factor|floatformat:2 }}
                                         <span class="icon"><i class="fa fa-check-circle"></i></span>
                                     </span>
-                                {% elif load_factor < 1.6 %}
+                                {% elif additional < 2 %}
                                     <span class="has-text-weight-bold is-size-6 has-text-orange has-tooltip-arrow has-tooltip-multiline has-tooltip-orange"
                                     data-tooltip="Consider adding {{ additional }} additional worker{{ additional|pluralize }} to the {{ queue_name }} queue.">
                                         {{ load_factor|floatformat:2 }}

vulnerabilities/views.py

@@ -59,8 +59,6 @@
 
 PAGE_SIZE = 10
 
-CACHE_TIMEOUT = 60 * 5
-
 
 class VulnerableCodeView(View):
     """
@@ -965,11 +963,12 @@ def get_queryset(self):
 
     def get_context_data(self, **kwargs):
         context = super().get_context_data(**kwargs)
+        cache_timeout = 60 * 10
         load_per_queue = cache.get("load_per_queue")
 
         if load_per_queue is None:
             load_per_queue = compute_queue_load_factor()
-            cache.set("load_per_queue", load_per_queue, CACHE_TIMEOUT)
+            cache.set("load_per_queue", load_per_queue, cache_timeout)
 
         context["load_per_queue"] = load_per_queue
         context["active_pipeline_count"] = PipelineSchedule.objects.filter(is_active=True).count()

vulnerablecode/settings.py

@@ -402,6 +402,18 @@
 }
 
 
+vcio_redis_host = env.str("VULNERABLECODE_REDIS_HOST", default=None)
+vcio_redis_port = env.str("VULNERABLECODE_REDIS_PORT", default=None)
+
+if vcio_redis_host and vcio_redis_port:
+    CACHES = {
+        "default": {
+            "BACKEND": "django.core.cache.backends.redis.RedisCache",
+            "LOCATION": f"redis://{vcio_redis_host}:{vcio_redis_port}",
+        }
+    }
+
+
 # FederatedCode integration
 
 FEDERATEDCODE_VULNERABILITIES_REPO = env.str(