From 259cb5acc03a1085bad7e2b470223db48bb2b188 Mon Sep 17 00:00:00 2001 From: jchambers2012 Date: Tue, 11 Jun 2024 15:38:31 -0400 Subject: [PATCH] Update jobs.py add rq_queue_name --- netbox/core/models/jobs.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/netbox/core/models/jobs.py b/netbox/core/models/jobs.py index b9f0d0b91..2c11f8464 100644 --- a/netbox/core/models/jobs.py +++ b/netbox/core/models/jobs.py @@ -198,7 +198,7 @@ class Job(models.Model): job_end.send(self) @classmethod - def enqueue(cls, func, instance, name='', user=None, schedule_at=None, interval=None, **kwargs): + def enqueue(cls, func, instance, name='', user=None, schedule_at=None, interval=None,rq_queue_name=None, **kwargs): """ Create a Job instance and enqueue a job using the given callable @@ -211,7 +211,8 @@ class Job(models.Model): interval: Recurrence interval (in minutes) """ object_type = ObjectType.objects.get_for_model(instance, for_concrete_model=False) - rq_queue_name = get_queue_for_model(object_type.model) + if rq_queue_name == None: + rq_queue_name = get_queue_for_model(object_type.model) queue = django_rq.get_queue(rq_queue_name) status = JobStatusChoices.STATUS_SCHEDULED if schedule_at else JobStatusChoices.STATUS_PENDING job = Job.objects.create(