mirror/netbox-community-netbox
1
0
Fork 0
mirror of https://github.com/netbox-community/netbox.git synced 2024-05-10 07:54:54 +00:00
Code Activity

Log a warning when rqworker invoked without specified queues

Browse Source
This commit is contained in:
jeremystretch
2021-07-09 21:23:27 -04:00
parent d3b4a72f4f
commit fe1f221286
1 changed files with 12 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
netbox/extras/management/commands/rqworker.py
View File

@ -1,7 +1,13 @@
from django.conf import settings import logging
from django_rq.management.commands.rqworker import Command as _Command from django_rq.management.commands.rqworker import Command as _Command
DEFAULT_QUEUES = ('high', 'default', 'low')
logger = logging.getLogger('netbox.rqworker')
class Command(_Command): class Command(_Command):
""" """
Subclass django_rq's built-in rqworker to listen on all configured queues if none are specified (instead Subclass django_rq's built-in rqworker to listen on all configured queues if none are specified (instead
@ -11,6 +17,10 @@ class Command(_Command):
# If no queues have been specified on the command line, listen on all configured queues. # If no queues have been specified on the command line, listen on all configured queues.
if len(args) < 1: if len(args) < 1:
args = settings.RQ_QUEUES queues = ', '.join(DEFAULT_QUEUES)
logger.warning(
f"No queues have been specified. This process will service the following queues by default: {queues}"
)
args = DEFAULT_QUEUES
super().handle(*args, **options) super().handle(*args, **options)