NeoAnd/netbox
1
0
Fork 0
mirror of https://github.com/netbox-community/netbox.git synced 2025-07-16 12:12:53 -06:00
Code Issues Actions 11 Packages Projects Releases Wiki Activity

feat(core): Add queue_name parameter to Job.enqueue() method (#19424)

Browse Source
This commit is contained in:
dianbofa 2025-05-08 23:39:55 +08:00 committed by GitHub
parent 6665810a6d
commit 0c04a8d301
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
netbox/core/models/jobs.py
View File

@ -215,6 +215,7 @@ class Job(models.Model):
schedule_at=None, schedule_at=None,
interval=None, interval=None,
immediate=False, immediate=False,
queue_name=None,
**kwargs **kwargs
): ):
""" """
@ -238,7 +239,7 @@ class Job(models.Model):
object_id = instance.pk object_id = instance.pk
else: else:
object_type = object_id = None 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) queue = django_rq.get_queue(rq_queue_name)
status = JobStatusChoices.STATUS_SCHEDULED if schedule_at else JobStatusChoices.STATUS_PENDING status = JobStatusChoices.STATUS_SCHEDULED if schedule_at else JobStatusChoices.STATUS_PENDING
job = Job( job = Job(