|
|
@@ -13,21 +13,22 @@ import celery
|
|
|
from celery.signals import celeryd_init
|
|
|
from celery import signals
|
|
|
|
|
|
+from click import Option
|
|
|
|
|
|
-app = Celery('tasks', backend ='redis://172.104.92.245', broker='redis://172.104.92.245')
|
|
|
-qname=None
|
|
|
|
|
|
-def add_preload_options(parser):
|
|
|
- parser.add_argument(
|
|
|
- "-Z", "--template", default="default", help="Configuration template to use.",
|
|
|
- )
|
|
|
|
|
|
-app.user_options["preload"].add(add_preload_options)
|
|
|
+app = Celery('tasks', backend ='redis://172.104.92.245', broker='redis://172.104.92.245')
|
|
|
+qname=None
|
|
|
|
|
|
+app.user_options['preload'].add(Option(('-Z', '--template'),
|
|
|
+ default='default',
|
|
|
+ help='Configuration template to use.'))
|
|
|
|
|
|
@signals.user_preload_options.connect
|
|
|
def on_preload_parsed(options, **kwargs):
|
|
|
- print(options["template"])
|
|
|
+ print(options['template'])
|
|
|
+ print(options)
|
|
|
+
|
|
|
|
|
|
@celeryd_init.connect
|
|
|
def configure_workers(sender=None, **kwargs):
|
