diff --git a/django_q/conf.py b/django_q/conf.py index 58989d4..3ba9e23 100644 --- a/django_q/conf.py +++ b/django_q/conf.py @@ -1,4 +1,5 @@ import logging +from copy import deepcopy from signal import signal from multiprocessing import cpu_count, Queue @@ -50,6 +51,9 @@ class Conf(object): # ORM broker ORM = conf.get('orm', None) + # Custom broker + BROKER = conf.get('broker', None) + # Database Poll POLL = conf.get('poll', 0.2) @@ -169,7 +173,7 @@ if not logger.handlers: # rollbar if Conf.ROLLBAR: - rollbar_conf = Conf.ROLLBAR + rollbar_conf = deepcopy(Conf.ROLLBAR) try: import rollbar rollbar.init(rollbar_conf.pop('access_token'), environment=rollbar_conf.pop('environment'), **rollbar_conf) @@ -180,9 +184,6 @@ else: rollbar = None - - - # get parent pid compatibility def get_ppid(): if hasattr(os, 'getppid'):