Переглянути джерело

Get the queue from QUEUE_MAPPINGS when deleting JobResults

kkthxbye 3 роки тому
батько
коміт
1354947434
1 змінених файлів з 2 додано та 1 видалено
  1. 2 1
      netbox/extras/models/models.py

+ 2 - 1
netbox/extras/models/models.py

@@ -634,7 +634,8 @@ class JobResult(models.Model):
     def delete(self, *args, **kwargs):
         super().delete(*args, **kwargs)
 
-        queue = django_rq.get_queue("default")
+        rq_queue_name = get_config().QUEUE_MAPPINGS.get(self.obj_type.name, RQ_QUEUE_DEFAULT)
+        queue = django_rq.get_queue(rq_queue_name)
         job = queue.fetch_job(str(self.job_id))
 
         if job: