Show More
@@ -14,6 +14,8 To make sure that the config really has | |||||
14 | mandatory settings. |
|
14 | mandatory settings. | |
15 | """ |
|
15 | """ | |
16 |
|
16 | |||
|
17 | import logging | |||
|
18 | ||||
17 | import celery |
|
19 | import celery | |
18 | import tg |
|
20 | import tg | |
19 |
|
21 | |||
@@ -25,6 +27,16 class CeleryConfig(object): | |||||
25 | CELERY_TASK_SERIALIZER = 'json' |
|
27 | CELERY_TASK_SERIALIZER = 'json' | |
26 |
|
28 | |||
27 |
|
29 | |||
|
30 | desupported = set([ | |||
|
31 | 'celery.result.dburi', | |||
|
32 | 'celery.result.serialier', | |||
|
33 | 'celery.send.task.error.emails', | |||
|
34 | ]) | |||
|
35 | ||||
|
36 | ||||
|
37 | log = logging.getLogger(__name__) | |||
|
38 | ||||
|
39 | ||||
28 | def celery_config(config): |
|
40 | def celery_config(config): | |
29 | """Return Celery config object populated from relevant settings in a config dict, such as tg.config""" |
|
41 | """Return Celery config object populated from relevant settings in a config dict, such as tg.config""" | |
30 |
|
42 | |||
@@ -34,6 +46,8 def celery_config(config): | |||||
34 | LIST_PARAMS = """CELERY_IMPORTS CELERY_ACCEPT_CONTENT""".split() |
|
46 | LIST_PARAMS = """CELERY_IMPORTS CELERY_ACCEPT_CONTENT""".split() | |
35 |
|
47 | |||
36 | for config_key, config_value in sorted(config.items()): |
|
48 | for config_key, config_value in sorted(config.items()): | |
|
49 | if config_key in desupported and config_value: | |||
|
50 | log.error('Celery configuration setting %r is no longer supported', config_key) | |||
37 | celery_key = config_key.replace('.', '_').upper() |
|
51 | celery_key = config_key.replace('.', '_').upper() | |
38 | if celery_key.split('_', 1)[0] not in PREFIXES: |
|
52 | if celery_key.split('_', 1)[0] not in PREFIXES: | |
39 | continue |
|
53 | continue |
General Comments 0
You need to be logged in to leave comments.
Login now