From 0c04a8d30163a03228f166e3efee8de701830e8c Mon Sep 17 00:00:00 2001 From: dianbofa <124864101+dianbofa@users.noreply.github.com> Date: Thu, 8 May 2025 23:39:55 +0800 Subject: [PATCH] feat(core): Add queue_name parameter to Job.enqueue() method (#19424) --- netbox/core/models/jobs.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/netbox/core/models/jobs.py b/netbox/core/models/jobs.py index 8c704ecad..779e767b6 100644 --- a/netbox/core/models/jobs.py +++ b/netbox/core/models/jobs.py @@ -215,6 +215,7 @@ class Job(models.Model): schedule_at=None, interval=None, immediate=False, + queue_name=None, **kwargs ): """ @@ -238,7 +239,7 @@ class Job(models.Model): object_id = instance.pk else: object_type = object_id = None - rq_queue_name = get_queue_for_model(object_type.model if object_type else None) + rq_queue_name = queue_name if queue_name else get_queue_for_model(object_type.model if object_type else None) queue = django_rq.get_queue(rq_queue_name) status = JobStatusChoices.STATUS_SCHEDULED if schedule_at else JobStatusChoices.STATUS_PENDING job = Job(