Skip to content

Commit 0c04a8d

Browse files
authored
feat(core): Add queue_name parameter to Job.enqueue() method (#19424)
1 parent 6665810 commit 0c04a8d

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

netbox/core/models/jobs.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -215,6 +215,7 @@ def enqueue(
215215
schedule_at=None,
216216
interval=None,
217217
immediate=False,
218+
queue_name=None,
218219
**kwargs
219220
):
220221
"""
@@ -238,7 +239,7 @@ def enqueue(
238239
object_id = instance.pk
239240
else:
240241
object_type = object_id = None
241-
rq_queue_name = get_queue_for_model(object_type.model if object_type else None)
242+
rq_queue_name = queue_name if queue_name else get_queue_for_model(object_type.model if object_type else None)
242243
queue = django_rq.get_queue(rq_queue_name)
243244
status = JobStatusChoices.STATUS_SCHEDULED if schedule_at else JobStatusChoices.STATUS_PENDING
244245
job = Job(

0 commit comments

Comments
 (0)