add a hourly cron to evaluate all rules

Signed-off-by: tdruez <tdruez@aboutcode.org>

Author: tdruez

dejacode/settings.py

@@ -475,7 +475,9 @@ def gettext_noop(s):
 
 # Cron jobs (scheduler)
 daily_at_3am = "0 3 * * *"
+hourly = "0 * * * *"
 DEJACODE_VULNERABILITIES_CRON = env.str("DEJACODE_VULNERABILITIES_CRON", default=daily_at_3am)
+DEJACODE_POLICY_RULES_CRON = env.str("DEJACODE_POLICY_RULES_CRON", default=hourly)
 
 
 def enable_rq_eager_mode():

dje/cron_jobs.py

@@ -11,6 +11,7 @@
 from rq import cron
 
 from dje.tasks import update_vulnerabilities
+from policy.tasks import evaluate_all_products_rules_task
 
 two_hour = 7200
 
@@ -20,3 +21,10 @@
     cron=settings.DEJACODE_VULNERABILITIES_CRON,  # Daily at 3am by default
     job_timeout=two_hour,
 )
+
+cron.register(
+    func=evaluate_all_products_rules_task,
+    queue_name="default",
+    cron=settings.DEJACODE_POLICY_RULES_CRON,  # Hourly by default
+    job_timeout=two_hour,
+)

policy/rules.py

@@ -35,10 +35,14 @@ class PackageBaseRule(BaseRule):
     def count_violations(self, product, threshold, parameters):
         Package = apps.get_model("component_catalog", "package")
 
-        count = Package.objects.filter(
-            productpackages__product=product,
-            **self.package_filter,
-        ).distinct().count()
+        count = (
+            Package.objects.filter(
+                productpackages__product=product,
+                **self.package_filter,
+            )
+            .distinct()
+            .count()
+        )
 
         return count if count > threshold else 0