mirror of
https://github.com/netbox-community/netbox.git
synced 2025-08-08 16:48:16 -06:00
Add logging for django_rq errors
This commit is contained in:
parent
e2f2799f73
commit
d34a87f591
@ -1,3 +1,4 @@
|
|||||||
|
import logging
|
||||||
import uuid
|
import uuid
|
||||||
|
|
||||||
import django_rq
|
import django_rq
|
||||||
@ -24,6 +25,7 @@ __all__ = (
|
|||||||
'Job',
|
'Job',
|
||||||
)
|
)
|
||||||
|
|
||||||
|
logger = logging.getLogger('netbox.core.jobs')
|
||||||
|
|
||||||
class Job(models.Model):
|
class Job(models.Model):
|
||||||
"""
|
"""
|
||||||
@ -222,8 +224,7 @@ class Job(models.Model):
|
|||||||
try:
|
try:
|
||||||
queue = django_rq.get_queue(rq_queue_name)
|
queue = django_rq.get_queue(rq_queue_name)
|
||||||
except Exception:
|
except Exception:
|
||||||
# User defined queue casued an error - return to default logic
|
logger.warning(f"User defined queue '{rq_queue_name}' cased an error or was not found. Falling back to default queue.")
|
||||||
pass
|
|
||||||
if not queue:
|
if not queue:
|
||||||
rq_queue_name = get_queue_for_model(object_type.model)
|
rq_queue_name = get_queue_for_model(object_type.model)
|
||||||
queue = django_rq.get_queue(rq_queue_name)
|
queue = django_rq.get_queue(rq_queue_name)
|
||||||
|
Loading…
Reference in New Issue
Block a user