4
4
from django .conf import settings
5
5
from django .core .exceptions import ImproperlyConfigured
6
6
7
- from scheduler .settings_types import SchedulerConfig , Broker , QueueConfiguration
7
+ from scheduler .settings_types import SchedulerConfiguration , Broker , QueueConfiguration
8
8
9
9
logger = logging .getLogger ("scheduler" )
10
10
logging .basicConfig (level = logging .DEBUG )
11
11
12
12
_QUEUES : Dict [str , QueueConfiguration ] = dict ()
13
- SCHEDULER_CONFIG : SchedulerConfig = SchedulerConfig ()
13
+ SCHEDULER_CONFIG : SchedulerConfiguration = SchedulerConfiguration ()
14
14
15
15
16
16
class QueueNotFoundError (Exception ):
@@ -35,14 +35,15 @@ def conf_settings():
35
35
_QUEUES [queue_name ] = QueueConfiguration (** queue_config )
36
36
37
37
user_settings = getattr (settings , "SCHEDULER_CONFIG" , {})
38
- if "FAKEREDIS" in user_settings :
39
- logger .warning ("Configuration using FAKEREDIS is deprecated. Use BROKER='fakeredis' instead" )
40
- user_settings ["BROKER" ] = Broker .FAKEREDIS if user_settings ["FAKEREDIS" ] else Broker .REDIS
41
- user_settings .pop ("FAKEREDIS" )
42
- for k in user_settings :
43
- if k not in SCHEDULER_CONFIG .__annotations__ :
44
- raise ImproperlyConfigured (f"Unknown setting { k } in SCHEDULER_CONFIG" )
45
- setattr (SCHEDULER_CONFIG , k , user_settings [k ])
38
+ if isinstance (user_settings , dict ):
39
+ if "FAKEREDIS" in user_settings :
40
+ logger .warning ("Configuration using FAKEREDIS is deprecated. Use BROKER='fakeredis' instead" )
41
+ user_settings ["BROKER" ] = Broker .FAKEREDIS if user_settings ["FAKEREDIS" ] else Broker .REDIS
42
+ user_settings .pop ("FAKEREDIS" )
43
+ for k in user_settings :
44
+ if k not in SCHEDULER_CONFIG .__annotations__ :
45
+ raise ImproperlyConfigured (f"Unknown setting { k } in SCHEDULER_CONFIG" )
46
+ setattr (SCHEDULER_CONFIG , k , user_settings [k ])
46
47
47
48
48
49
conf_settings ()
0 commit comments