feat: remove job from redis before deleting the run

Signed-off-by: Keshav Priyadarshi <git@keshav.space>

Author: keshav-space

vulnerabilities/models.py

@@ -14,6 +14,7 @@
 import xml.etree.ElementTree as ET
 from contextlib import suppress
 from functools import cached_property
+from inspect import cleandoc
 from itertools import groupby
 from operator import attrgetter
 from traceback import format_exc as traceback_format_exc
@@ -2073,7 +2074,7 @@ def pipeline_class(self):
 
     @property
     def job(self):
-        with suppress(NoSuchJobError):
+        with suppress(redis.exceptions.ConnectionError, NoSuchJobError):
             return Job.fetch(
                 str(self.run_id),
                 connection=django_rq.get_connection(),
@@ -2219,20 +2220,19 @@ def stop_run(self):
         )
         self.set_run_stopped()
 
-    def delete_run(self, delete_self=True):
+    def delete_run(self):
         if job := self.job:
             job.delete()
 
-        if delete_self:
-            self.delete()
-
     def delete(self, *args, **kwargs):
         """
         Before deletion of the run instance, try to stop the run execution.
         """
         with suppress(redis.exceptions.ConnectionError, AttributeError):
             self.stop_run()
 
+        self.delete_run()
+
         return super().delete(*args, **kwargs)
 
     def append_to_log(self, message, is_multiline=False):
@@ -2366,16 +2366,20 @@ def pipeline_class(self):
         from vulnerabilities.importers import IMPORTERS_REGISTRY
         from vulnerabilities.improvers import IMPROVERS_REGISTRY
         from vulnerabilities.pipelines.exporters import EXPORTERS_REGISTRY
+        from vulnerabilities.pipelines.management import MANAGEMENT_REGISTRY
 
-        pipeline_registry = IMPORTERS_REGISTRY | IMPROVERS_REGISTRY | EXPORTERS_REGISTRY
+        pipeline_registry = (
+            IMPORTERS_REGISTRY | IMPROVERS_REGISTRY | EXPORTERS_REGISTRY | MANAGEMENT_REGISTRY
+        )
 
         return pipeline_registry[self.pipeline_id]
 
     @property
     def description(self):
         """Return the pipeline class."""
+
         if self.pipeline_class:
-            return self.pipeline_class.__doc__
+            return cleandoc(self.pipeline_class.__doc__ or "")
 
     @property
     def all_runs(self):